socket的多线程实现

步骤：

　　1、服务端创建ServerSocket，循环调用accept()等待客户端连接；

　　2、客户端创建socket并请求与服务端对话；

　　3、服务端接收客户端的请求，创建socket与客户端进行专线连接；

　　4、服务端监测是否接收到消息，长时间没有接收到消息则关闭连接；

　　public class ServerSocketThread extends Thread{

　　private Socket socket = null;

　　public ServerSocketThread (Socket socket){
　　this.socket = socket;
　　}
　　@Override
　　public void run(){
　　　　try {
　　　　　　InputStream inputStream = socket.getInputStream();
　　　　　　OutputStream outputStream = socket.getOutputStream();
　　　　　　BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(inputStream));
　　　　　　if(bufferedReader.readLine()!=null){
　　　　　　　　String read = bufferedReader.readLine();
　　　　　　　　System.out.println(read);
　　　　　　　　System.out.println(str2HexStr(read));
　　　　　　}
　　　　/**
　　　　* 关闭输出流
　　　　*/
　　　　socket.shutdownOutput();


　　　　/**
　　　　* 关闭相对应的资源
　　　　*/
　　　　outputStream.close();
　　　　bufferedReader.close();
　　　　inputStream.close();
　　　　socket.close();
　　　　} catch (IOException e) {
　　　　e.printStackTrace();
　　　　}


　　}
}

public class SocketServer {
　　public static void main(String[] args) {
　　　　try {
　　　　　　ServerSocket serverSocket = new ServerSocket(8888);
　　　　　　Socket socket = null;
　　　　　　int clientCount = 0;

　　　　　　while(true){
　　　　　　　　socket = serverSocket.accept();
　　　　　　　　ServerSocketThread serverSocketThread = new ServerSocketThread(socket);
　　　　　　　　serverSocketThread.start();
　　　　　　　　clientCount++;
　　　　　　　　System.out.println("客户端数量为："+clientCount);
　　　　　　}
　　　　} catch (IOException e) {
　　　　e.printStackTrace();
　　}
　　}
}

原文链接:https://www.cnblogs.com/hssds/p/11683815.html
如有疑问请与原作者联系

标签：

版权申明：本站文章部分自网络，如有侵权，请联系：west999com@outlook.com
特别注意：本站所有转载文章言论不代表本站观点，本站所提供的摄影照片，插画，设计作品，如需使用，请与原作者联系，版权归原作者所有