Java 实例 - ServerSocket 和 Socket 通信实例

以下实例演示了如何实现客户端发送消息到服务器,服务器接收到消息并读取输出,然后写出到客户端客户端接收到输出。

1、建立服务器端

  • 服务器建立通信ServerSocket
  • 服务器建立Socket接收客户端连接
  • 建立IO输入流读取客户端发送的数据
  • 建立IO输出流向客户端发送数据消息

服务器端代码:

Server.java 文件

  1. import java.io.BufferedReader;
  2. import java.io.BufferedWriter;
  3. import java.io.IOException;
  4. import java.io.InputStreamReader;
  5. import java.io.OutputStreamWriter;
  6. import java.net.ServerSocket;
  7. import java.net.Socket;
  8. public class Server {
  9. public static void main(String[] args) {
  10. try {
  11. ServerSocket ss = new ServerSocket(8888);
  12. System.out.println("启动服务器....");
  13. Socket s = ss.accept();
  14. System.out.println("客户端:"+s.getInetAddress().getLocalHost()+"已连接到服务器");
  15. BufferedReader br = new BufferedReader(new InputStreamReader(s.getInputStream()));
  16. //读取客户端发送来的消息
  17. String mess = br.readLine();
  18. System.out.println("客户端:"+mess);
  19. BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));
  20. bw.write(mess+"\n");
  21. bw.flush();
  22. } catch (IOException e) {
  23. e.printStackTrace();
  24. }
  25. }
  26. }

以上代码运行输出结果为:

  1. 启动服务器....

2、建立客户端

  • 创建Socket通信,设置通信服务器的IP和Port
  • 建立IO输出流向服务器发送数据消息
  • 建立IO输入流读取服务器发送来的数据消息

客户端代码:

Client.java 文件

  1. import java.io.BufferedReader;
  2. import java.io.BufferedWriter;
  3. import java.io.IOException;
  4. import java.io.InputStream;
  5. import java.io.InputStreamReader;
  6. import java.io.OutputStream;
  7. import java.io.OutputStreamWriter;
  8. import java.net.Socket;
  9. import java.net.UnknownHostException;
  10. public class Client {
  11. public static void main(String[] args) {
  12. try {
  13. Socket s = new Socket("127.0.0.1",8888);
  14. //构建IO
  15. InputStream is = s.getInputStream();
  16. OutputStream os = s.getOutputStream();
  17. BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(os));
  18. //向服务器端发送一条消息
  19. bw.write("测试客户端和服务器通信,服务器接收到消息返回到客户端\n");
  20. bw.flush();
  21. //读取服务器返回的消息
  22. BufferedReader br = new BufferedReader(new InputStreamReader(is));
  23. String mess = br.readLine();
  24. System.out.println("服务器:"+mess);
  25. } catch (UnknownHostException e) {
  26. e.printStackTrace();
  27. } catch (IOException e) {
  28. e.printStackTrace();
  29. }
  30. }
  31. }

以上代码运行输出结果为:

  1. 服务器:测试客户端和服务器通信,服务器接收到消息返回到客户端