java Socket多线程服务器源代码介绍


java Socket多线程在我们进行相关学习的时候需要注意不断出现的问题，下面我们就来看看在java Socket多线程中服务器的代码编写。

java Socket多线程需要我们不断的学习，在学习的时候我们就会发现在服务器的配置上有不少的问题。下面我们就来看看服务器源代码是如何编写的，以便大家更好的使用java Socket多线程。

1. import java.io.BufferedReader;
2. import java.io.IOException;
3. import java.io.InputStreamReader;
4. import java.io.PrintWriter;
5. import java.net.ServerSocket;
6. import java.net.Socket;
7. import java.util.ArrayList;
8. import java.util.List;
9. import java.util.concurrent.ExecutorService;
10. import java.util.concurrent.Executors;
11. public class ChatServer {
12. private static final int PORT = 1234; // 端口号
13. private static List<Socket> list = new ArrayList<Socket>();
// 保存连接对象
14. private ExecutorService exec;
15. private ServerSocket server;
16. public static void main(String[] args) {
17. new ChatServer();
18. }
19. public ChatServer() {
20. try {
21. server = new ServerSocket(PORT);
22. exec = Executors.newCachedThreadPool();
23. System.out.println(“服务器已启动！”);
24. Socket client = null;
25. while (true) {
26. client = server.accept(); // 接收客户连接
27. list.add(client);
28. exec.execute(new ChatTask(client));
29. }
30. } catch (IOException e) {
31. e.printStackTrace();
32. }
33. }
34. static class ChatTask implements Runnable {
35. private Socket socket;
36. private BufferedReader br;
37. private PrintWriter pw;
38. private String msg;
39. public ChatTask(Socket socket) throws IOException {
40. this.socket = socket;
41. br = new BufferedReader(new InputStreamReader(socket
42. .getInputStream()));
43. msg = “【” + this.socket.getInetAddress() + “】
进入聊天室！当前聊天室有【”
44. + list.size() + “】人”;
45. sendMessage();
46. }
47. public void run() {
48. try {
49. while ((msg = br.readLine()) != null) {
50. if (msg.trim().equals(“bye”)) {
51. list.remove(socket);
52. br.close();
53. pw.close();
54. msg = “【” + socket.getInetAddress() + “】
离开聊天室！当前聊天室有【”
55. + list.size() + “】人”;
56. socket.close();
57. sendMessage();
58. break;
59. } else {
60. msg = “【” + socket.getInetAddress() + “】说：” + msg;
61. sendMessage();
62. }
63. }
64. } catch (IOException e) {
65. e.printStackTrace();
66. }
67. }
68. /**
69. * 群发消息给聊天室的所有人
70. */
71. private void sendMessage() throws IOException {
72. System.out.println(msg);
73. for (Socket client : list) {
74. pw = new PrintWriter(client.getOutputStream(), true);
75. pw.println(msg);
76. }
77. }
78. }
79. }
80. import java.io.BufferedReader;
81. import java.io.InputStreamReader;
82. import java.io.PrintWriter;
83. import java.net.Socket;
84. import java.util.concurrent.ExecutorService;
85. import java.util.concurrent.Executors;
86. public class ChatClient {
87. private static final int PORT = 7891;
88. private static ExecutorService exec =
Executors.newCachedThreadPool();
89. public static void main(String[] args) throws Exception {
90. new ChatClient();
91. }
92. public ChatClient() {
93. try {
94. Socket socket = new Socket(“221.130.165.41″, PORT);
95. exec.execute(new Sender(socket));
96. System.out.println(“【” + socket.getInetAddress() + “】
您好，欢迎来到简易聊天室！”);
97. BufferedReader br = new BufferedReader(new
InputStreamReader(socket.getInputStream()));
98. String msg;
99. while ((msg = br.readLine()) != null) {
100. System.out.println(“收到—->”+msg);
101. }
102. } catch (Exception e) {
103. }
104. }