javasocket长连接编码

注意事项&＃xff1a;

1.在springboot项目中启动一个socketServer&＃xff0c;为了防止主次线程的资源竞争&＃xff0c;最好是以线程的方式去实现。
2.在springboot中启动这个线程的时候&＃xff0c;建议采用&＃64;Configuration方式去生成一个bean&＃xff0c;方便以后service bean的注入。

package com.sinosoft.cp.socket;import com.google.common.util.concurrent.ThreadFactoryBuilder;
import com.sinosoft.cp.util.TypeUtil;
import org.nutz.dao.Chain;
import org.nutz.dao.Cnd;
import org.nutz.lang.Lang;
import org.nutz.log.Log;
import org.nutz.log.Logs;import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.concurrent.*;public class SocketServer extends Thread{Log log &＃61; Logs.get();private volatile boolean running &＃61; false;private long receiveTimeDelay &＃61; 1000*30;private ThreadFactory namedThreadFactory &＃61; new ThreadFactoryBuilder().setNameFormat("demo-pool-%d").build();private ExecutorService pool &＃61; new ThreadPoolExecutor(5, 200,0L, TimeUnit.MILLISECONDS,new LinkedBlockingQueue(1024), namedThreadFactory, new ThreadPoolExecutor.AbortPolicy());ServerSocket serverSocket &＃61; null;Socket socket &＃61; null;private Integer port;&＃64;Overridepublic void run() {super.run();startServer();}public SocketServer(int port) {this.port&＃61;port;}public void startServer() {if (running) {return;}running &＃61; true;try {serverSocket &＃61; new ServerSocket(port);System.out.println("server started...");while (true) {socket &＃61; serverSocket.accept();//程序阻塞&＃xff0c;等待客户端的接入managerConnection(socket);}} catch (Exception e) {e.printStackTrace();} finally {try {serverSocket.close();socket.close();pool.shutdown();} catch (Exception e) {e.printStackTrace();}}}/*** 管理服务器与客户端的连接** &＃64;param socket*/public void managerConnection(final Socket socket) {//每一个客户端连接都开启一个子线程pool.execute(new Runnable() {Socket s;boolean run &＃61; true;long lastReceiveTime &＃61; System.currentTimeMillis();private void overThis() {if (run) {run &＃61; false;}if (s !&＃61; null) {try {s.close();} catch (IOException e) {e.printStackTrace();}}}&＃64;Overridepublic void run() {while (running && run) {if (System.currentTimeMillis() - lastReceiveTime > receiveTimeDelay) {overThis();} else {DataInputStream reader &＃61; null;BufferedWriter writer &＃61; null;try {reader &＃61; new DataInputStream(new BufferedInputStream(socket.getInputStream()));writer &＃61; new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));while (reader.available() > 0) {lastReceiveTime &＃61; System.currentTimeMillis();doService(reader, writer);}} catch (IOException e) {e.printStackTrace();overThis();}}}}});}public void doService(DataInputStream reader, BufferedWriter writer) {};}