Java 实现简单Socket 通信的示例

$ java Server.java
Bind Port 9090
New client connected.
Received Message --> Are you OK!

$ java Client.java
Are you OK!
Send Msg --> Are you OK!
Bye
$

import java.net.*;
import java.io.*;

class Server {
 
 public static void main(String[] args) {
  // ServerSocket 实现了 AutoCloseable 接口，所以支持 try-with-resource 语句
  // 创建一个 ServerSocket，监听 9090 端口
  try(ServerSocket serv = new ServerSocket(9090)){
   System.out.printf("Bind Port %d\n", serv.getLocalPort());
   Socket socket = null;
   while(true){
    // 接收连接，如果没有连接，accept() 方法会阻塞
    socket = serv.accept();
    
    // 获取输入流，并使用 BufferedInputStream 和 InputStreamReader 装饰，方便以字符流的形式处理，方便一行行读取内容
    try(BufferedReader in = new BufferedReader( new InputStreamReader(socket.getInputStream()) )){
     String msg = null;
     char[] cbuf = new char[1024];
     int len = 0;
     while( (len = in.read(cbuf, 0, 1024)) != -1 ){ // 循环读取输入流中的内容
      msg = new String(cbuf, 0, len);
      if("Bye".equals(msg)) { // 如果检测到 "Bye" ，则跳出循环，不再读取输入流中内容。
       break;
      }
      System.out.printf("Received Message --> %s \n", msg);
     }
    }catch (IOException e){
     e.printStackTrace();
    }
    
   }
   
  }catch (IOException e){
   e.printStackTrace();
  }
 }
}
2.3 客户端程序代码
import java.net.*;
import java.io.*;
import java.util.*;

class Client{
 
 public static void main(String[] args){
  
  try(Socket socket = new Socket("localhost", 9090)){
   BufferedWriter out = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));
   Scanner scanner = new Scanner(System.in);
   scanner.useDelimiter("\r\n");
   String msg = null;
   while( !(msg = scanner.next()).equals("Bye") ){
    System.out.printf("Send Msg --> %s \n", msg);
    out.write(msg);
    out.flush(); // 立即发送，否则需要积累到一定大小才一次性发送
   }
  }catch (IOException e){
   e.printStackTrace();
  }
  
 }
 
}

import java.net.*;
import java.io.*;

class Server {
 
 public static void main(String[] args){
  
  // 创建一个 DatagramPacket 实例，用来接收客户端发送过来的 UDP 数据报，这个实例可以重复利用。
  byte[] buf = new byte[8192]; // 缓存区
  int len = buf.length;  // 要利用的缓存区的大小
  DatagramPacket pac = new DatagramPacket(buf, len);
  
  // 创建服务端的套接字，需要指定绑定的端口号
  try(DatagramSocket serv = new DatagramSocket(9191)){
   
   while(true){
    serv.receive(pac); // 接收数据报。如果没有数据报发送过来，会阻塞
    System.out.println("Message --> " + new String(pac.getData(), 0, pac.getLength()));
   }
   
  }catch (IOException e){
   e.printStackTrace();
  }
 }
 
}

import java.io.*;
import java.net.*;
import java.util.*;

class Client {
 public static void main(String[] args){
  
  // 创建一个客户端的 UDP 套接字，不需要指定任何信息
  try(DatagramSocket client = new DatagramSocket()){
   
   // 创建一个数据报实例，数据和长度在发送之前都会重新设置，所以这里直接置为 0 即可。 
   // 由于是发送端，所以需要设置服务端的地址和端口
   DatagramPacket pac = new DatagramPacket(new byte[0], 0, InetAddress.getByName("localhost"), 9191);
   
   // 扫描控制台输入
   Scanner scanner = new Scanner(System.in);
   scanner.useDelimiter("\r\n");
   String msg = null;
   while( !(msg = scanner.next()).equals("Bye") ){
    // 设置要发送的数据
    pac.setData(msg.getBytes()); 
    // 发送数据报
    client.send(pac);
    System.out.println("Sent Message --> " + msg);
   }
  }catch (IOException e){
   e.printStackTrace();
  }
  
 }
}