Java使用线程池实现socket编程的方法详解

更新时间：2022年03月30日 14:28:07 作者：宋振嘉

这篇文章主要为大家详细介绍了Java使用线程池实现socket编程的方法，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下，希望能够给你带来帮助

前言

以多个客户端和一个服务端的socket通信为例，服务端启动时创建一个固定大小的线程池。服务端每接收到一个连接请求后（通信任务），交给线程池执行，任务类实现了Runnable接口，用于跟客户端进行读写操作，该类的对象作为任务通过execute(Runnable task)提交给线程池。

一、一个简单的C/S模型实现

1.服务器：

import java.io.InputStream;
import java.net.ServerSocket;
import java.net.Socket;
public class Server {
    public static void main(String[] args) throws Exception {
        System.out.println("server start");
        ServerSocket server = new ServerSocket(1003);
        while (true) {
            Socket client = server.accept();
            InputStream input = client.getInputStream();
            byte[] b = new byte[8196];
            int len = input.read(b);
            System.out.println(new String(b, 0, len));
            if(new String(b).equals("close"))
                break;
            client.close();
        }
        server.close();
    }
}

2.客户端：

import java.io.OutputStream;
import java.net.Socket;
import java.util.Scanner;
public class Client {
    public static void main(String[] args) throws Exception {
        System.out.println("client start");
        Scanner scanner =new Scanner(System.in);
        Socket client =new Socket("localhost",1003);
        OutputStream out = client.getOutputStream();
        while (true) {
            String str = scanner.nextLine();
            out.write(str.getBytes());
        }
    }
}

此处只能服务器接收客户端信息。

二、线程池使用方法

1.新建一个线程池

ExecutorService pool = Executors.newFixedThreadPool(3);

创建一个线程池，该线程池重用在共享无界队列上运行的固定数量的线程。在任何时候，最多3个线程将是活动的处理任务。如果在所有线程都处于活动状态时提交了其他任务，它们将在队列中等待，直到有线程可用。如果任何线程在关闭之前的执行过程中由于失败而终止，如果需要执行后续任务，新的线程将取代它。池中的线程将一直存在，直到显式关闭。

2.用Runnable接口实现线程

private static class InnerThread implements Runnable{
public void run();
}

3.创建线程对象并提交至线程池执行

InnerThread innerThread = new InnerThread();
pool.execute(innerThread);

三、结合起来

当新的连接建立时创建一个新线程并提交到线程池

while(true){
                Socket clientSocket = server.accept();
                InnerThread innerThread = new InnerThread(clientSocket);
                pool.execute(innerThread);
            }

run方法为如何处理新连接，以及客户端和服务端的信息交流。

四、使用新的输入输出流

由于OutputStream和InputStream类有方法没有实现或是实现的不是很好，所以我们选择使用
BufferedReader，PrintWriter类来实现通信。

服务器:

BufferedReader br = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));
PrintWriter pw = new PrintWriter(new OutputStreamWriter(clientSocket.getOutputStream()));
while(true){
                    String buf = br.readLine();
                    System.out.println(Thread.currentThread().getName()+" client: " + buf);
                    if(buf.equals("close")){
                        break;
                    }
                    pw.println("response:"+buf);
                    pw.flush();
                }
                System.out.println("close client");
                br.close();
                pw.close();
                clientSocket.close();

客户端:

BufferedReader br = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));
PrintWriter pw = new PrintWriter(new OutputStreamWriter(clientSocket.getOutputStream()));
            while(true){
                System.out.print("client: ");
                String buf = sc.nextLine();
                pw.println(buf);
                pw.flush();
                if(buf.equals("close")){
                    break;
                }
                buf= br.readLine();
                System.out.println("server: " + buf);
                if(buf.equals("close")){
                    break;
                }
            }
            br.close();
            pw.close();
            sc.close();
            clientSocket.close();

这样子就能较为方便的实现服务端向客户端发送信息。

总结

以上就是今天要讲的内容，本文实现了使用线程池实现socket编程。

本篇文章就到这里了，希望能够给你带来帮助，也希望您能够多多关注脚本之家的更多内容!

您可能感兴趣的文章:

SpringBoot整合dataworks的实现过程
这篇文章主要介绍了SpringBoot整合dataworks的实现过程,实现主要是编写工具类，如果需要则可以配置成SpringBean，注入容器即可使用，需要的朋友可以参考下
2022-08-08
java web上传文件和下载文件代码片段分享
这篇文章主要为大家详细介绍了java web上传文件和下载文件代码片段，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
2017-01-01
Java中的继承关系与方法覆盖
这篇文章主要介绍了Java中的继承关系与方法覆盖,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教
2024-03-03
Spring的嵌套事务(Propagation.NESTED)到底是个啥案例代码讲解
SavePoint是数据库事务中的一个概念, 可以将整个事务切割为不同的小事务,可以选择将状态回滚到某个小事务发生时的样子，本文通过案例代码讲解Spring的嵌套事务(Propagation.NESTED)到底是个啥，感兴趣的朋友跟随小编一起看看吧
2023-01-01
Spring中的代理ProxyFactory解析
这篇文章主要介绍了Spring中的ProxyFactory解析,在Java中,代理模式的实现通常依靠Proxy类和InvocationHandler接口,本文将介绍如何使用ProxyFactory来创建代理模式,需要的朋友可以参考下
2023-12-12
详解SpringBoot如何自定义注解
注解,也叫元数据,一种代码级别的说明,它是JDK1.5及以后版本引入的一个特性,与类、接口、枚举是在同一个层次,本文给大家详细介绍了SpringBoot如何自定义注解,文中通过代码讲解的非常详细,需要的朋友可以参考下
2024-08-08
关于SpringSecurity的基本使用示例
这篇文章主要介绍了关于SpringSecurity的基本使用示例,SpringSecurity 本质是一个过滤器链SpringSecurity 采用的是责任链的设计模式，它有一条很长的过滤器链,需要的朋友可以参考下
2023-05-05
Spring集成Mybatis过程详细讲解
mybatis-plus是一个Mybatis的增强工具,在Mybatis的基础上只做增强不做改变,为简化开发、提高效率而生,下面这篇文章主要给大家介绍了关于SpringBoot整合Mybatis-plus案例及用法实例的相关资料,需要的朋友可以参考下
2023-03-03
Mybatis-plus如何提前获取实体类用雪花算法生成的ID
本文主要介绍了Mybatis-plus如何提前获取实体类用雪花算法生成的ID，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
2022-07-07
springboot+jwt+springSecurity微信小程序授权登录问题
这篇文章主要介绍了springboot+jwt+springSecurity微信小程序授权登录问题,本文给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下
2021-01-01