正文

经典 socket通讯 -- 已验证

IP云
IP云V管理员/0 阅读
12/02
小程序：扫一扫查出行
【扫一扫了解最新限行尾号】
复制小程序
[tcp通信]
来源：不详；
client：
  1. package com.defonds.socket.begin;
  2. import java.io.BufferedReader;
  3. import java.io.DataInputStream;
  4. import java.io.DataOutputStream;
  5. import java.io.IOException;
  6. import java.io.InputStreamReader;
  7. import java.net.Socket;
  8. public class Client {
  9. public static final String IP_ADDR = "localhost";//服务器地址
  10. public static final int PORT = 12345;//服务器端口号
  11. public static void main(String[] args) {
  12. System.out.println("客户端启动...");
  13. System.out.println("当接收到服务器端字符为 \"OK\" 的时候, 客户端将终止\n");
  14. while (true) {
  15. Socket socket = null;
  16. try {
  17. //创建一个流套接字并将其连接到指定主机上的指定端口号
  18. socket = new Socket(IP_ADDR, PORT);
  19. //读取服务器端数据
  20. DataInputStream input = new DataInputStream(socket.getInputStream());
  21. //向服务器端发送数据
  22. DataOutputStream out = new DataOutputStream(socket.getOutputStream());
  23. System.out.print("请输入: \t");
  24. String str = new BufferedReader(new InputStreamReader(System.in)).readLine();
  25. out.writeUTF(str);
  26. String ret = input.readUTF();
  27. System.out.println("服务器端返回过来的是: " + ret);
  28. // 如接收到 "OK" 则断开连接
  29. if ("OK".equals(ret)) {
  30. System.out.println("客户端将关闭连接");
  31. Thread.sleep(500);
  32. break;
  33. }
  34. out.close();
  35. input.close();
  36. } catch (Exception e) {
  37. System.out.println("客户端异常:" + e.getMessage());
  38. } finally {
  39. if (socket != null) {
  40. try {
  41. socket.close();
  42. } catch (IOException e) {
  43. socket = null;
  44. System.out.println("客户端 finally 异常:" + e.getMessage());
  45. }
  46. }
  47. }
  48. }
  49. }
  50. }
服务端：
  1. package com.defonds.socket.begin;
  2. import java.io.BufferedReader;
  3. import java.io.DataInputStream;
  4. import java.io.DataOutputStream;
  5. import java.io.InputStreamReader;
  6. import java.net.ServerSocket;
  7. import java.net.Socket;
  8. public class Server {
  9. public static final int PORT = 12345;//监听的端口号
  10. public static void main(String[] args) {
  11. System.out.println("服务器启动...\n");
  12. Server server = new Server();
  13. server.init();
  14. }
  15. public void init() {
  16. try {
  17. ServerSocket serverSocket = new ServerSocket(PORT);
  18. while (true) {
  19. // 一旦有堵塞, 则表示服务器与客户端获得了连接
  20. Socket client = serverSocket.accept();
  21. // 处理这次连接
  22. new HandlerThread(client);
  23. }
  24. } catch (Exception e) {
  25. System.out.println("服务器异常: " + e.getMessage());
  26. }
  27. }
  28. private class HandlerThread implements Runnable {
  29. private Socket socket;
  30. public HandlerThread(Socket client) {
  31. socket = client;
  32. new Thread(this).start();
  33. }
  34. public void run() {
  35. try {
  36. // 读取客户端数据
  37. DataInputStream input = new DataInputStream(socket.getInputStream());
  38. String clientInputStr = input.readUTF();//这里要注意和客户端输出流的写方法对应,否则会抛 EOFException
  39. // 处理客户端数据
  40. System.out.println("客户端发过来的内容:" + clientInputStr);
  41. // 向客户端回复信息
  42. DataOutputStream out = new DataOutputStream(socket.getOutputStream());
  43. System.out.print("请输入:\t");
  44. // 发送键盘输入的一行
  45. String s = new BufferedReader(new InputStreamReader(System.in)).readLine();
  46. out.writeUTF(s);
  47. out.close();
  48. input.close();
  49. } catch (Exception e) {
  50. System.out.println("服务器 run 异常: " + e.getMessage());
  51. } finally {
  52. if (socket != null) {
  53. try {
  54. socket.close();
  55. } catch (Exception e) {
  56. socket = null;
  57. System.out.println("服务端 finally 异常:" + e.getMessage());
  58. }
  59. }
  60. }
  61. }
  62. }
  63. }

相关阅读

目录[+]