`

java socket/swing聊天系统

 
阅读更多
上个周五的下午，在公司闲来无事，
写了个小程序玩玩，
稍微测试了一下，居然能用！
但由于代码量较少，也谈不上什么设计，
发上来算是个备忘吧：
服务器端程序：
  1. packagecom.test.talk;
  3. importjava.awt.BorderLayout;
  4. importjava.awt.FlowLayout;
  5. importjava.awt.event.ActionEvent;
  6. importjava.awt.event.ActionListener;
  7. importjava.awt.event.WindowAdapter;
  8. importjava.awt.event.WindowEvent;
  9. importjava.io.DataInputStream;
  10. importjava.io.DataOutputStream;
  11. importjava.io.IOException;
  12. importjava.net.BindException;
  13. importjava.net.ServerSocket;
  14. importjava.net.Socket;
  15. importjava.util.LinkedList;
  16. importjava.util.List;
  18. importjavax.swing.JButton;
  19. importjavax.swing.JFrame;
  20. importjavax.swing.JLabel;
  21. importjavax.swing.JPanel;
  22. importjavax.swing.JTextField;
  24. publicclassServerextendsJFrame
  25. {
  26. booleanstarted=false;
  28. privateServerSocketss=null;
  30. privateListclientList=newLinkedList();
  32. privateJLabelportLbl=null;
  34. privateJTextFieldportTxt=null;
  36. privateJButtonportSetBtn=null;
  38. privateStringport=null;
  40. privateJButtonstartBtn=null;
  42. privateJButtonstopBtn=null;
  44. privateJPanelmainPanle=null;
  46. privateJPanelheadPanle=null;
  48. publicstaticvoidmain(String[]args)
  49. {
  50. newServer();
  51. }
  53. publicServer()
  54. {
  55. headPanle=newJPanel(newFlowLayout(FlowLayout.LEFT));
  56. portLbl=newJLabel("PORT");
  57. portTxt=newJTextField(7);
  58. portSetBtn=newJButton("OK");
  59. portSetBtn.addActionListener(newActionListener()
  60. {
  61. publicvoidactionPerformed(ActionEvente)
  62. {
  63. if(portTxt.getText().matches("//d+"))
  64. {
  65. port=portTxt.getText();
  66. startBtn.setEnabled(true);
  67. stopBtn.setEnabled(true);
  68. }
  69. else
  70. {
  71. javax.swing.JOptionPane.showMessageDialog(null,"portbeinputtedisillegal");
  72. }
  73. }
  74. });
  75. headPanle.add(portLbl);
  76. headPanle.add(portTxt);
  77. headPanle.add(portSetBtn);
  78. getContentPane().add(headPanle,BorderLayout.NORTH);
  79. startBtn=newJButton("Start");
  80. stopBtn=newJButton("Stop");
  81. startBtn.setEnabled(false);
  82. stopBtn.setEnabled(false);
  83. mainPanle=newJPanel(newFlowLayout(FlowLayout.CENTER));
  84. startBtn.addActionListener(newStartClickListener());
  86. stopBtn.addActionListener(newActionListener()
  87. {
  88. publicvoidactionPerformed(ActionEvente)
  89. {
  90. started=false;
  91. clientList.clear();
  92. try
  93. {
  94. if(ss!=null)
  95. {
  96. ss.close();
  97. }
  98. }
  99. catch(IOExceptione1)
  100. {
  101. e1.printStackTrace();
  102. }
  103. }
  104. });
  105. mainPanle.add(startBtn);
  106. mainPanle.add(stopBtn);
  107. getContentPane().add(mainPanle,BorderLayout.CENTER);
  109. addWindowListener(newWindowAdapter()
  110. {
  111. publicvoidwindowClosing(WindowEvente)
  112. {
  113. started=false;
  114. clientList.clear();
  115. try
  116. {
  117. if(ss!=null)
  118. {
  119. ss.close();
  120. }
  121. }
  122. catch(IOExceptione1)
  123. {
  124. e1.printStackTrace();
  125. }
  126. System.exit(0);
  127. }
  128. });
  130. this.setSize(300,300);
  131. setLocation(100,100);
  132. pack();
  133. setVisible(true);
  134. }
  136. privatevoidstart()
  137. {
  138. try
  139. {
  140. ss=newServerSocket(Integer.parseInt(port));
  141. started=true;
  142. }
  143. catch(BindExceptionbe)
  144. {
  145. javax.swing.JOptionPane.showMessageDialog(null,"portisuseingbyothers");
  146. }
  147. catch(IOExceptione)
  148. {
  149. javax.swing.JOptionPane.showMessageDialog(null,"connectserverfail");
  150. }
  151. try
  152. {
  153. while(started)
  154. {
  155. Sockets=ss.accept();
  156. ClientImplcr=newClientImpl(s);
  157. newThread(cr).start();
  158. clientList.add(cr);
  159. System.out.println("SystemInfo："+s.getInetAddress()+"connectsuccessfully");
  160. }
  161. }
  162. catch(IOExceptione)
  163. {
  164. System.out.println("Clientclosed!");
  165. }
  166. }
  168. classClientImplimplementsRunnable
  169. {
  170. privateSockets;
  172. privateDataInputStreamdis=null;
  174. privateDataOutputStreamdos=null;
  176. booleanbConnect=false;
  178. publicClientImpl(Sockets)
  179. {
  180. this.s=s;
  181. try
  182. {
  183. dis=newDataInputStream(s.getInputStream());
  184. dos=newDataOutputStream(s.getOutputStream());
  185. bConnect=true;
  186. }
  187. catch(IOExceptione)
  188. {
  189. e.printStackTrace();
  190. }
  191. }
  193. privatevoidsend(Stringstr)
  194. {
  195. try
  196. {
  197. dos.writeUTF(str);
  198. }
  199. catch(IOExceptione)
  200. {
  201. e.printStackTrace();
  202. }
  204. }
  206. publicvoidrun()
  207. {
  208. ClientImplcr=null;
  209. try
  210. {
  211. while(bConnect)
  212. {
  213. Stringstr=dis.readUTF();
  214. System.out.println(str);
  215. for(inti=0;i<clientList.size();i++)
  216. {
  217. cr=(ClientImpl)clientList.get(i);
  218. cr.send(str);
  219. }
  220. }
  221. }
  222. catch(Exceptione)
  223. {
  224. clientList.remove(cr);
  225. System.out.println(s.getInetAddress()+"hasleaved");
  226. }
  227. finally
  228. {
  229. try
  230. {
  231. if(dis!=null)
  232. dis.close();
  233. if(dos!=null)
  234. dos.close();
  235. if(s!=null)
  236. {
  237. s.close();
  238. s=null;
  239. }
  240. }
  241. catch(IOExceptionio)
  242. {
  243. io.printStackTrace();
  244. }
  245. }
  246. }
  247. }
  249. classStartClickListenerimplementsRunnable,ActionListener
  250. {
  251. publicvoidactionPerformed(ActionEvente)
  252. {
  253. newThread(this).start();
  254. }
  256. publicvoidrun()
  257. {
  258. start();
  259. }
  260. }
  261. }
客户端程序：
  1. packagecom.test.talk;
  3. importjava.awt.BorderLayout;
  4. importjava.awt.FlowLayout;
  5. importjava.awt.event.ActionEvent;
  6. importjava.awt.event.ActionListener;
  7. importjava.awt.event.WindowAdapter;
  8. importjava.awt.event.WindowEvent;
  9. importjava.io.DataInputStream;
  10. importjava.io.DataOutputStream;
  11. importjava.io.IOException;
  12. importjava.net.Socket;
  13. importjava.net.UnknownHostException;
  15. importjavax.swing.JButton;
  16. importjavax.swing.JFrame;
  17. importjavax.swing.JLabel;
  18. importjavax.swing.JPanel;
  19. importjavax.swing.JTextArea;
  20. importjavax.swing.JTextField;
  22. /**
  23. *Client
  24. *
  25. *@authorhx0272
  26. *
  27. */
  28. publicclassClient
  29. {
  30. publicstaticvoidmain(String[]args)
  31. {
  32. ClientFrameframe=newClientFrame();
  33. }
  34. }
  36. classClientFrameextendsJFrame
  37. {
  38. privateJPanelmainPanel;
  40. privateJPanelheadPanel;
  42. privateJPanelfootPanel;
  44. privateJTextAreashowArea;
  46. privateJTextFieldinputTxt;
  48. privateJLabelportLbl;
  50. privateJLabelipLbl;
  52. privateJLabelnameLbl;
  54. privateJTextFieldportTxt;
  56. privateJTextFieldipTxt;
  58. privateJTextFieldnameTxt;
  60. privateJButtonsubmitBtn;
  62. privateJButtonnameBtn;
  64. privateJButtonloginBtn;
  66. privateSocketclientSocket=null;
  68. privateDataOutputStreamdos=null;
  70. privateDataInputStreamdis=null;
  72. privatebooleanbConnect=false;
  74. privateStringname="";
  76. publicClientFrame()
  77. {
  78. init();
  79. }
  81. privatevoidinit()
  82. {
  83. //mainpanelBegin
  84. mainPanel=newJPanel();
  85. showArea=newJTextArea(15,80);
  86. showArea.setEditable(false);
  87. mainPanel.add(showArea);
  88. getContentPane().add(mainPanel,BorderLayout.CENTER);
  89. //mainpanelEnd
  91. //headpanelBegin
  92. headPanel=newJPanel(newFlowLayout(FlowLayout.LEFT));
  93. portLbl=newJLabel("PORT");
  94. portTxt=newJTextField(7);
  95. ipLbl=newJLabel("IP");
  96. ipTxt=newJTextField(25);
  98. nameLbl=newJLabel("name");
  100. nameTxt=newJTextField(15);
  102. nameBtn=newJButton("OK");
  104. loginBtn=newJButton("login");
  105. nameBtn.addActionListener(newActionListener()
  106. {
  107. publicvoidactionPerformed(ActionEvente)
  108. {
  109. Stringtmp=nameTxt.getText();
  110. if(tmp!=null||!tmp.equals(""))
  111. {
  112. intid=javax.swing.JOptionPane.showConfirmDialog(null,"yesorno","chooseyes",
  113. javax.swing.JOptionPane.OK_OPTION);
  114. if(id==0)
  115. {
  116. name=nameTxt.getText();
  117. loginBtn.setEnabled(true);
  118. nameBtn.setEnabled(false);
  119. }
  120. }
  121. }
  122. });
  123. headPanel.add(portLbl);
  124. headPanel.add(portTxt);
  125. headPanel.add(ipLbl);
  126. headPanel.add(ipTxt);
  128. headPanel.add(loginBtn);
  129. headPanel.add(nameLbl);
  130. headPanel.add(nameTxt);
  131. headPanel.add(nameBtn);
  132. loginBtn.setEnabled(false);
  133. loginBtn.addActionListener(newButtonClickAction());
  134. getContentPane().add(headPanel,BorderLayout.NORTH);
  135. //headpanelEnd
  137. //footpanelBegin
  138. footPanel=newJPanel(newFlowLayout(FlowLayout.LEFT));
  139. inputTxt=newJTextField(70);
  140. submitBtn=newJButton("submit");
  142. footPanel.add(inputTxt);
  143. footPanel.add(submitBtn);
  145. submitBtn.addActionListener(newButtonClickAction());
  146. submitBtn.setEnabled(false);
  147. getContentPane().add(footPanel,BorderLayout.SOUTH);
  148. //footpanelEnd
  150. addWindowListener(newWindowAdapter()
  151. {
  152. publicvoidwindowClosing(WindowEvente)
  153. {
  154. disConnect();
  155. System.exit(0);
  156. }
  157. });
  159. this.setSize(300,300);
  160. setLocation(100,100);
  161. pack();
  162. setVisible(true);
  163. }
  165. /**
  166. *loginbutton/submitbuttonactionlistener
  167. *
  168. *@authorhx0272
  169. *
  170. */
  171. classButtonClickActionimplementsActionListener
  172. {
  173. publicvoidactionPerformed(ActionEvente)
  174. {
  175. if("submit".equals(e.getActionCommand()))
  176. {
  177. Stringstr=inputTxt.getText().trim();
  178. inputTxt.setText("");
  179. sendToServer(str);
  180. }
  181. elseif("login".equals(e.getActionCommand()))
  182. {
  183. connect();
  184. }
  185. }
  186. }
  188. /**
  189. *enterbeinputtedevent
  190. *
  191. *@authorhx0272
  192. */
  193. classEnterClickActionimplementsActionListener
  194. {
  195. publicvoidactionPerformed(ActionEvente)
  196. {
  197. Stringstr=inputTxt.getText().trim();
  198. inputTxt.setText("");
  199. sendToServer(str);
  200. }
  201. }
  203. /**
  204. *sendmessagetoserver
  205. *
  206. *@authorhx0272
  207. */
  208. privatevoidsendToServer(Stringstr)
  209. {
  210. try
  211. {
  212. dos.writeUTF(name+":"+str);
  213. dos.flush();
  214. }
  215. catch(IOExceptione)
  216. {
  217. e.printStackTrace();
  218. }
  219. }
  221. /**
  222. *closeresource
  223. *
  224. *@authorhx0272
  225. */
  226. privatevoiddisConnect()
  227. {
  228. try
  229. {
  230. //clientSocket.close();
  231. //
  232. //dos.close();
  234. bConnect=false;
  235. }
  236. catch(Exceptione)
  237. {
  238. e.printStackTrace();
  239. }
  240. }
  242. /**
  243. *receivemessagefromserver
  244. *
  245. *@authorhx0272
  246. */
  247. privateclassReceiveimplementsRunnable
  248. {
  249. publicvoidrun()
  250. {
  251. try
  252. {
  253. while(bConnect)
  254. {
  255. Stringstr=dis.readUTF();
  256. showArea.setText(showArea.getText()+str+'/n');
  257. }
  258. }
  259. catch(IOExceptione)
  260. {
  261. javax.swing.JOptionPane.showMessageDialog(null,"connectservererror");
  262. }
  264. }
  265. }
  267. /**
  268. *connectionbegin
  269. *
  270. *@authorhx0272
  271. */
  272. privatevoidconnect()
  273. {
  274. try
  275. {
  276. if(ipTxt.getText().matches("//d{1,3}.//d{1,3}.//d{1,3}.//d{1,3}")&&portTxt.getText().matches("//d+"))
  277. {
  278. clientSocket=newSocket(ipTxt.getText(),Integer.parseInt(portTxt.getText()));
  279. dos=newDataOutputStream(clientSocket.getOutputStream());
  280. dis=newDataInputStream(clientSocket.getInputStream());
  281. bConnect=true;
  282. newThread(newReceive()).start();
  283. System.out.println("Iamcoming");
  284. javax.swing.JOptionPane.showMessageDialog(null,"connectserversuccess");
  285. submitBtn.setEnabled(true);
  286. inputTxt.addActionListener(newEnterClickAction());
  287. }
  288. else
  289. {
  290. javax.swing.JOptionPane.showMessageDialog(null,"portoripbeinputtedisillegal");
  291. }
  292. }
  293. catch(UnknownHostExceptionuhe)
  294. {
  295. javax.swing.JOptionPane.showMessageDialog(null,"connectservererror");
  296. }
  297. catch(IOExceptione)
  298. {
  299. javax.swing.JOptionPane.showMessageDialog(null,"connectservererror");
  300. }
  301. }
  302. }
使用说明：
1.先运行服务器端程序，设定好端口号
2.点击Start按钮，运行服务器
3.运行客户端程序
4.设定好昵称
5.设定与服务器端匹配的端口号和服务器的ip地址
6.点击Login按钮，登录到聊天系统
7.可以聊天了。

分享到：
评论
发表评论

您还没有登录,请您登录后再发表评论

相关推荐

    java基于socket/server的多线程聊天室程序，可以公聊和私聊。

    综上所述，本程序通过综合运用Java Socket编程、多线程技术和Swing图形界面库，成功实现了具有公聊和私聊功能的聊天室应用。这对于学习网络编程、多线程以及Java GUI开发都有着重要的参考价值。

    java Socket，Swing聊天室系统的设计与实现答辩.ppt

    java Socket，Swing聊天室系统的设计与实现答辩.ppt

    java Socket，Swing聊天室系统的设计与实现毕业论文.doc

    "java Socket，Swing聊天室系统的设计与实现毕业论文" 本资源摘要信息提供了关于 Java Socket 和 Swing 聊天室系统的设计与实现的毕业论文。该论文旨在设计和实现一个基于 C/S 架构的聊天室系统，使用 Java 语言、...

    Java swing实现简单的C/S聊天及文件传输系统

    在这个项目中，"Java swing实现简单的C/S聊天及文件传输系统"是利用Swing构建一个客户端/服务器（Client/Server）架构的聊天和文件传输应用。这个系统允许用户通过网络进行文本聊天并交换文件。以下是关于这个项目的...

    C/S聊天程序(JAVA,C/S)

    7. **用户界面**：客户端的用户界面通常使用Java Swing或JavaFX库来构建，提供友好的交互体验，包括文本输入框、聊天窗口和按钮等元素。 8. **事件驱动编程**：Java的事件模型使得程序能够响应用户的输入，如点击...

    java swing socket写的聊天工具

    Java Swing 是Java GUI（图形用户界面）库，用于构建桌面应用程序。...总的来说，这个Java Swing和Socket结合的聊天工具是一个综合性的项目，涵盖了GUI设计、网络编程、多线程和并发控制等多个IT领域的知识点。

    java+swing聊天室

    Java Swing聊天室是一种基于Java GUI（图形用户界面）框架Swing构建的实时通信应用程序。Swing是Java标准库的一部分，提供了丰富的组件库，用于创建桌面应用程序。在这个项目中，我们将探讨如何利用Java Swing来实现...

    java swing socket聊天

    在这个Java Swing聊天应用中，服务器端会监听特定的端口，等待客户端的连接请求。当客户端连接成功后，服务器会为每个客户端创建一个新的Socket连接，以实现一对一的通信。客户端则通过Socket连接到服务器，向服务器...

    面试作品java c/s聊天室带简单界面

    2. **GUI（图形用户界面）**：Java的Swing或JavaFX库可以用来创建用户友好的交互界面，包括登录窗口、聊天窗口、在线用户列表等。用户可以通过GUI输入和查看信息，增强了用户体验。 3. **文件IO**：文件输入/输出在...

    java swing+socket实现多人聊天程序

    java 利用swing+socket实现多人聊天程序，分客户端，服务端，运行效果参考博客 https://blog.csdn.net/wcc27857285/article/details/84038401

    Java聊天室 Swing编程 socket

    Java聊天室是一个基于Swing图形用户界面（GUI）和Socket通信技术实现的桌面应用程序。Swing是Java标准版（Java SE）的一部分，提供了一套丰富的组件库，用于创建美观、功能丰富的用户界面。Socket编程是网络编程的...

    即时聊天程序java socket swing

    在这个场景中，Java Socket 和 Swing 框架被广泛应用于构建客户端-服务器（C/S）架构的系统。下面我们将深入探讨这些技术及其在即时聊天程序中的应用。 1. **Java Socket** Java Socket 是 Java 提供的网络编程...

    Java TCP /IP socket 自制简易聊天工具

    在UI方面，这个简易聊天工具可能使用了Java的Swing或JavaFX库来创建图形用户界面。用户可以输入文本，点击发送按钮将消息通过Socket发送到服务器，同时，程序也会从服务器接收消息并在界面上显示。 代码结构可能...

    仿QQ聊天系统（java swing）

    【标题】"仿QQ聊天系统（java swing）"是一个基于Java Swing开发的桌面...通过这个项目，学习者可以锻炼解决问题的能力，提高对Java Swing、多线程和Socket编程的理解，并了解如何将这些技术应用于实际的聊天系统中。

    java的Socket实现的多人聊天程序

    Java的Socket实现的多人聊天程序是一个基于网络通信的项目，主要利用了Java的Socket类来构建客户端和服务端的通信桥梁。Socket是TCP/IP协议的一部分，它提供了两台计算机之间进行数据传输的基础。在这个项目中，...

    java swing 多功能 聊天室

    通过查看和学习这个项目的源码，开发者可以深入理解Java Swing在实际项目中的应用，以及如何结合网络编程实现一个功能完善的聊天室系统。 总的来说，"java swing 多功能 聊天室"项目展示了Java Swing在构建复杂GUI...

    基于java Swing 框架使用socket技术开发的即时通讯系统【源码+数据库】

    本项目是一套基于java Swing 框架使用socket技术开发的即时通讯系统，主要针对计算机相关专业的正在做bishe的学生和需要项目实战练习的Java学习者。 包含：项目源码、数据库脚本等，该项目可以直接作为bishe使用。 ...

    Java+Swing即时聊天系统，客户端和服务端，多线程,socket

    总结起来，Java+Swing即时聊天系统是通过结合Java的Swing库构建用户界面，利用多线程进行并发处理，通过Socket进行网络通信，实现用户间的实时消息传递。这样的系统为学习和理解Java的GUI编程、多线程以及网络编程...

    java多线程+Socket+Swing做的局域网聊天程序

    【标题】"java多线程+Socket+Swing做的局域网聊天程序"涉及的核心知识点主要涵盖Java编程、多线程、网络通信以及图形用户界面设计。以下将详细阐述这些关键概念及其在实现局域网聊天程序中的应用。 **1. Java编程**...

Magicbox
Global site tag (gtag.js) - Google Analytics