結合線程 java.awt exc iss order 新建 exception connect border

出處：http://blog.csdn.net/tuzongxun 最近的項目有一個在線網頁交流的需求，由於很久以前做過的demo已經忘記的差不多了，因此便重新學習一下。 我計劃的大致實現步驟分這樣幾大步： 1、使用awt組件和socket實現簡單的單客戶端向服務端持續發送消息； 2、結合線程，實現多客戶端連接服務端發送消息； 3、實現服務端轉發客戶端消息至所有客戶端，同時在客戶端顯示； 4、把awt組件生成的窗口界面改成前端jsp或者html展示的界面，java socket實現的客戶端改為前端技術實現。 這裏首先實現第一步的簡單功能，難點在於： 1、沒有用過awt組件，沒有用過java相關的監聽事件； 2、長時間沒有使用socket進行客戶端和服務端的交互，並且沒有真正進行過cs結構的開發。 實現功能的代碼如下： 客戶端： [java] view plain copy

1. package chat.chat;
3. import java.awt.BorderLayout;
4. import java.awt.Frame;
5. import java.awt.TextArea;
6. import java.awt.TextField;
7. import java.awt.event.ActionEvent;
8. import java.awt.event.ActionListener;
9. import java.awt.event.WindowAdapter;
10. import java.awt.event.WindowEvent;
11. import java.io.DataOutputStream;
12. import java.io.IOException;
13. import java.net.Socket;
14. import java.net.UnknownHostException;
16. /**
17. * 在線聊天客戶端 1、生成圖形窗口界面輪廓 2、為輪廓添加關閉事件 3、在輪廓中加入輸入區域和內容展示區域 4、為輸入區域添加回車事件
18. * 5、建立服務端連接並發送數據
19. *
20. * @author tuzongxun123
21. *
22. */
23. public class ChatClient extends Frame {
24. // 用戶輸入區域
25. private TextField tfTxt = new TextField();
26. // 內容展示區域
27. private TextArea tarea = new TextArea();
28. private Socket socket = null;
29. // 數據輸出流
30. private DataOutputStream dataOutputStream = null;
32. public static void main(String[] args) {
33. new ChatClient().launcFrame();
34. }
36. /**
37. * 建立一個簡單的圖形化窗口
38. *
39. * @author：tuzongxun
40. * @Title: launcFrame
41. * @param
42. * @return void
43. * @date May 18, 2016 9:57:00 AM
44. * @throws
45. */
46. public void launcFrame() {
47. setLocation(300, 200);
48. this.setSize(200, 400);
49. add(tfTxt, BorderLayout.SOUTH);
50. add(tarea, BorderLayout.NORTH);
51. pack();
52. // 監聽圖形界面窗口的關閉事件
53. this.addWindowListener(new WindowAdapter() {
55. @Override
56. public void windowClosing(WindowEvent e) {
57. System.exit(0);
58. disConnect();
59. }
60. });
61. tfTxt.addActionListener(new TFLister());
62. setVisible(true);
63. connect();
64. }
66. /**
67. * 連接服務器
68. *
69. * @author：tuzongxun
70. * @Title: connect
71. * @param
72. * @return void
73. * @date May 18, 2016 9:56:49 AM
74. * @throws
75. */
76. public void connect() {
77. try {
78. // 新建服務端連接
79. socket = new Socket("127.0.0.1", 8888);
80. // 獲取客戶端輸出流
81. dataOutputStream = new DataOutputStream(socket.getOutputStream());
82. System.out.println("連上服務端");
83. } catch (UnknownHostException e) {
84. e.printStackTrace();
85. } catch (IOException e) {
86. e.printStackTrace();
87. }
88. }
90. /**
91. * 關閉客戶端資源
92. *
93. * @author：tuzongxun
94. * @Title: disConnect
95. * @param
96. * @return void
97. * @date May 18, 2016 9:57:46 AM
98. * @throws
99. */
100. public void disConnect() {
101. try {
102. dataOutputStream.close();
103. socket.close();
104. } catch (IOException e) {
105. e.printStackTrace();
106. }
107. }
109. /**
110. * 向服務端發送消息
111. *
112. * @author：tuzongxun
113. * @Title: sendMessage
114. * @param @param text
115. * @return void
116. * @date May 18, 2016 9:57:56 AM
117. * @throws
118. */
119. private void sendMessage(String text) {
120. try {
121. dataOutputStream.writeUTF(text);
122. dataOutputStream.flush();
123. } catch (IOException e1) {
124. e1.printStackTrace();
125. }
126. }
128. /**
129. * 圖形窗口輸入區域監聽回車事件
130. *
131. * @author tuzongxun123
132. *
133. */
134. private class TFLister implements ActionListener {
136. @Override
137. public void actionPerformed(ActionEvent e) {
138. String text = tfTxt.getText().trim();
139. tarea.setText(text);
140. tfTxt.setText("");
141. // 回車後發送數據到服務器
142. sendMessage(text);
143. }
144. }
145. }

服務端： [java] view plain copy

1. package chat.chat;
3. import java.io.DataInputStream;
4. import java.io.EOFException;
5. import java.io.IOException;
6. import java.net.BindException;
7. import java.net.ServerSocket;
8. import java.net.Socket;
10. /**
11. * java使用socket和awt組件簡單實現在線聊天功能服務端 可以實現一個客戶端連接後不斷向服務端發送消息
12. * 但不支持多個客戶端同時連接，原因在於代碼中獲得客戶端連接後會一直循環監聽客戶端輸入，造成阻塞
13. * 以至於服務端無法二次監聽另外的客戶端，如要實現，需要使用異步或者多線程
14. *
15. * @author tuzongxun123
16. *
17. */
18. public class ChatServer {
20. public static void main(String[] args) {
21. // 是否成功啟動服務端
22. boolean isStart = false;
23. // 服務端socket
24. ServerSocket ss = null;
25. // 客戶端socket
26. Socket socket = null;
27. // 服務端讀取客戶端數據輸入流
28. DataInputStream dataInputStream = null;
29. try {
30. // 啟動服務器
31. ss = new ServerSocket(8888);
32. } catch (BindException e) {
33. System.out.println("端口已在使用中");
34. // 關閉程序
35. System.exit(0);
36. } catch (Exception e) {
37. e.printStackTrace();
38. }
40. try {
41. isStart = true;
42. while (isStart) {
43. boolean isConnect = false;
44. // 啟動監聽
45. socket = ss.accept();
46. System.out.println("one client connect");
47. isConnect = true;
48. while (isConnect) {
49. // 獲取客戶端輸入流
50. dataInputStream = new DataInputStream(
51. socket.getInputStream());
52. // 讀取客戶端傳遞的數據
53. String message = dataInputStream.readUTF();
54. System.out.println("客戶端說：" + message);
55. }
57. }
58. } catch (EOFException e) {
59. System.out.println("client closed!");
60. } catch (Exception e) {
61. e.printStackTrace();
62. } finally {
63. // 關閉相關資源
64. try {
65. dataInputStream.close();
66. socket.close();
67. } catch (IOException e) {
68. e.printStackTrace();
69. }
70. }
71. }
72. }

java Socket實現簡單在線聊天（一）