目錄

• • • 一、socket簡單客戶端與服務端
    • 二、socket客戶端多次發(fā)送消息到服務端
    • 三、socket多客戶端多次發(fā)送消息到服務端

一、socket簡單客戶端與服務端

客戶端發(fā)送消息給服務端，服務端接收到消息后回應客戶端。

客戶端：

import java.io.*; import java.net.Socket;public class MainClient1 {public static void main(String[] args) {try {//設置發(fā)送到的ip和端口Socket socket = new Socket("127.0.0.1", 9999);//從socket獲取輸出流到緩沖寫區(qū)，用來發(fā)送數(shù)據到服務端BufferedWriter bufferedWriter = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));//獲取Socket的輸入流，用來接收從服務端發(fā)送過來的數(shù)據DataInputStream in = new DataInputStream(socket.getInputStream());//緩沖讀區(qū)的內容寫入緩沖寫區(qū)，發(fā)送到服務端bufferedWriter.write("你好，我的第一個socket！");bufferedWriter.flush();socket.shutdownOutput();//獲取服務端返回的數(shù)據System.out.println(in.readUTF());} catch (IOException e) {e.printStackTrace();}} }

服務端：

import java.io.BufferedReader; import java.io.DataOutputStream; import java.io.IOException; import java.io.InputStreamReader; import java.net.ServerSocket; import java.net.Socket;public class MainServer {public static void main(String[] args) {try {//服務端綁定端口ServerSocket serverSocket = new ServerSocket(9999);//獲取客戶端連接(accept是阻塞的，如果有多個客戶端而服務端不用多線程會只獲取第一個連接的客戶端)Socket socket = serverSocket.accept();//獲取Socket的輸出流，用來向客戶端發(fā)送數(shù)據DataOutputStream out = new DataOutputStream (socket.getOutputStream());//獲取Socket的輸入流，用來接收從客戶端發(fā)送過來的數(shù)據BufferedReader reader = new BufferedReader(new InputStreamReader(socket.getInputStream(), "UTF-8"));String str = reader.readLine();System.out.println("客戶端發(fā)來的消息："+str);//發(fā)送消息到對應的客戶端out.writeUTF("服務端回復:已收到你的消息\"" + str+"\"");} catch (IOException e) {e.printStackTrace();}} }

測試：
先啟動服務端，再啟動客戶端。

二、socket客戶端多次發(fā)送消息到服務端

客戶端從鍵盤可多次發(fā)送消息給服務端，服務端接每次收到消息后回應客戶端。

客戶端：

import java.io.*; import java.net.Socket;public class MainClient1 {public static void main(String[] args) {try {//設置發(fā)送到的ip和端口Socket socket = new Socket("127.0.0.1", 9999);//從socket獲取輸出流到緩沖寫區(qū)BufferedWriter bufferedWriter = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(System.in, "UTF-8"));//獲取Socket的輸入流，用來接收從服務端發(fā)送過來的數(shù)據DataInputStream in = new DataInputStream(socket.getInputStream());while (true) {//獲取鍵盤輸入的內容到緩沖讀區(qū)bufferedWriter.write(bufferedReader.readLine());bufferedWriter.write("\n");bufferedWriter.flush();//獲取服務端返回的數(shù)據System.out.println(in.readUTF());}} catch (IOException e) {e.printStackTrace();}} }

服務端：

import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader; import java.net.ServerSocket; import java.net.Socket;public class MainServer {public static void main(String[] args) {try {//服務端綁定端口ServerSocket serverSocket = new ServerSocket(9999);//獲取客戶端連接Socket socket = serverSocket.accept();//獲取Socket的輸出流，用來向客戶端發(fā)送數(shù)據DataOutputStream out = new DataOutputStream (socket.getOutputStream());//獲取Socket的輸入流，用來接收從客戶端發(fā)送過來的數(shù)據BufferedReader reader = new BufferedReader(new InputStreamReader(socket.getInputStream(), "UTF-8"));String str ;while ((str = reader.readLine()) != null) {//輸出打印System.out.println("客戶端發(fā)來的消息："+str);//發(fā)送消息到對應的客戶端out.writeUTF("服務端回復:已收到你的消息\"" + str+"\"");}} catch (IOException e) {e.printStackTrace();}} }

測試：
先啟動服務端，再啟動客戶端，客戶端可多次輸入消息。

三、socket多客戶端多次發(fā)送消息到服務端

上面的例子是一個客戶端對應一個服務端，下面采用多線程對多個客戶端對應一個服務端進行示例說明。

客戶端1：

import java.io.*; import java.net.Socket;public class MainClient1 {public static void main(String[] args) {try {//設置發(fā)送到的ip和端口Socket socket = new Socket("127.0.0.1", 9999);//從socket獲取輸出流到緩沖寫區(qū)BufferedWriter bufferedWriter = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(System.in, "UTF-8"));//獲取Socket的輸入流，用來接收從服務端發(fā)送過來的數(shù)據DataInputStream in = new DataInputStream(socket.getInputStream());while (true) {//獲取鍵盤輸入的內容到緩沖讀區(qū)bufferedWriter.write(bufferedReader.readLine());bufferedWriter.write("\n");bufferedWriter.flush();//獲取服務端返回的數(shù)據System.out.println(in.readUTF());}} catch (IOException e) {e.printStackTrace();}} }

客戶端2：

import java.io.*; import java.net.Socket;public class MainClient2 {public static void main(String[] args) {try {//設置發(fā)送到的ip和端口Socket socket = new Socket("127.0.0.1", 9999);//從socket獲取輸出流到緩沖寫區(qū)BufferedWriter bufferedWriter = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(System.in, "UTF-8"));//獲取Socket的輸入流，用來接收從服務端發(fā)送過來的數(shù)據DataInputStream in = new DataInputStream(socket.getInputStream());while (true) {//獲取鍵盤輸入的內容到緩沖讀區(qū)bufferedWriter.write(bufferedReader.readLine());bufferedWriter.write("\n");bufferedWriter.flush();//獲取服務端返回的數(shù)據System.out.println(in.readUTF());}} catch (IOException e) {e.printStackTrace();}} }

服務端：

import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader; import java.net.ServerSocket; import java.net.Socket; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors;public class MainServer {public static void main(String[] args) {try {//服務端綁定端口ServerSocket serverSocket = new ServerSocket(9999);//定長線程池ExecutorService executorService = Executors.newFixedThreadPool(100);while (true) {Socket socket = serverSocket.accept();//每當有一個服務端連接到服務器就新開一個線程處理executorService.execute(() -> {try {//socket中獲取輸入流到緩沖區(qū)BufferedReader reader = new BufferedReader(new InputStreamReader(socket.getInputStream(), "UTF-8"));//獲取Socket的輸出流，用來向客戶端發(fā)送數(shù)據DataOutputStream out = new DataOutputStream (socket.getOutputStream());String str;//讀取緩沖區(qū)信息到str并輸出while (((str = reader.readLine()) != null)) {System.out.println("客戶端發(fā)來的消息："+str);//發(fā)送消息到對應的客戶端out.writeUTF("服務端回復:已收到你的消息\"" + str+"\"");}} catch (IOException e) {e.printStackTrace();}});}} catch (IOException e) {e.printStackTrace();}} }

測試：
先啟動服務端，再啟動兩個客戶端，兩個客戶端可多次輸入消息接受服務端的響應。

---

在idea中啟動多個main的方法技巧：

要啟動哪個就右上角切換哪個。

---

參考：

Java socket詳解,看這一篇就夠了

Java Socket 服務端發(fā)送數(shù)據 客戶端接收數(shù)據

Java TCP Socket 編程

總結

以上是生活随笔為你收集整理的java Socket编程的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。