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();

   }

  }

}