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

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

目录前言一、一个简单的C/S模型实现1.服务器：2.客户端：二、线程池使用方法1.新建一个线程池2.用Runnable接口实现线程3.创建线程对象并提交至线程池执行三、结合起来四、使用新的输入输出流总结

前言

以多个客户端和一个服务端的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);

http://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 jdexHfuuAlava.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和InputSdexHfuuAltream类有方法没有实现或是实现的不是很好，所以我们选择使用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.equahttp://ls("close")){

break;

}

buf= br.readLine();

System.out.println("server: " + buf);

if(buf.equals("close")){

break;

}

}

br.close();

pw.close();

sc.close();

clientSocket.close();

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

总结

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

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

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。