一个简易聊天功能的服务器端和客户端源码
2014-08-27 17:01
148 查看
本文来自:小易博客专栏。转载请注明出处:http://blog.csdn.net/oldinaction
学习完J2SE可以写一个简易的聊天软件来让刚学的知识融会贯通,代码注释的很详细哦!
学习完J2SE可以写一个简易的聊天软件来让刚学的知识融会贯通,代码注释的很详细哦!
开发版本历程:
V0.1:客户端实现一个界面 V0.2:客户端界面有输入框和显示框的界面 V0.3:客户端关闭按钮可以关闭窗口 V0.4:客户端按回车后输入框的文字显示在显示框 V0.5:服务端能够起一个服务监听某端口 V0.6:客户端能够连接到服务器端 V0.7:客户端发一条消息,服务端能够接收到 V0.8:服务器端能到接收多条来自客户端的消息,改善V0.7的只能接受一条消息 V0.9:客户端关闭后,服务器端采取相应的措施,是服务器端不报错 V1.0:服务器端可以连接多个客户端,并且可以接收到来自每个客户端发送的消息 V1.1:服务器端把接收到每个客户端的消息发送出去 V1.2:每个客户端都能接收来自服务器的数据,并显示在显示框 V1.3:检查一些异常并修复(下面的代码就是这个版本) 注:代码还有很多改进的地方,这只是一个简易的版本
聊天服务器端代码:
import java.io.*; import java.net.*; import java.util.*; public class ChatServer { boolean started = false; ServerSocket ss = null; List<Client> clients = new ArrayList<Client>(); public static void main(String[] args){ new ChatServer().start(); //不能直接这样调用start() } public void start(){ try { ss = new ServerSocket(8888); //在端口8888建立监听 started = true; //建立监听成功令此变量为真 }catch (SocketException e){ System.out.println("端口使用中。。。"); System.out.println("请关掉相关程序!"); System.exit(0); }catch (IOException e) { e.printStackTrace(); } try{ while(started){ Socket s = ss.accept(); //***重要***若此处报错,尝试用360进行LSP修复 Client c = new Client(s); //每接受一个客户端就会new一个线程 System.out.println("a client connected"); new Thread(c).start(); //启动线程,start()方法只是启动线程,而线程中的run()方法这是实现此线程功能的代码 clients.add(c); } }catch (IOException e) { e.printStackTrace(); }finally{ try { ss.close(); } catch (IOException e) { e.printStackTrace(); } } } //定义一个线程内部类 class Client implements Runnable{ private Socket s; private DataInputStream dis = null; private DataOutputStream dos = null; private boolean bConnected = false; public Client(Socket s){ this.s=s; try { dis = new DataInputStream(s.getInputStream()); dos = new DataOutputStream(s.getOutputStream()); bConnected = true; // 有一个客户端连上后另此变量为真 } catch (IOException e) { e.printStackTrace(); } } public void send(String str){ try { dos.writeUTF(str); } catch (IOException e) { clients.remove(this);//防止有一个客户端退出了,其他客户端还在发消息,此时List里面还有这个退出的客户端,服务器就会报错 System.out.println("对方退出了,已经从List里面去除了!"); } } public void run() { try { while (bConnected) { String str = dis.readUTF(); //readUTF()是一个阻塞式的,main方法执行到此处就一直一行一行的读,程序停在此处 System.out.println(str); for(int i = 0; i < clients.size(); i++){ Client c = clients.get(i); c.send(str); } } }catch(EOFException e){ System.out.println("Client closed!"); }catch (IOException e) { e.printStackTrace(); }finally{ try { if(dis != null) dis.close(); if(dos != null) dos.close(); if(s != null) s.close(); } catch (IOException e1) { e1.printStackTrace(); } } } } }
聊天客户端代码:
import java.awt.*; import java.awt.event.*; import java.io.*; import java.net.*; //客户端ChatClient public class ChatClient extends Frame{ //响应他的事件,需要去访问他的内容,所以定义为成员变量 TextField tfTxt = new TextField(); TextArea taContent = new TextArea(); Socket s = null; DataOutputStream dos = null; DataInputStream dis = null; private boolean bConnected = false; Thread tRecv = new Thread(new RecvThread()); public static void main(String[] args) { new ChatClient().launchFrame(); } //运行客户端窗口的方法 public void launchFrame(){ this.setLocation(400,300); setSize(300,300); add(tfTxt,BorderLayout.SOUTH); //BorderLayout为Frame默认布局管理器。调用其他应调用setLayout(某个布局管理器对象) add(taContent,BorderLayout.NORTH); pack(); //如果没有pack();则两个控件中有空的部分 //使用匿名类添加窗口的事件监听器,注意WindowAdapter()的使用,windowClosing将要关闭窗口 this.addWindowListener(new WindowAdapter() { public void windowClosing(WindowEvent e) { disconnect(); System.exit(0); } }); //把监听器添加在文本框上,此时回车直接返回对象的信息,不需要添加Enter的KeyListener tfTxt.addActionListener(new TFListener()); setVisible(true); connect(); tRecv.start(); } public void connect(){ try { s = new Socket("127.0.0.1",8888); dos = new DataOutputStream(s.getOutputStream()); dis = new DataInputStream(s.getInputStream()); System.out.println("connected!"); bConnected = true; } catch (UnknownHostException e) { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); } } public void disconnect() { try { dos.close(); dis.close(); s.close(); } catch (IOException e) { e.printStackTrace(); } } private class TFListener implements ActionListener { public void actionPerformed(ActionEvent e) { String str = tfTxt.getText().trim(); //String里面的方法trim()去掉两边的空格 tfTxt.setText(""); //设置一个空字符串,让文本框里面的内容为空 try { dos.writeUTF(str); dos.flush(); } catch (IOException e1) { e1.printStackTrace(); } } } private class RecvThread implements Runnable { @Override public void run() { try { while (bConnected) { String str = dis.readUTF(); taContent.setText(taContent.getText() + str + '\n'); } } catch(SocketException e){ System.out.println("退出了,bye!"); } catch (IOException e) { e.printStackTrace(); } } } }
相关文章推荐
- 一个简易聊天功能的服务器端和客户端源码
- java nio SocketChannel 服务器端与多客户端 信息交互(聊天功能)
- java nio SocketChannel 服务器端与多客户端 信息交互(聊天功能)
- 我现在在做一个app,里面要有聊天的功能,但是我在网上找了好多例子,我都没有运行成功,希望路过的大神能给我点指导或者源码也行
- Remoting模仿QQ实现客户端,服务器端聊天功能
- nodejs简单实现TCP服务器端和客户端的聊天功能示例
- Android网络编程之一个Android下菜单系统模块的实现(开桌功能))(Android客户端+服务器端Servlet+Mysql)
- 一个客户端和一个服务器端聊天
- 基于Java Socket实现一个简易在线聊天功能(一)
- 简单迭代服务器端/客户端:模仿飞Q聊天功能,实现IM通信
- nodejs中一个简单的TCP服务器端和客户端的聊天服务器
- 直播时代:让IOS普通开发者一天内做出一个RTMP直播客户端,并且带有美艳直播功能。(文章最下面有github源码地址)
- Remoting模仿QQ实现客户端,服务器端聊天功能
- java在线聊天项目0.7版 连接多个客户端问题,开启多个客户端后服务器端只接收到一个 对各种异常的补充处理
- Socket——实现简单的一对一服务器端与客户端聊天功能
- 简易聊天程序教程(四)客户端基本功能
- H264音视频直播系统 服务器端+客户端源码 可用于视频聊天、视频会议
- 用服务器端和客户端来实现聊天功能
- 直播项目,在线聊天功能--socket实现客户端和服务器端通讯的简单案例
- 基于TCP/IP的手机聊天游戏(附带源码和解释)之服务器端类