Go语言视频零基础入门到精通

javalearner

1，服务器端代码

2. import java.io.BufferedReader;
3. import java.io.IOException;
4. import java.io.InputStreamReader;
5. import java.io.PrintWriter;
6. import java.net.ServerSocket;
7. import java.net.Socket;
8. import java.util.ArrayList;
9. import java.util.List;
10. public class Server {
11. public static void main(String[] args) {
12.   try {
13.    ServerSocket server = new ServerSocket(8001);
14.    List<Socket> ss = new ArrayList<Socket>();
15.    while(true){
16.     Socket socket = server.accept();
17.     ss.add(socket);
18.     new ServerThread1(socket).start();
19.    }
20.   } catch (IOException e) {
21.    e.printStackTrace();
22.   }
23.   
24. }
26. }
27. class ServerThread1 extends Thread{
28. private Socket socket;
30. public ServerThread1(Socket socket){
31.   this.socket = socket;
32. }
34. public void run(){
35.   PrintWriter out = null;
36.   BufferedReader in = null;
37.   try{
38.    out = new PrintWriter(socket.getOutputStream());
39.    in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
40.    
41.    String s = in.readLine();
42.    System.out.println(s+"上线了");
43.    out.println(s+"上线了");
44.    out.flush();
45.    
46.    s = in.readLine();
47.    
48.    while(s!= null && !s.equals("quit")){
49.     System.out.println(s);
50.     out.println(s);
51.     out.flush();
52.     s = in.readLine();
53.    }
54.   }catch(Exception e){
55.    e.printStackTrace();
56.   }finally{
57.    try{
58.     in.close();
59.     out.close();
60.     socket.close();
61.    }catch(Exception e){
62.    }
63.   }
64. }
66. }

复制代码

2，客户端代码

2. import java.io.BufferedReader;
3. import java.io.IOException;
4. import java.io.InputStreamReader;
5. import java.io.PrintWriter;
6. import java.net.Socket;
7. import java.net.UnknownHostException;
9. public class Client {
10. public static void main(String[] args) {
11.   try {
12.    Socket socket = new Socket("10.6.16.68",8001);
13.    BufferedReader sin = new BufferedReader(new InputStreamReader(System.in));
14.    PrintWriter out = new PrintWriter(socket.getOutputStream());
15.    System.out.print("请输入您的用户名：");
16.    String cname = sin.readLine();
17.    out.println(cname);
18.    out.flush();
19.    new ClientThread(socket).start();
20.    String c = sin.readLine();
21.    while(!c.equals("quit")){
22.     out.println(cname+"说："+c);
23.     out.flush();
24.     c = sin.readLine();
25.    }
26.    out.close();
27.    socket.close();
28.   } catch (UnknownHostException e) {
29.    e.printStackTrace();
30.   } catch (IOException e) {
31.    e.printStackTrace();
32.   }
33. }
34. }
35. class ClientThread extends Thread{
37. private Socket socket;
39. public ClientThread(Socket socket){
40.   this.socket = socket;
41. }
43. public void run(){
44.   BufferedReader in = null;
45.   try{
46.    in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
47.   }catch(IOException e){
48.    e.printStackTrace();
49.   }
50.   
51.   while(true){
52.    String s;
53.    try{
54.     s = in.readLine();
55.     System.out.println(s);
56.    }catch(IOException e){
57.     break;
58.    }
59.   }
60. }
61. }

复制代码

在客户端输入聊天信息：

服务器端接收到的消息：