基于多线程的TCP socket通信经典案例

Posted 2020-09-14 ThinkVenus

服务器端

package com.thinkvenus.study.socket;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.net.Socket;

/**
 * 服务器端线程处理类
 */
public class ThreadServer extends Thread {
    
    private Socket socket;
    
    public ThreadServer(Socket socket) {
        this.socket = socket;
    }
    
    /**
     * 线程执行的操作，响应客户端请求
     */
    @Override
    public void run() {
        InputStream is = null;
        InputStreamReader isr = null;
        BufferedReader br = null;
        OutputStream os = null;
        PrintWriter pw = null;
        
        try {
            is = socket.getInputStream();
            isr = new InputStreamReader(is);
            br = new BufferedReader(isr);
            String msg;
            while((msg = br.readLine()) != null) {
                System.out.println("这里是服务器端，客户端说：" + msg);
            }
            socket.shutdownInput();//关闭输入
            
            //获取输出流，响应客户端的请求
            os = socket.getOutputStream();
            pw = new PrintWriter(os);
            pw.write("欢迎您");
            pw.flush();
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            
            //关闭资源
            try {
                if(pw != null) pw.close();
                if(os != null) os.close();
                if(br != null) br.close();
                if(isr != null) isr.close();
                if(is != null) is.close();
                if(socket != null) socket.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
            
        }
    }
    
}

 

package com.thinkvenus.study.socket;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;

/**
 * 基于TCP的socket通信
 */

public class Server {
    
    public static void main(String[] args) {
        try {
            ServerSocket serverSocket = new ServerSocket(8888);
            System.out.println("*****************服务端即将启动，等待客户端的连接**********");
            int count = 0;
            //循环监听客户端的连接
            while(true) {
                Socket socket = serverSocket.accept();//开始监听
                ThreadServer ts = new ThreadServer(socket);
                ts.start();
                count++;
                System.out.println("客户端的数量："+count);
            }
            
        } catch (IOException e) {
            e.printStackTrace();
        }
        
    }
    
}

 

客户端：

package com.thinkvenus.study.socket;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.net.Socket;
import java.net.UnknownHostException;

public class Client {
    
    public static void main(String[] args) {
        try {
            Socket socket = new Socket("localhost", 8888);
            OutputStream os = socket.getOutputStream();
            PrintWriter pw = new PrintWriter(os);//将输出流包装为打印流
            pw.println("username=aaron; pwd="+Math.random());
            pw.flush();
            
            socket.shutdownOutput();//关闭输出
            //获取输入流，获取服务器端的响应
            InputStream is = socket.getInputStream();
            InputStreamReader isr = new InputStreamReader(is);
            BufferedReader br = new BufferedReader(isr);
            String msg;
            while((msg = br.readLine()) != null) {
                System.out.println("我是客户端，服务端说："+ msg);
            }
            
            //关闭资源
            br.close();
            isr.close();
            is.close();
            pw.close();
            os.close();
            socket.close();
            
        } catch (UnknownHostException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
    
}