Commit 5b1ccbe3 authored by xinglei's avatar xinglei

*)修改socket启动

parent dac9e50d
package com.yeejoin.amos.kgd.config;
import org.springframework.context.annotation.Configuration;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;
import javax.annotation.PostConstruct;
import java.io.IOException;
......@@ -12,14 +15,25 @@ import java.net.Socket;
* @Description:
* @Date: 2023/10/9 18:45
*/
@Configuration
@Component
public class SocketConfig {
private static final Logger log = LoggerFactory.getLogger(SocketConfig.class);
@Value("${socket.port}")
private Integer port;
@PostConstruct
public void init() {
public void socketStart() {
//直接另起一个线程挂起Socket服务
new Thread(this::socketServer).start();
}
private void socketServer() {
ServerSocket ss = null;
try {
ss = new ServerSocket(7777);
ss = new ServerSocket(port);
log.info("socket端口在:{}中开启并持续监听=====>", port);
while (true) {
Socket socket = ss.accept();
// 创建新线程处理连接
......
......@@ -53,4 +53,6 @@ spring.servlet.multipart.maxRequestSize=100MB
spring.main.allow-bean-definition-overriding=true
spring.http.encoding.charset=utf-8
spring.http.encoding.enabled=true
spring.http.encoding.force=true
\ No newline at end of file
spring.http.encoding.force=true
socket.port=7777
\ No newline at end of file
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment