利用多线程和TCP创建多个客户端与服务端通信

    1. package JDBC_DemoDay07;/*
    3.     @create 2021--01--04--10:26
    4. */
    6. import java.io.IOException;
    7. import java.io.InputStream;
    8. import java.io.OutputStream;
    9. import java.net.ServerSocket;
    10. import java.net.Socket;
    12. //定义一个通信类
    13. public class ServerThree extends Thread {
    14.     private Socket socket;      //定义一个socket类
    15.     private OutputStream os;    //输出流
    16.     private InputStream is;     //输入流
    18.     public void setSocket(Socket socket) {
    19.         this.socket = socket;
    20.     }
    22.     //线程创建方法
    23.     public void run() {
    24.         try {
    25.             System.out.println("已启动一个线程来处理~");
    26.             //为输入输出流赋值
    27.             os = socket.getOutputStream();
    28.             is = socket.getInputStream();
    29.             //开始通信
    30.             //输出：传送信息给客户机
    31.             String outS = "Hello,Welcome to my ServerSocket!\t\n";
    33.             out(outS);
    34.             //输入：发送信息给服务器
    35.             ReadString();
    36.             //关闭连接
    37.             os.close();
    38.             is.close();
    39.             socket.close();
    40.         } catch (Exception e) {
    41.         }
    42.     }
    44.     //建立多个服务器连接
    45.     private void setUpServer(int prot) throws IOException {
    46.         //将输入的端口设置为服务器
    47.         ServerSocket server = new ServerSocket(prot);
    48.         //输出当前服务器的端口号
    49.         System.out.println("服务器创建成功，端口号：" + server.getLocalPort());
    51.         while (true) {
    52.             Socket socketPram = server.accept();
    53.             ServerThree ts = new ServerThree();
    54.             ts.setSocket(socketPram);
    56.             //启动线程
    57.             ts.start();
    58.         }
    59.     }
    61.     //输入：定义一个传送字符给服务器的方法
    62.     private void ReadString() throws IOException {
    63.         //将字符串转化为byte数组
    64.         String input = "";
    65.         while (!input.equals("bye")) {
    66.             input = "";
    67.             //读取第一个字符
    68.             int AsciiNumber = is.read();
    69.             while (AsciiNumber != 13) {
    70.                 //将ascii码转化为相应的char型字符
    71.                 input += (char) AsciiNumber;
    72.                 //接收下一个字符
    73.                 AsciiNumber = is.read();
    75.             }
    76.             System.out.println(input);
    77.             AsciiNumber = is.read();
    78.         }
    79.     }
    81.     //输出：定义一个输出信息到客户都的方法
    82.     private void out(String outS) throws IOException {
    83.         //将字字符串转化为byte数组
    84.         byte[] dataout = outS.getBytes();
    85.         //调用write（）将信息发送给客户机
    86.         os.write(dataout);
    87.         //强制输出到命令行的界面中
    88.         os.flush();
    89.     }
    91.     //主函数入口
    92.     public static void main(String[] args) throws IOException {
    93.         //创建一个通信类的对象
    94.         ServerThree server = new ServerThree();
    95.         server.setUpServer(8091);
    97.     }
    98. }