ตัวอย่างชวา - ตัวอย่าง ServerSocket และซ็อกเก็ตการสื่อสาร

ตัวอย่าง Java

ตัวอย่างต่อไปนี้แสดงให้เห็นถึงวิธีการใช้ลูกค้าส่งข้อความไปยังเซิร์ฟเวอร์ได้รับข้อความและอ่านที่ส่งออกแล้วเขียนไปยังลูกค้าลูกค้าจะได้รับการส่งออก

1 เพื่อสร้างเซิร์ฟเวอร์

• เซิร์ฟเวอร์ ServerSocket เพื่อสร้างการสื่อสาร
• ซ็อกเก็ตที่ได้รับเซิร์ฟเวอร์ของลูกค้าเพื่อสร้างการเชื่อมต่อ
• สร้างกระแสอินพุทข้อมูลที่จะอ่าน IO ส่งโดยไคลเอ็นต์
• สถานประกอบการของ IO ลงให้กับลูกค้าในการส่งข้อความข้อมูล

รหัสฝั่งเซิร์ฟเวอร์:

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("启动服务器....");
         Socket s = ss.accept();
         System.out.println("客户端:"+s.getInetAddress().getLocalHost()+"已连接到服务器");
         
         BufferedReader br = new BufferedReader(new InputStreamReader(s.getInputStream()));
         //读取客户端发送来的消息
         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();
      }
   }
}

รหัสดังกล่าวจะดำเนินการส่งออกเป็น:

启动服务器....

2 สถานประกอบการของลูกค้า

• สร้างซ็อกเก็ตการสื่อสาร, การตั้งค่า IP ของเซิร์ฟเวอร์การสื่อสารและท่าเรือ
• สร้าง IO เซิร์ฟเวอร์การไหลของข้อมูลการส่งออกส่งข้อความ
• สร้างกระแสอินพุท IO จะอ่านข้อความข้อมูลที่ส่งมาจากเซิร์ฟเวอร์

รหัสลูกค้า:

/*
 author by w3cschool.cc
 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);
         
         //构建IO
         InputStream is = s.getInputStream();
         OutputStream os = s.getOutputStream();
         
         BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(os));
         //向服务器端发送一条消息
         bw.write("测试客户端和服务器通信，服务器接收到消息返回到客户端\n");
         bw.flush();
         
         //读取服务器返回的消息
         BufferedReader br = new BufferedReader(new InputStreamReader(is));
         String mess = br.readLine();
         System.out.println("服务器："+mess);
      } catch (UnknownHostException e) {
         e.printStackTrace();
      } catch (IOException e) {
         e.printStackTrace();
      }
   }
}

รหัสดังกล่าวจะดำเนินการส่งออกเป็น:

服务器：测试客户端和服务器通信，服务器接收到消息返回到客户端

ตัวอย่าง Java