我于2014年开启即时通讯的开发之路，历经从服务端到客户端，从第三方到自研，经历过诸多的研发难题，都一一破解。现将经验总结如下，希望对行业内从事IM开发的程序员有所帮助。
成都创新互联是创新、创意、研发型一体的综合型网站建设公司，自成立以来公司不断探索创新，始终坚持为客户提供满意周到的服务，在本地打下了良好的口碑，在过去的十载时间我们累计服务了上千家以及全国政企客户，如成都三维植被网等企业单位，完善的项目管理流程，严格把控项目进度与质量监控加上过硬的技术实力获得客户的一致称扬。
①P2P方式
P2P方式多用于局域网内聊天，这种方式在有种种限制和不便。一方面它只适合在线的点对点消息传输，对离线，群组等支持不够。另一方面由于 NAT 的存在，使得不同局域网内机器互联难度大大上升，在某些网络类型(对称NAT)下无法建立连接。使用P2P方式的软件在启动后一般做两件事情：
1、进行UDP广播:发送自己信息和接受同局域网内其他端信息。
2、开启TCP监听:等待其他端进行连接。
②服务器中转方式
大部分的互联网IM产品都采用服务器中转这种方式进行消息传输，相对于P2P的方式，具有有以下的优点:
1、支持更多P2P无法支持或支持不好的业务，如离线消息，群组，聊天室。
2、方便业务逻辑的拓展和新旧版本的兼容，当然它也有自己的问题，就是服务器架构复杂，并发要求高。
通过以上的比较，建议我们在开发IM系统的时候使用服务器中转的方式。
IM的网络连接方式有基于TCP的长连接和基于HTTP短连接两种:
①基于TCP的长连接
基于TCP长连接则能够更好地支持大批量用户，问题是客户端和服务器的实现比较复杂。也有一些改进，比如下行使用MQTT进行服务器通知/消息的下发，上行使用HTTP短连接进行指令和消息的上传。这种方式能够保证下行消息/指令的及时性，但是在弱网络下上行慢的问题还是比较严重，早期的来往就是基于这种方式。
②基于HTTP短连接
常见于WEB IM系统(现在很多WEBIM都是基于WebSocket实现)，它的优点是实现简单，方便开发上手，问题是流量大，服务器负载较大，消息及时性无法很好地保证，对大规模的用户量支持不够，适合小型的IM系统。
IM常见的协议有：XMPP，MQTT，私有协议。各种协议优缺点情况如下：
①XMPP协议
优点：协议开源，可拓展性强，在各个端(有各种语言的实现，对于前期入门级的开发者是很好的选择，方便进入IM开发的程序员快速上手。
缺点：XML表现力弱，有太多冗余信息，流量大。
常见案例：Gtalk、新浪微博、Facebook。
②MQTT协议
优点：协议简单，流量少。
缺点：不是一个专门为IM设计的协议，多使用于推送。
③私有协议
几乎所有主流的IM APP都是使用私有协议。
优点：高效，节约流量(一般使用二进制协议)，安全性高，难以破解。
缺点：开发初期没有现有样列可以参考，对于参与IM开发的程序员的要求比较高。
常见案例：微信、钉钉。
根据以上的对比，我们得出结果，一个好的协议需要满足高效、简洁、节约流量、易于拓展等要求，同时又能够和当前的开发团队的技术堆栈匹配，不能选择一个他们很难上手的。
这里再提一下，我当时开发IM系统的时候，上手用的是XMPP，在使用的过程中发现了很多问题，踩了很多坑。
①实时性原则
消息实时到达接收方，如果用户在线，则消息实时到达，如果用户不在线，则消息在用户登录后到达。由于网络波动，以及移动端操作系统对应用前后台切换的管理，如何实现用户连接管理、消息实时推送，推送失败的处理方式，客户端重连机制，消息如何补齐等，都需要IM系统考虑。由于TCP开发略微复杂，早期的基于HTTP短轮询、长轮询的低效的技术方案，也无法达到实时性的要求。
②可靠性原则
是指我们经常听到的“消息送达”，通常用消息的不丢失和不重复两个技术指标来表示。可靠性是要确保消息被发送后，能够被接收者收到。由于网络环境的复杂性，以及用户在线的不确定性，消息的可靠性（不丢失、不重复）是IM系统的核心指标，也是IM系统实现中的难点之一。总体来说，IM系统的消息“可靠性”，通常就是指聊天消息投递的可靠性（准确的说，这个“消息”是广义的，因为还存用户看不见的各种指令和通知，包括但不限于进群退群通知、好友添加通知等，为了方便描述，统称“消息”）。
从消息发送者和接收者用户行为来讲，消息“可靠性”应该分为以下几种情况：
1、发送失败：对于这种情况要感知到，明确反馈给发送方。如果此消息没有发送成功，发送方可以选择重试或者稍后再试。
2、发送成功：如果接收方处在“在线”状态，应该立即收到此消息。如果接收方处在“离线”状态不能收到消息，一旦上线则立刻收到消息。
3、消息不能重复：简言之就是发送的一条消息不能被重复收到多次。
③一致性原则
系统中要重视消息的时序问题，不能出现发送的消息顺序颠倒的问题。通常出现时序的问题有以下的原因：
1、网络传输延迟导致时序不一致。不同用户发送的消息到达服务器的延时差异较大，给消息时序性带来挑战。早期开发过程中经常会遇到这种问题。
2、分布式系统的出现导致时序不一致。IM系统模块众多，接入层、消息逻辑层等、每层都分布式集群化，这些应用分布在不同的机器上，如何保证时序是个难点。
④扩展性原则
扩展性是IM系统后期要考虑的问题，包括功能的扩展，服务器的扩展等，这次就先不展开阐述。
Mina和Netty都是Java领域高性能和高可伸缩性网络应用程序的网络应用框架。
Mina是 Apache 组织的项目，它为开发高性能和高可用性的网络 应用程序提供的框架。当前的Mina版本支持基于 Java NIO 技术的 TCP/UDP 应用程序开发、串口通讯程序。目前正在使用 Mina的 软件有：Apache Directory Project、AsyncWeb、AMQP（Advanced Message Queuing Protocol）、RED5 Server（Macromedia Flash Media RTMP）、ObjectRADIUS、Openfire等。
Netty是由JBOSS提供的一个java开源框架。Netty提供异步的、 事件驱动的网络应用程序框架和工具，用以快速开发高性能、高可靠性的网络服务器和客户端程序。也就是说Netty是一个基于NIO的客户端和服务器端框架，使用Netty可以确保你快速和简单的开发出一个网络应用。
虽然我使用过Mina，但是建议开发选型上使用Netty 。因为Netty有对google protocal buf的支持，有更完整的ioc容器支持(spring,guice,jbossmc和osgi)。Mina更新到2.0就不再更新了，而Netty一直在更新，目前最新发布的版本已经更新到4.1，从版本更新角度可以看出Netty的社区很活跃，修复问题一直在持续，这将对我们选择它进行开发带来很多便利。
单体Netty IM系统，可以支持10万并发，如果机器性能良好的情况下可以超过10万。
分布式的Netty IM系统，可以支持更高的并发数。各组件的功能如下：
①IM Server 连接器：主要用来负责维持和客户端的TCP连接。
②缓存：负责用户、用户绑定关系、用户群组关系的缓存。 缓存临时数据、加快读速度。可以做成集群方式。
③数据库：用户、群组、离线消息。可以做成集群方式。
④消息队列：用户状态广播、群组消息广播。可以做成集群方式。
开发环境推荐使用netty-4.1.30这个版本，jdk使用1.8及以上版本。如下所示：
io.netty
netty-all
4.1.30.Final
①开发框架采用Netty + Spring(Spring4.x)。
②Spring采用Spring cloud。基于restful 短连接的分布式微服务架构，完成用户在线管理、单点登录系统。
③消息队列采用rocketMQ 高速队列，整流作用。
④数据库采用MYSQL。
⑤协议JSON +自定义数据包采用Fastjson。
基于Netty的IM开源代码在网上有很多，这里就不列举了，可以自行去git上下载。我认为关键是把概念理清楚，技术堆栈选好，总体框架定好，接下来就是开发一个适合中小企业的IM系统了，但是要考虑到后期的扩展性，因为一个好的产品不能自己用，要让更多的人使用。
使用7z格式压缩上传
下载1：
下载2： att.newsmth.net/att.php?p.75.25665.766.7z
Java版源代码下载：
（有些网友对C++如何实现感兴趣，推荐一下Poco带的WebSocket功能，把Java源代码翻译成C++就行了）
1. 说明：
utf8版本，支持各种语言版本的windows系统
程序内嵌数据库
用户帐号非明文存储
在Firefox/Chrome浏览器测试通过，建议使用Chrome，Firefox不支持mp3的消息提示音
2. 现有功能
注册/登录/搜索/添加好友（需要双方互相添加对方为好友，才能互相聊天）
抖动窗口
两种状态，登录/离线
3.可扩展的功能
使用Windows域用户帐号，无需注册
收发离线信息
查看历史信息
新消息提示
群聊
共享文件
4. （可能）存在的问题
并发性未作充分测试
添加好友的确认
5. 适用的场景
学校
小公司
6.使用
解压后双击执行start.bat，将自动进入初始界面，如下图
默认使用80端口，若80端口已被占用，修改start.bat中的setserver_port=80
双击左上角图标，弹出对话框，可以选择注册
注册成功
登录
搜索好友，如不提供搜索条件，则返回所有已注册用户
添加好友
添加好友提示
聊天
这里有一个简单的模拟通讯 要先运行服务器端 再运行客户端 否则会报错：
服务器端代码：
package com.test3;
import java.net.*;
import java.io.*;
import javax.swing.*;
import java.awt.*;
import java.awt.event.*;
public class Server2 extends JFrame implements ActionListener , KeyListener {
JTextArea jta=null;
JScrollPane jsp=null;
JTextField jtf=null;
JButton jb=null;
JPanel jp=null;
InputStreamReader isr=null;
BufferedReader br=null;
PrintWriter pw=null;
Socket s;
String jtatext="";
public static void main(String[] args) {
// TODO Auto-generated method stub
Server2 sv2=new Server2();
}
public Server2(){
jta=new JTextArea();
jta.setEditable(false);
jsp=new JScrollPane(jta);
jtf=new JTextField(10);
jtf.addKeyListener(this);
jb=new JButton("发送");
jb.addActionListener(this);
jp=new JPanel();
jp.add(jtf);
jp.add(jb);
this.add(jsp,"Center");
this.add(jp,"South");
this.setSize(300,300);
this.setLocationRelativeTo(this);
this.setTitle("服务器端");
this.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
this.setVisible(true);
try{
ServerSocket ss=new ServerSocket(9999);
s=ss.accept();
isr=new InputStreamReader(s.getInputStream());
br=new BufferedReader(isr);
pw=new PrintWriter(s.getOutputStream(),true);
while(true){
String info=br.readLine();
jta.append("客户端对服务器说： "+info+"\r\n");
// this.jta.setText(jtatext);
}
}catch(Exception e){
e.printStackTrace();
}
}
@Override
public void actionPerformed(ActionEvent e) {
if(e.getSource()==jb){
try {
pw.println(jtf.getText());
jta.append("服务器对客户端说： "+jtf.getText()+"\r\n");
// jta.setText(jtatext);
jtf.setText("");
} catch (Exception e1) {
// TODO Auto-generated catch block
e1.printStackTrace();
}
}
}
@Override
public void keyTyped(KeyEvent e) {}
@Override
public void keyPressed(KeyEvent e) {
if(e.getKeyCode()==KeyEvent.VK_ENTER){
try {
pw.println(jtf.getText());
jta.append("服务器对客户端说： "+jtf.getText()+"\r\n");
jtf.setText("");
} catch (Exception e1) {
e1.printStackTrace();
}
}
}
@Override
public void keyReleased(KeyEvent e) {}
}
客户端代码：
package com.test3;
import java.net.*;
import java.io.*;
import javax.swing.*;
import java.awt.*;
import java.awt.event.*;
public class Client2 extends JFrame implements ActionListener ,KeyListener {
JTextArea jta=null;
JScrollPane jsp=null;
JTextField jtf=null;
JButton jb=null;
JPanel jp=null;
String jtatext="";
Socket s;
PrintWriter pw=null;
InputStreamReader isr=null;
BufferedReader br=null;
public static void main(String[] args) {
// TODO Auto-generated method stub
Client2 sv2=new Client2();
}
public Client2(){
jta=new JTextArea();
jta.setEditable(false);
jsp=new JScrollPane(jta);
jtf=new JTextField(10);
jtf.addKeyListener(this);
jb=new JButton("发送");
jb.addActionListener(this);
jp=new JPanel();
jp.add(jtf);
jp.add(jb);
this.add(jsp,"Center");
this.add(jp,"South");
this.setSize(300,300);
this.setLocationRelativeTo(this);
this.setTitle("客户端");
this.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
this.setVisible(true);
try {
s=new Socket("127.3.3.3",9999);
isr=new InputStreamReader(s.getInputStream());
br=new BufferedReader(isr);
pw=new PrintWriter(s.getOutputStream(),true);
while(true){
String info=br.readLine();
jta.append("服务器对客户端说： "+info+"\r\n");
}
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
@Override
public void actionPerformed(ActionEvent e) {
if(e.getSource()==jb){
try {
pw.println(this.jtf.getText());
jta.append("客户端对服务器说： "+jtf.getText()+"\r\n");
jtf.setText("");
} catch (Exception e1) {
// TODO Auto-generated catch block
e1.printStackTrace();
}
}
}
public void keyTyped(KeyEvent e) {}
public void keyPressed(KeyEvent e) {
if(e.getKeyCode()==KeyEvent.VK_ENTER){
try {
pw.println(this.jtf.getText());
jta.append("客户端对服务器说： "+jtf.getText()+"\r\n");
jtf.setText("");
} catch (Exception e1) {
// TODO Auto-generated catch block
e1.printStackTrace();
}
}
}
public void keyReleased(KeyEvent e) {}
}
package service_client_for_many;
import java.awt.BorderLayout;
import java.awt.Font;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Vector;
import javax.swing.JButton;
import javax.swing.JFrame;
import javax.swing.JPanel;
import javax.swing.JScrollPane;
import javax.swing.JTextArea;
import javax.swing.JTextField;
/**
* 双工服务器,多人 本服务器默认不提供服务,而是在客户端连接时创建独立线程负责业务
**/
public class MutilServer implements ActionListener {
private JFrame frame;
/** 边界布局的主面板 */
private JPanel panelMain;
private JPanel panelDown;
private JTextArea ta;
private JTextField txt;
private JButton but;
private JScrollPane jsp;
private Font font;
/**
* 当前服务器使用端口
*/
private int port = 6666;
/**
* 远程客户端的IP
*/
private String clientIp;
/**
* 记录所有正在工作的服务员的登记表
*/
private VectorWaiter dengJiBiao;
public MutilServer() {
frame = new JFrame("双工多人服务器");
panelMain = new JPanel(new BorderLayout());
panelDown = new JPanel();
ta = new JTextArea();
txt = new JTextField(20);
but = new JButton("发送");
jsp = new JScrollPane(ta);
// 粘贴界面
panelDown.add(txt);
panelDown.add(but);
panelMain.add(jsp, BorderLayout.CENTER);
panelMain.add(panelDown, BorderLayout.SOUTH);
// 字体
font = new Font("宋体", Font.BOLD, 18);
txt.setFont(font);
ta.setFont(font);
but.setFont(font);
// 文本域只读
ta.setEditable(false);
// 按钮添加监听
but.addActionListener(this);
frame.add(panelMain);
frame.setBounds(100, 300, 400, 400);
frame.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);// 关闭窗体时结束程序
frame.setAlwaysOnTop(true);// 永远在所有窗体最上
frame.setVisible(true);
// 创建登记表
dengJiBiao = new VectorWaiter();
// 光标给消息文本框
txt.requestFocus();
createServer();
}
/**
* 显示文本到文本域,并且追加一个换行
*
* @param msg
* 要显示的文本
*/
public void showTxt(String msg) {
ta.append(msg + "\n");
}
public static void main(String[] args) {
new MutilServer();
}
// 动作监听
public void actionPerformed(ActionEvent e) {
if (e.getSource() == but) {// 发送
txt.requestFocus();
String str = txt.getText().trim();
if(str.length()==0){
showTxt("不可以发送空消息");
return;
}
if(dengJiBiao.size()==0){
showTxt("当前木有客户连接,无法发送信息");
return;
}
str ="服务器消息:"+str;
//找到所有登记表中的服务员,实现群发
for (int i = 0; i dengJiBiao.size(); i++) {
Waiter w = dengJiBiao.get(i);//得到当前循环的服务员
w.send(str);
}
// 清空文本框,得到焦点
txt.setText("");
}
}
/**
* 启动网络服务器
*/
public void createServer() {
showTxt("正在启动服务器,使用本机" + port + "端口...");
try {
ServerSocket server = new ServerSocket(port);
showTxt("服务器启动成功,开始监听网络连接...");
while (true) {
Socket jiaoYi = server.accept();
// 每得到一个交易,就是来了一个客户端.需要交给一个新的服务员去维护处理
new Waiter(jiaoYi, dengJiBiao, this);
}
} catch (IOException e) {
showTxt("服务器启动失败,可能端口被占用");
}
}
}
package service_client_for_many;
import java.awt.BorderLayout;
import java.awt.Font;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.Socket;
import java.net.UnknownHostException;
import javax.swing.JButton;
import javax.swing.JFrame;
import javax.swing.JPanel;
import javax.swing.JScrollPane;
import javax.swing.JTextArea;
import javax.swing.JTextField;
/** 客户端双工 */
public class MyClient implements ActionListener{
private JFrame frame;
/** 边界布局的主面板 */
private JPanel panelMain;
private JPanel panelDown;
private JTextArea ta;
private JTextField txt;
private JButton but;
private JScrollPane jsp;
private Font font;
/**
* 服务器IP
*/
private String ip = "192.168.10.239";
/**
* 服务器端口
*/
private int port = 6666;
private BufferedReader br;
private BufferedWriter bw;
public MyClient() {
frame = new JFrame("双工客户端1");
panelMain = new JPanel(new BorderLayout());
panelDown = new JPanel();
ta = new JTextArea();
txt = new JTextField(20);
but = new JButton("发送");
jsp = new JScrollPane(ta);
// 粘贴界面
panelDown.add(txt);
panelDown.add(but);
panelMain.add(jsp, BorderLayout.CENTER);
panelMain.add(panelDown, BorderLayout.SOUTH);
// 字体
font = new Font("宋体", Font.BOLD, 18);
txt.setFont(font);
ta.setFont(font);
but.setFont(font);
// 文本域只读
ta.setEditable(false);
//按钮添加监听
but.addActionListener(this);
frame.add(panelMain);
frame.setBounds(500, 200, 400, 400);
frame.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);// 关闭窗体时结束程序
frame.setAlwaysOnTop(true);// 永远在所有窗体最上
frame.setVisible(true);
// 光标给消息文本框
txt.requestFocus();
linkServer();
}
/** 显示文本到文本域,并且追加一个换行
* @param msg 要显示的文本
*/
public void showTxt(String msg) {
ta.append(msg+"\n");
}
public static void main(String[] args) {
new MyClient();
}
//动作监听
public void actionPerformed(ActionEvent e) {
if (e.getSource() == but) {// 发送
if (bw == null) {
showTxt("当前没有客户端连接,无法发送消息");
return;
}
String s = txt.getText().trim();// 得到文本框要发送的文字,去掉两端空格
if (s.length() == 0) {
showTxt("不可以发送空消息");
return;
}
showTxt("我说:" + s);
try {
bw.write(s + "\n");// 发送网络消息给对方
bw.flush();// 清空缓冲
} catch (IOException e1) {
showTxt("信息:" + s + " 发送失败");
}
// 清空文本框,得到焦点
txt.setText("");
txt.requestFocus();
}
}
/**
* 连接服务器
*/
public void linkServer(){
showTxt("准备连接服务器"+ip+":"+port);
try {
Socket jiaoYi = new Socket(ip,port);
showTxt("连接服务器成功,开始进行通讯");
// 得到输入和输出
br = new BufferedReader(new InputStreamReader(
jiaoYi.getInputStream()));
bw = new BufferedWriter(new OutputStreamWriter(
jiaoYi.getOutputStream()));
String s = null;
while ((s = br.readLine()) != null) {
showTxt( s);
}
} catch (UnknownHostException e) {
showTxt("连接服务器失败,网络连通错误");
} catch (IOException e) {
showTxt("与服务器通讯失败,已经断开连接");
}
showTxt("关闭");
}
}
package service_client_for_many;
import java.awt.BorderLayout;
import java.awt.Font;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.Socket;
import java.net.UnknownHostException;
import javax.swing.JButton;
import javax.swing.JFrame;
import javax.swing.JPanel;
import javax.swing.JScrollPane;
import javax.swing.JTextArea;
import javax.swing.JTextField;
/** 客户端双工 */
public class MyClient2 implements ActionListener{
private JFrame frame;
/** 边界布局的主面板 */
private JPanel panelMain;
private JPanel panelDown;
private JTextArea ta;
private JTextField txt;
private JButton but;
private JScrollPane jsp;
private Font font;
/**
* 服务器IP
*/
private String ip = "192.168.10.239";
/**
* 服务器端口
*/
private int port = 6666;
private BufferedReader br;
private BufferedWriter bw;
public MyClient2() {
frame = new JFrame("双工客户端2");
panelMain = new JPanel(new BorderLayout());
panelDown = new JPanel();
ta = new JTextArea();
txt = new JTextField(20);
but = new JButton("发送");
jsp = new JScrollPane(ta);
// 粘贴界面
panelDown.add(txt);
panelDown.add(but);
panelMain.add(jsp, BorderLayout.CENTER);
panelMain.add(panelDown, BorderLayout.SOUTH);
// 字体
font = new Font("宋体", Font.BOLD, 18);
txt.setFont(font);
ta.setFont(font);
but.setFont(font);
// 文本域只读
ta.setEditable(false);
//按钮添加监听
but.addActionListener(this);
frame.add(panelMain);
frame.setBounds(900, 200, 400, 400);
frame.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);// 关闭窗体时结束程序
frame.setAlwaysOnTop(true);// 永远在所有窗体最上
frame.setVisible(true);
// 光标给消息文本框
txt.requestFocus();
linkServer();
}
/** 显示文本到文本域,并且追加一个换行
* @param msg 要显示的文本
*/
public void showTxt(String msg) {
ta.append(msg+"\n");
}
public static void main(String[] args) {
new MyClient2();
}
//动作监听
public void actionPerformed(ActionEvent e) {
if (e.getSource() == but) {// 发送
if (bw == null) {
showTxt("当前没有客户端连接,无法发送消息");
return;
}
String s = txt.getText().trim();// 得到文本框要发送的文字,去掉两端空格
if (s.length() == 0) {
showTxt("不可以发送空消息");
return;
}
showTxt("我说:" + s);
try {
bw.write(s + "\n");// 发送网络消息给对方
bw.flush();// 清空缓冲
} catch (IOException e1) {
showTxt("信息:" + s + " 发送失败");
}
// 清空文本框,得到焦点
txt.setText("");
txt.requestFocus();
}
}
/**
* 连接服务器
*/
public void linkServer(){
showTxt("准备连接服务器"+ip+":"+port);
try {
Socket jiaoYi = new Socket(ip,port);
showTxt("连接服务器成功,开始进行通讯");
// 得到输入和输出
br = new BufferedReader(new InputStreamReader(
jiaoYi.getInputStream()));
bw = new BufferedWriter(new OutputStreamWriter(
jiaoYi.getOutputStream()));
String s = null;
while ((s = br.readLine()) != null) {
showTxt(s);
}
} catch (UnknownHostException e) {
showTxt("连接服务器失败,网络连通错误");
} catch (IOException e) {
showTxt("与服务器通讯失败,已经断开连接");
}
showTxt("关闭");
}
}
package service_client_for_many;
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.Socket;
import java.util.Vector;
/**
* 服务员,线程类
* 在客户端连接后创建启动
* 负责当前客户端的所有数据收发
* 并且在业务需要时,将结果与服务器(老板)进行报告
*/
public class Waiter extends Thread{
private Socket sc;
private VectorWaiter dengJiBiao ;
private MutilServer server;
/**
* 客户端IP
*/
private String ip;
private BufferedReader br;
private BufferedWriter bw;
/** 创建一个的新的服务员,负责当前传递的客户端连接(交易)
* 启动新线程
* @param sc 负责的交易
* @param dengJiBiao所有正在工作的服务员(所有交易)
* @param server 老板,也就是服务器
*/
public Waiter(Socket sc, VectorWaiter dengJiBiao,
MutilServer server) {
this.sc = sc;
this.dengJiBiao = dengJiBiao;
this.server = server;
//初始化连接的准备工作
ip = sc.getInetAddress().getHostAddress();
// 得到输入和输出
try {
br = new BufferedReader(new InputStreamReader(
sc.getInputStream()));
bw = new BufferedWriter(new OutputStreamWriter(
sc.getOutputStream()));
} catch (IOException e) {
this.server.showTxt("与客户端:"+ip+"建立通讯失败");
e.printStackTrace();
return;//无效客户,不再继续
}
this.server.showTxt("客户端:"+ip+"连接服务器成功");
//启动线程
this.start();
}
//线程
public void run(){
//开始时,登记开工
dengJiBiao.addElement(this);
System.out.println(this.getClass().getName());
try {
String s = null;
while ((s = br.readLine()) != null) {
server.showTxt("客户"+ip+"说:" + s);
//当前客户发来的信息,其它客户也要能看得见.需要实现转发
//从登记表找到所有正在干活的服务员
for (int i = 0; i dengJiBiao.size(); i++) {
Waiter w = dengJiBiao.get(i);
//排除掉当前服务员自己
if(w!=this)
w.send("客户"+ip+"说:" + s);
}
}
} catch (Exception e) {
server.showTxt("客户"+ip+"已经离开");
}
//结束时,登记下班
dengJiBiao.removeElement(this);
}
/** 发送信息给当前服务员负责的客户端
* @param msg
*/
public void send(String msg){
try {
bw.write(msg+"\n");
bw.flush();
} catch (Exception e) {
server.showTxt("给客户:"+ip+"发送信息"+msg+"失败");
}
}
}
一个服务器类·两个客户端类，一个线程类负责收发
20分！！！？？(⊙o⊙)
给你这个做参考吧。自己改一下就行了。（共两个文件）
//ChatClient.java
import java.awt.*;
import java.awt.event.*;
import java.io.*;
import java.net.*;
public class ChatClient extends Frame {
Socket s = null;
DataOutputStream dos = null;
DataInputStream dis = null;
private boolean bConnected = false;
TextField tfTxt = new TextField();
TextArea taContent = new TextArea();
Thread tRecv = new Thread(new RecvThread());
public static void main(String[] args) {
new ChatClient().launchFrame();
}
public void launchFrame() {
setLocation(400, 300);
this.setSize(300, 300);
add(tfTxt, BorderLayout.SOUTH);
add(taContent, BorderLayout.NORTH);
pack();
this.addWindowListener(new WindowAdapter() {
@Override
public void windowClosing(WindowEvent arg0) {
disconnect();
System.exit(0);
}
});
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();
}
/*
try {
bConnected = false;
tRecv.join();
} catch(InterruptedException e) {
e.printStackTrace();
} finally {
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();
//taContent.setText(str);
tfTxt.setText("");
try {
//System.out.println(s);
dos.writeUTF(str);
dos.flush();
//dos.close();
} catch (IOException e1) {
e1.printStackTrace();
}
}
}
private class RecvThread implements Runnable {
public void run() {
try {
while(bConnected) {
String str = dis.readUTF();
//System.out.println(str);
taContent.setText(taContent.getText() + str + '\n');
}
} catch (SocketException e) {
System.out.println("退出了，bye!");
} catch (EOFException e) {
System.out.println("推出了，bye - bye!");
} catch (IOException e) {
e.printStackTrace();
}
}
}
}
//ChatServer.java
import java.io.*;
import java.net.*;
import java.util.*;
public class ChatServer {
boolean started = false;
ServerSocket ss = null;
ListClient clients = new ArrayListClient();
public static void main(String[] args) {
new ChatServer().start();
}
public void start() {
try {
ss = new ServerSocket(8888);
started = true;
} catch (BindException e) {
System.out.println("端口使用中....");
System.out.println("请关掉相关程序并重新运行服务器！");
System.exit(0);
} catch (IOException e) {
e.printStackTrace();
}
try {
while(started) {
Socket s = ss.accept();
Client c = new Client(s);
System.out.println("a client connected!");
new Thread(c).start();
clients.add(c);
//dis.close();
}
} catch (IOException e) {
e.printStackTrace();
} finally {
try {
ss.close();
} catch (IOException e) {
// TODO Auto-generated catch block
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);
System.out.println("对方退出了！我从List里面去掉了！");
//e.printStackTrace();
}
}
public void run() {
try {
while(bConnected) {
String str = dis.readUTF();
System.out.println(str);
for(int i=0; iclients.size(); i++) {
Client c = clients.get(i);
c.send(str);
//System.out.println(" a string send !");
}
/*
for(IteratorClient it = clients.iterator(); it.hasNext(); ) {
Client c = it.next();
c.send(str);
}
*/
/*
IteratorClient it = clients.iterator();
while(it.hasNext()) {
Client c = it.next();
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();
//s = null;
}
} catch (IOException e1) {
e1.printStackTrace();
}
}
}
}
}
网易云信致力于互联网络技术的开发与研究，使开发者通过简单集成客户端SDK和云端开放API，快速实现强大的移动互联网IM和音视频功能。在场景化方面，深入各行各业，狠抓痛点，第一时间包装相应的场景方案，助力企业解决行业难题。同时，网易云信...
2020-03-09 回答者：网易(杭州)网络有... 10
如何编写一个即时通讯软件
答：可以用bmob做后端，有即时通讯的demo 昨天下班前发布了最新的Bmob_IM_V1.1.2版本的SDK和应用Demo，还未正式通知大家，但还是有人察觉到了，那么，这一次版本更新了什么呢？ 主要是针对大家都比较关心的问题进行了集中解决。 一、更新功能： 1、...
2016-12-21 回答者: C900612 2个回答 1
如何搭建一个自己的IM即时通讯聊天软件？
问：如何搭建一个自己的IM即时通讯聊天软件？
答：搭建一个自己的IM即时通讯聊天软件的框架如下：1、CIM 中的各个组件均采用 Spring Boot 构建。2、采用 Netty + Google Protocol Buffer 构建底层通信。3、Redis 存放各个客户端的路由信息、账号信息、在线状态等。4、Zookeeper 用于 IM-server ...
2018-09-03 回答者: 容联云 5个回答 1
怎么用Java写一个即时通讯软件？
答：我看到过一个，链接给你，用websocket的 里面有个example就是im的
2013-05-24 回答者: micoud_10 4个回答 1
写一个简单的即时通讯软件需要掌握哪些基础的网络知识
答：掌握TCP/UDP网络协议，还要知道Socket知识，会java或者C#或者C语言的编程，这样就可以通过语言来实现网络的通讯。建议看看Openfire，采用的协议是XMPP。
2017-02-16 回答者: 天123456941 1个回答
请问可以用哪些语言编写即时通讯软件？
问：并请说明那种语言最好
答：当然要用JAVA和C++等多程序开发. 你可以看这家企业即时通讯软件
2007-03-14 回答者: 13813857798 3个回答
我要用java写一个简单的即时通讯软件，该怎么写。...
问：我们打算先用http实现信息收发，有人会做吗。有demo的话求发我感谢。
答：你是说电脑端手机端都要开发吗，电脑端一般用socket, Android端用XMPP5通信
2015-03-10 回答者: 沦落人1992 1个回答
自己写的小型的即时通讯软件如何像QQ一样实现聊天...
答：用socket或者serversocket，也可以使用数据包。必须要有这个，就可以在不同的计算机上实现即时通讯，但是，其功能与专业的聊天软件差别比较大
2010-11-08 回答者: 孙7421 3个回答 5
求大神帮写用JAVA编写一个即时通信的软件 有常 谢谢了
问：会的留言 可商量后再写
答：描述得太不够具体，，，，，是单对单、还是可以单对多；要不要分群；要不要图片；等
2020-06-17 回答者: 知道网友 2个回答 1
开发一个即时通讯软件需要什么样的人员?
问：开发一个即时通讯软件需要什么样的人员?比如说需要几个程序员,多少平面...
答：要看规模，不知道你要做多大的 架构师 起码1个，如果大的话要两个 数据库设计 人员 美工1-2个 程序员依大小而定，小的话3，4个 大的话就每准了 如果作为产品的话，时间将会很长，自己玩，自己用的话，就很快了
重庆分公司
重庆分公司
