TCP通信模型：线程池优化

2022-04-20 21:31:06 阅读：116 来源： 互联网

标签：java socket 通信模型 TCP 线程 io new import Socket

package com.czie.d8_socket;

import java.io.IOException;
import java.io.OutputStream;
import java.io.PrintStream;
import java.net.Socket;
import java.util.Scanner;

/**
 * FileName: CilentDemo
 * Author:   lps
 * Date:     2022/4/20 13:12
 * Sign:刘品水 Q：1944900433
 * 使用线程池优化实现通信
 */
public class CilentDemo {
    public static void main(String[] args) {
        try {
            System.out.println("客户端启动成功");
            //Socket(String host, int port) 创建流套接字并将其连接到指定主机上的指定端口号。
            Socket socket = new Socket("192.168.10.102",22222);
            OutputStream os = socket.getOutputStream();
            //把低级的字节流包装成打印流
            PrintStream ps = new PrintStream(os);
            //发送消息
            Scanner sc = new Scanner(System.in);
            while (true) {
                System.out.println("请说：");
                String msg = sc.nextLine();
                ps.println(msg);
                ps.flush();
            }

            //关闭资源
            //socket.close();

        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

package com.czie.d8_socket;

import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.concurrent.*;

/**
 * FileName: ServerDemo
 * Author:   lps
 * Date:     2022/4/20 13:12
 * Sign:刘品水 Q：1944900433
 */
public class ServerDemo {
    //使用静态变量记住一个线程池对象
    private static ExecutorService pool=new ThreadPoolExecutor(3,5,6,
            TimeUnit.SECONDS,new ArrayBlockingQueue<>(2), Executors.defaultThreadFactory(),
            new ThreadPoolExecutor.AbortPolicy());
    public static void main(String[] args) {
        try {
            System.out.println("服务端启动成功");
            ServerSocket ss = new ServerSocket(22222);
            //定义以恶搞死循环由主线程负责不断接受客户端socket管道链接
            while (true) {
                //每接受一个客户端socket的链接交给一个独立的子线程负责读取信息
                Socket socket = ss.accept();

                System.out.println(socket.getRemoteSocketAddress()+"他来了,潇洒的来了");

                 Runnable target=new ServerReaderRunnable(socket);
                 pool.execute(target);


            }

        } catch (IOException e) {
            e.printStackTrace();
        }


    }
}

package com.czie.d8_socket;

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

/**
 * FileName: ServerReaderRunnable
 * Author:   lps
 * Date:     2022/4/20 20:43
 * Sign:刘品水 Q：1944900433
 */
public class ServerReaderRunnable implements Runnable {
    private Socket socket;
    public ServerReaderRunnable(Socket socket){
        this.socket=socket;
    }
    @Override
    public void run() {
        try {
            InputStream is = socket.getInputStream();
            //包装成缓冲字符输入流
            BufferedReader br = new BufferedReader(new InputStreamReader(is));
            //按照行读取消息
            String msg;
            while ((msg = br.readLine()) != null) {
                System.out.println(socket.getRemoteSocketAddress() + "说了：" + msg);
            }
        } catch (IOException e) {
            System.out.println(socket.getRemoteSocketAddress() + "下线了！！");
        }
    }
}

标签：java,socket,通信模型,TCP,线程,io,new,import,Socket
来源： https://www.cnblogs.com/lps1944900433/p/16171813.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

ICode9

TCP通信模型：线程池优化