Java 實(shí)例 - ServerSocket 和 Socket 通信實(shí)例

Java 實(shí)例 Java 實(shí)例

以下實(shí)例演示了如何實(shí)現(xiàn)客戶端發(fā)送消息到服務(wù)器,服務(wù)器接收到消息并讀取輸出,然后寫出到客戶端客戶端接收到輸出。

1、建立服務(wù)器端

  • 服務(wù)器建立通信ServerSocket
  • 服務(wù)器建立Socket接收客戶端連接
  • 建立IO輸入流讀取客戶端發(fā)送的數(shù)據(jù)
  • 建立IO輸出流向客戶端發(fā)送數(shù)據(jù)消息

服務(wù)器端代碼:

import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.ServerSocket;
import java.net.Socket;

public class Server {
   public static void main(String[] args) {
      try {
         ServerSocket ss = new ServerSocket(8888);
         System.out.println("啟動(dòng)服務(wù)器....");
         Socket s = ss.accept();
         System.out.println("客戶端:"+s.getInetAddress().getLocalHost()+"已連接到服務(wù)器");
         
         BufferedReader br = new BufferedReader(new InputStreamReader(s.getInputStream()));
         //讀取客戶端發(fā)送來的消息
         String mess = br.readLine();
         System.out.println("客戶端:"+mess);
         BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));
         bw.write(mess+"\n");
         bw.flush();
      } catch (IOException e) {
         e.printStackTrace();
      }
   }
}

以上代碼運(yùn)行輸出結(jié)果為:

啟動(dòng)服務(wù)器....

2、建立客戶端

  • 創(chuàng)建Socket通信,設(shè)置通信服務(wù)器的IP和Port
  • 建立IO輸出流向服務(wù)器發(fā)送數(shù)據(jù)消息
  • 建立IO輸入流讀取服務(wù)器發(fā)送來的數(shù)據(jù)消息

客戶端代碼:

/*
 author by w3cschool.cn
 Main.java
 */

import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.OutputStreamWriter;
import java.net.Socket;
import java.net.UnknownHostException;

public class Client {
   public static void main(String[] args) {
      try {
         Socket s = new Socket("127.0.0.1",8888);
         
         //構(gòu)建IO
         InputStream is = s.getInputStream();
         OutputStream os = s.getOutputStream();
         
         BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(os));
         //向服務(wù)器端發(fā)送一條消息
         bw.write("測(cè)試客戶端和服務(wù)器通信,服務(wù)器接收到消息返回到客戶端\n");
         bw.flush();
         
         //讀取服務(wù)器返回的消息
         BufferedReader br = new BufferedReader(new InputStreamReader(is));
         String mess = br.readLine();
         System.out.println("服務(wù)器:"+mess);
      } catch (UnknownHostException e) {
         e.printStackTrace();
      } catch (IOException e) {
         e.printStackTrace();
      }
   }
}

以上代碼運(yùn)行輸出結(jié)果為:

服務(wù)器:測(cè)試客戶端和服務(wù)器通信,服務(wù)器接收到消息返回到客戶端

Java 實(shí)例 Java 實(shí)例