1.多线程方式循环处理多个socket请求-server

server

  1. package com.sunyj.practice.t0001_socket.multiThread;
  3. import java.io.IOException;
  4. import java.io.InputStream;
  5. import java.io.UnsupportedEncodingException;
  6. import java.net.ServerSocket;
  7. import java.net.Socket;
  8. import java.util.concurrent.ExecutorService;
  9. import java.util.concurrent.Executors;
  11. /**
  12.  * 多线程方式循环处理多个socket请求-server
  13.  * @author syj
  14.  * @date 2019年5月15日 下午9:52:16
  15.  */
  16. public class Server {
  17.     public static void main(String[] args) {
  18.         int port = 9212;
  19.         try {
  20.             @SuppressWarnings("resource")
  21.             ServerSocket serverSocket = new ServerSocket(port);
  22. //            serverSocket.setSoTimeout();
  23.             System.out.println("server一直等待client连接的到来...");
  24.             ExecutorService executorService = Executors.newFixedThreadPool(100);
  25.             while(true) {
  26.                 Socket socket = serverSocket.accept();
  27.                 Runnable runnable = () -> {
  28.                     readMsg(socket);
  29.                 };
  30.                 executorService.submit(runnable);
  31.             }
  32.         } catch (IOException e) {
  33.             e.printStackTrace();
  34.         }
  36.     }
  38.     /**
  39.      * 读取socket传来的信息
  40.      * @param socket
  41.      * @throws IOException
  42.      * @throws UnsupportedEncodingException
  43.      */
  44.     private static void readMsg(Socket socket){
  45.         try {
  46.             InputStream inputStream = socket.getInputStream();
  47.             byte[] bytes = new byte[1024];
  48.             int len;
  49.             StringBuilder sb = new StringBuilder();
  50.             while((len = inputStream.read(bytes)) != -1) {
  51.                 sb.append(new String(bytes,0,len,"utf-8"));
  52.             }
  53.             System.out.println(sb.toString());
  54.             inputStream.close();
  55.             socket.close();
  56.         } catch (IOException e) {
  57.             e.printStackTrace();
  58.         }
  59.     }
  60. }

2.可重复发送信息SOCKET - client

client

  1. package com.sunyj.practice.t0001_socket.repeatSend;
  3. import java.io.IOException;
  4. import java.io.OutputStream;
  5. import java.net.InetSocketAddress;
  6. import java.net.Socket;
  7. import java.net.UnknownHostException;
  9. /**
  10.  * 可重复发送信息SOCKET - client
  11.  * @author syj
  12.  * @date 2019年5月15日 下午9:17:45
  13.  */
  14. public class Client {
  15.     public static void main(String[] args) throws UnknownHostException,IOException {
  16.         String host = "127.0.0.1";
  17.         int port = 9212;
  18.         try {
  19.             Socket socket = new Socket();
  20.             socket.connect(new InetSocketAddress(host,port), 10000);
  21.             OutputStream outputStream = socket.getOutputStream();
  22.             String msg = "你好，12312sfsaf";
  23.             byte[] bytes = msg.getBytes("utf-8");
  24.             outputStream.write(bytes.length >> 8);
  25.             System.out.println(bytes.length);
  26.             System.out.println(bytes.length >> 8);
  27.             outputStream.write(bytes.length);
  28.             outputStream.write(msg.getBytes("utf-8"));
  29.             outputStream.flush();
  31.             msg = "second send message...";
  32.             outputStream.write(bytes.length >> 8);
  33.             outputStream.write(bytes.length);
  34.             outputStream.write(msg.getBytes("utf-8"));
  35.             outputStream.flush();
  37.             msg = "第三次发送...";
  38.             outputStream.write(bytes.length >> 8);
  39.             outputStream.write(bytes.length);
  40.             outputStream.write(msg.getBytes("utf-8"));
  41.             outputStream.flush();
  43.             outputStream.close();
  44.             socket.close();
  45.         } catch (UnknownHostException e) {
  46.             e.printStackTrace();
  47.             throw e;
  48.         } catch (IOException e) {
  49.             e.printStackTrace();
  50.             throw e;
  51.         }
  52.     }
  53. }

server

  1. package com.sunyj.practice.t0001_socket.repeatSend;
  3. import java.io.IOException;
  4. import java.io.InputStream;
  5. import java.net.ServerSocket;
  6. import java.net.Socket;
  8. /**
  9.  * 可重复发送的SOCKET
  10.  * @author syj
  11.  * @date 2019年5月15日 下午9:06:52
  12.  */
  13. public class Server {
  14.     public static void main(String[] args) throws IOException {
  15.         int port = 9212;
  16.         try {
  17.             ServerSocket serverSocket = new ServerSocket(port);
  18.             System.out.println("-----server一直等待客户端连接的到来...");
  19.             serverSocket.setSoTimeout(10000);
  20.             Socket socket = serverSocket.accept();
  21.             InputStream inputStream = socket.getInputStream();
  22.             byte[] bytes;
  23.             while(true) {
  24.                 int first = inputStream.read();        //读取第一个字节
  25.                 if(first == -1) {
  26.                     break;
  27.                 }
  28.                 int second = inputStream.read();
  29.                 System.out.println(first << 8);
  30.                 int len = (first << 8) + second;
  31.                 System.out.println(len);
  32.                 bytes = new byte[len];
  33.                 inputStream.read(bytes, 0, len);
  34.                 System.out.println("------get message from client:"+new String(bytes,"utf-8"));
  35.             }
  36.             inputStream.close();
  37.             socket.close();
  38.             serverSocket.close();
  39.         } catch (IOException e) {
  40.             e.printStackTrace();
  41.             throw e;
  42.         }
  44.     }
  45. }

3.simple

client

  1. package com.sunyj.practice.t0001_socket.simple;
  3. import java.io.IOException;
  4. import java.io.InputStream;
  5. import java.io.OutputStream;
  6. import java.net.Socket;
  7. import java.net.UnknownHostException;
  9. /**
  10.  * 
  11.  * @author syj
  12.  * @date 2019年5月15日 下午8:24:18
  13.  */
  14. public class Client {
  15.     public static void main(String[] args) {
  16.         String host = "127.0.0.1";
  17.         int port = 9212;
  18.         try {
  19.             Socket socket = new Socket(host,port);
  20.             OutputStream outputStream = socket.getOutputStream();
  21.             outputStream.write("你好".getBytes("utf-8"));
  22.             //通过shutdownoutput来告诉服务器已经发送完数据，后续只能接受数据
  23.             socket.shutdownOutput();
  25.             InputStream inputStream = socket.getInputStream();
  26.             byte[] bytes = new byte[1024];
  27.             int len;
  28.             StringBuilder sb = new StringBuilder();
  29.             while((len = inputStream.read(bytes)) != -1) {
  30.                 sb.append(new String(bytes,0,len,"UTF-8"));
  31.             }
  32.             System.out.println("get message from server:"+sb.toString());
  33.             inputStream.close();
  34.             outputStream.close();
  35.             socket.close();
  36.         } catch (UnknownHostException e) {
  37.             e.printStackTrace();
  38.         } catch (IOException e) {
  39.             e.printStackTrace();
  40.         }
  42.     }
  43. }

server

  1. package com.sunyj.practice.t0001_socket.simple;
  3. import java.io.InputStream;
  4. import java.io.OutputStream;
  5. import java.net.ServerSocket;
  6. import java.net.Socket;
  8. /**
  9.  * socket服务端
  10.  * @author syj
  11.  * @date 2019年5月15日 下午8:00:49
  12.  */
  13. public class Server {
  14.     public static void main(String[] args) {
  15.         int port = 9212;
  16.         try {
  17.             ServerSocket serverSocket = new ServerSocket(port);
  18.             System.out.println("server一直等待客户端连接的到来。。。");
  19.             Socket socket = serverSocket.accept();
  20.             InputStream inputStream = socket.getInputStream();    //读取到内存中
  21.             byte[] bytes = new byte[1024];
  22.             StringBuilder sb = new StringBuilder();
  23.             int len;
  24.             while((len = inputStream.read(bytes)) != -1) {
  25.                 sb.append(new String(bytes,0,len,"UTF-8"));
  26.             }
  27.             System.out.println("get message from client:"+sb.toString());
  29.             OutputStream outputStream = socket.getOutputStream();
  30.             outputStream.write("hello client,I get the message.".getBytes("UTF-8"));
  31.             outputStream.close();
  32.             inputStream.close();
  33.             socket.close();
  34.             serverSocket.close();
  36.         } catch (Exception e) {
  37.             e.printStackTrace();
  38.         }
  39.     }
  40. }