Java使用線程池實(shí)現(xiàn)socket編程的方法詳解
前言
以多個(gè)客戶端和一個(gè)服務(wù)端的socket通信為例，服務(wù)端啟動時(shí)創(chuàng)建一個(gè)固定大小的線程池。服務(wù)端每接收到一個(gè)連接請求后（通信任務(wù)），交給線程池執(zhí)行，任務(wù)類實(shí)現(xiàn)了Runnable接口，用于跟客戶端進(jìn)行讀寫操作，該類的對象作為任務(wù)通過execute(Runnable task)提交給線程池。
一、一個(gè)簡單的C/S模型實(shí)現(xiàn)
1.服務(wù)器：
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());
}
}
}
此處只能服務(wù)器接收客戶端信息。
二、線程池使用方法
1.新建一個(gè)線程池
ExecutorService pool = Executors.newFixedThreadPool(3);
創(chuàng)建一個(gè)線程池，該線程池重用在共享無界隊(duì)列上運(yùn)行的固定數(shù)量的線程。 在任何時(shí)候，最多3個(gè)線程將是活動的處理任務(wù)。如果在所有線程都處于活動狀態(tài)時(shí)提交了其他任務(wù)，它們將在隊(duì)列中等待，直到有線程可用。 如果任何線程在關(guān)閉之前的執(zhí)行過程中由于失敗而終止，如果需要執(zhí)行后續(xù)任務(wù)，新的線程將取代它。 池中的線程將一直存在，直到顯式關(guān)閉。
2.用Runnable接口實(shí)現(xiàn)線程
private static class InnerThread implements Runnable{
public void run();
}
3.創(chuàng)建線程對象并提交至線程池執(zhí)行
InnerThread innerThread = new InnerThread(); pool.execute(innerThread);
三、結(jié)合起來
當(dāng)新的連接建立時(shí)創(chuàng)建一個(gè)新線程并提交到線程池
while(true){
Socket clientSocket = server.accept();
InnerThread innerThread = new InnerThread(clientSocket);
pool.execute(innerThread);
}
run方法為如何處理新連接，以及客戶端和服務(wù)端的信息交流。
四、使用新的輸入輸出流
由于OutputStream和InputStream類有方法沒有實(shí)現(xiàn)或是實(shí)現(xiàn)的不是很好，所以我們選擇使用
BufferedReader，PrintWriter類來實(shí)現(xiàn)通信。
服務(wù)器:
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();
這樣子就能較為方便的實(shí)現(xiàn)服務(wù)端向客戶端發(fā)送信息。
總結(jié)
以上就是今天要講的內(nèi)容，本文實(shí)現(xiàn)了使用線程池實(shí)現(xiàn)socket編程。
本篇文章就到這里了，希望能夠給你帶來幫助，也希望您能夠多多關(guān)注腳本之家的更多內(nèi)容!
相關(guān)文章
這篇文章主要介紹了首先用蒙塔卡洛算法求圓周率近似值，然后根據(jù)此近似值輸出圓的周長和面積，具有一定參考價(jià)值，需要的朋友可以了解下。2017-09-09
Java基于Dijkstra算法實(shí)現(xiàn)校園導(dǎo)游程序
這篇文章主要為大家詳細(xì)介紹了Java基于Dijkstra算法實(shí)現(xiàn)校園導(dǎo)游程序，文中示例代碼介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下2022-03-03
這篇文章主要介紹了Java方法覆蓋重寫實(shí)現(xiàn)原理解析,文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2019-12-12
這篇文章主要介紹了Java的RocketMQ之消息存儲和查詢原理詳解,一臺Broker服務(wù)器只有一個(gè)CommitLog文件(組),RocketMQ會將所有主題的消息存儲在同一個(gè)文件中,這個(gè)文件中就存儲著一條條Message,每條Message都會按照順序?qū)懭?需要的朋友可以參考下2024-01-01
Nacos服務(wù)實(shí)例的權(quán)重設(shè)置方式(以及設(shè)置為0時(shí)的作用與場景)
這篇文章主要介紹了Nacos服務(wù)實(shí)例的權(quán)重設(shè)置方式(以及設(shè)置為0時(shí)的作用與場景),具有很好的參考價(jià)值,希望對大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2024-07-07
這篇文章主要介紹了Mybatis條件if test如何使用枚舉值，具有很好的參考價(jià)值，希望對大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教2022-06-06
Java中的CyclicBarrier、CountDownLatch和Semaphore的具體使用
本文主要介紹了Java中的CyclicBarrier、CountDownLatch和Semaphore的具體使用,文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2024-05-05
java基礎(chǔ)之接口組成更新的實(shí)現(xiàn)
本文主要介紹了java基礎(chǔ)之接口組成更新的實(shí)現(xiàn)，文中通過示例代碼介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下2022-04-04
用java開發(fā)dota英雄最華麗的技能(實(shí)例講解)
下面小編就為大家分享一篇使用java開發(fā)dota英雄最華麗的技能實(shí)例，具有非常好的參考價(jià)值，希望對大家有所幫助。一起跟隨小編過來看看吧2017-11-11
這篇文章主要為大家詳細(xì)介紹了java如何將pdf轉(zhuǎn)換成image，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下2018-05-05