java实现c/s客户端间聊天-凯发app官方网站

凯发app官方网站-凯发k8官网下载客户端中心 | | 凯发app官方网站-凯发k8官网下载客户端中心

vibexie

凯发app官方网站首页　| 　　| 　

vibe26

  • 博客访问： 405140
  • 博文数量： 121
  • 博客积分： 0
  • 博客等级： 民兵
  • 技术积分： 1393
  • 用 户 组： 普通用户
  • 注册时间： 2014-03-11 12:17
个人简介

www.vibexie.com vibexie@qq.com

文章分类

（121）

  • （8）
  • （10）
  • （20）
  • （1）
  • （8）
  • （11）
  • （0）
  • （26）
  • （4）
  • （2）
  • （1）
  • （13）
  • （0）
  • （3）
  • （14）
  • （0）
文章存档

（55）

（66）

我的朋友
最近访客
推荐博文
相关博文
  • ·
  • ·
  • ·
  • ·
  • ·
  • ·
  • ·
  • ·
  • ·
  • ·
java实现c/s客户端间聊天

分类： java

2015-03-22 15:33:08

用了一天半的时间，终于还是把客户端聊天的功能实现了，刚开始的时侯，考虑客户端处于内网和外网的因素，肯定不能用udp通过ip地址来传送消息，
不过也可以通过udp打洞的方式来实现穿透nat，qq就是用udp打洞的方式，不过还有先进的方法保证udp的可靠性。但是udp打洞也是很难实现的。
经过半天的思考，还是决定用一种简单的方法实现 客户端-服务器-客户端 的通信，基于socket,在服务端保存一张map，map键值分别为username,socket。
再通过服务器的并发实现客户端间的通信，客户端发送的所有数据都先传到服务器，服务器再把数据解析发送到对应的接收端。

架构是这样的：
    客户端连接服务器，服务端start一个服务线程，用户输入自己的名字，发送给服务器端，服务器将username和当前连接的socket保存到一张hashmap中。
    如果已经有用户使用了该名字，服务器查询map中已经有这个用户吗，有的话通知用户重新输入用户名。
    确定username后，再选择要发送信息的好友，服务器再从map中拿出好友的socket，再把消息转发至好友的socket
    客户端接收方面，启用一个后台进程，去read自己的socket获取消息。
    更重要的是，后台线程和客户端主线程间用一个单向的管道，传送一些必要的信息。
整个架构中都没有忙等待，都是通过阻塞的方式进行数据的传递。所以在性能上是很强的。

由于只是为了实现这个功能，代码写好后就没有改过，代码还是挺粗糙的，经过测试，剩下一个bug就是linux端和windows端进行中文通信的时候就会有乱码，这个就不去处理了。

附源码：
     
给出服务器端代码：

qqserver.java

  1. package cn.com.xiebiao.smallqqserver;

  3. import java.io.ioexception;
  4. import java.net.serversocket;
  5. import java.net.socket;

  7. /**
  8.  *
  9.  * title : qqserver.java 
  10.  * author : vibe xie @
  11.  * time : mar 22, 2015 3:24:07 pm
  12.  * 凯发app官方网站 copyright: 凯发app官方网站 copyright (c) 2015
  13.  * description:
  14.  */

  16. public class qqserver {
  17.     private static serversocket serversocket=null;
  18.     private static socket socket=null;
  19.     //服务器端口
  20.     private static int server_port=8999;
  21.     //服务次数
  22.     private static int server_times=1;
  23.     
  24.     public static void main(string[] args) {
  25.         // todo auto-generated method stub    
  26.         try {
  27.             serversocket=new serversocket(server_port);
  28.             system.out.println("qq服务器启动...");
  29.             while(true){
  30.                 socket=serversocket.accept();
  31.                 system.out.println("服务器第"(server_times)"次连接");
  32.                 new thread(new serverthread(socket)).start();
  33.             }
  34.             
  35.         } catch (ioexception e) {
  36.             // todo auto-generated catch block
  37.             e.printstacktrace();
  38.         }finally{
  39.             try {
  40.                 serversocket.close();
  41.             } catch (ioexception e) {
  42.                 // todo auto-generated catch block
  43.                 e.printstacktrace();
  44.             }
  45.         }

  47.     }
  48. }

serverthread.java

  1. package cn.com.xiebiao.smallqqserver;

  3. import java.io.bufferedinputstream;
  4. import java.io.bufferedreader;
  5. import java.io.bufferedwriter;
  6. import java.io.ioexception;
  7. import java.io.inputstreamreader;
  8. import java.io.outputstreamwriter;
  9. import java.net.socket;
  10. import java.util.iterator;
  11. import java.util.map;
  12. import java.util.set;

  14. /**
  15.  *
  16.  * title : clientthread.java 
  17.  * author : vibe xie @
  18.  * time : mar 21, 2015 2:34:04 pm
  19.  * 凯发app官方网站 copyright: 凯发app官方网站 copyright (c) 2015
  20.  * description: clientthread接收发送端发来的消息，再把消息通过writethead线程发送给接收端
  21.  */
  22. public class serverthread implements runnable {
  23.     private socket socket;
  24.     private boolean flag=true;
  25.     //msg的格式是 "senderreceiver" 正文
  26.     private string msg=null;
  27.     private msganalyseutil msganalyse;
  28.     //将msg拆解为sender,receiver,message
  29.     private string sender;
  30.     private string receiver;
  31.     private string message;
  32.     
  33.     private bufferedreader bufferedreader;
  34.     private bufferedwriter writer;
  35.     public serverthread(socket socket) {
  36.         // todo auto-generated constructor stub
  37.         this.socket=socket;
  38.     }
  39.     
  40.     @override
  41.     public void run() {
  42.         // todo auto-generated method stub
  43.         try {
  44.             
  45.             /******************登录验证模块，用户名已存在，则放回fail,否则返回success************************/
  46.             bufferedreader=new bufferedreader(new inputstreamreader(socket.getinputstream()));
  47.             writer=new bufferedwriter(new outputstreamwriter(socket.getoutputstream()));
  48.             //连接成功则从socket读取用户名
  49.             sender=bufferedreader.readline();
  50.             //用户已存在，返回登录失败信息
  51.             while(usertable.isuserexist(sender)==true){
  52.                 writer.write("fail");
  53.                 writer.newline();
  54.                 writer.flush();
  55.                 sender=bufferedreader.readline();
  56.             }
  57.             
  58.             //将用户名和socket保存到用户表中
  59.             usertable.useradd(sender, socket);
  60.             //收到的用户名不存在，返回登录成功
  61.             writer.write("success");
  62.             writer.newline();
  63.             writer.flush();
  64.             /******************登录验证模块*************************************************************/
  65.             
  66.             while(flag==true){
  67.                 msg=bufferedreader.readline();
  68.                 //进行拆解
  69.                 system.out.println("服务器接收"msg);
  70.                 msganalyse=new msganalyseutil(msg);
  71.                 sender=msganalyse.getsender();
  72.                 receiver=msganalyse.getreceiver();
  73.                 message=msganalyse.getmessage();
  74.                 
  75.                 //接收到验证好友是否在线指令
  76.                 if(sender.equals("/instruction")){
  77.                     //在usertable表中查询好友是否在线，并重新包装消息，返回给请求者
  78.                     if(usertable.isuserexist(receiver)){
  79.                         message="y";
  80.                     }else {
  81.                         message="n";
  82.                     }
  83.                     //包装消息
  84.                     msg=sender"""tmp"message;
  85.                     writer.write(msg);
  86.                     writer.newline();
  87.                     writer.flush();
  88.                 }else{
  89.                     //未接收到指令，进行消息转发
  90.                     //服务器输出消息
  91.                     system.out.println("解析为 发送者:"sender" 接收者:"receiver" 信息:"message);
  92.                     
  93.                     if(message.equals("bye")){
  94.                         system.out.println("用户退出");
  95.                         
  96.                         //退出是通知客户端后台线程结束
  97.                         msg="/instruction""""tmp""bye";
  98.                         writer.write(msg);
  99.                         writer.newline();
  100.                         writer.flush();
  101.                         
  102.                         //从usertable中删除该用户
  103.                         usertable.deleteuser(sender);
  104.                         
  105.                         //结束服务器线程
  106.                         flag=false;
  107.                     }else {
  108.                         //转发消息给接收者
  109.                         writer=new bufferedwriter(new outputstreamwriter(usertable.getsocket(receiver).getoutputstream()));
  110.                         writer.write(msg);
  111.                         writer.newline();
  112.                         writer.flush();
  113.                     }
  114.                 }
  115.             }
  116.         } catch (exception e) {
  117.             // todo: handle exception
  118.             e.printstacktrace();
  119.         }
  120.         
  121.     }
  122. }

usertable.java

  1. package cn.com.xiebiao.smallqqserver;

  3. import java.net.socket;
  4. import java.util.hashmap;
  5. import java.util.map;
  6. /**
  7.  *
  8.  * title : usertable.java 
  9.  * author : vibe xie @
  10.  * time : mar 22, 2015 3:25:35 pm
  11.  * 凯发app官方网站 copyright: 凯发app官方网站 copyright (c) 2015
  12.  * description:
  13.  */
  14. class usertable{
  15.     private static map<string, socket> usertable=new hashmap<string, socket>();
  16.     
  17.     public static void useradd(string user,socket socket){
  18.         usertable.put(user,socket);
  19.     }
  20.     
  21.     public static void deleteuser(string user){
  22.         for(map.entry<string,socket> entry:usertable.returnusertable().entryset()){
  23.             if(entry.getkey().equals(user)){
  24.                 usertable.remove(entry.getkey());
  25.             }
  26.         }
  27.     }
  28.     
  29.     public static boolean isuserexist(string user){
  30.         boolean flag=false;
  31.         for(map.entry<string,socket> entry:usertable.returnusertable().entryset()){
  32.             if(entry.getkey().equals(user)){
  33.                 flag=true;
  34.                 return flag;
  35.             }
  36.         }
  37.         return flag;
  38.     }
  39.     public static map<string , socket> returnusertable(){
  40.         return usertable;
  41.     }
  42.     public static socket getsocket(string user){
  43.         return usertable.get(user);
  44.     }

  46. }


msganalyseutil.java

  1. package cn.com.xiebiao.smallqqserver;

  3. import java.util.regex.pattern;
  4. /**
  5.  *
  6.  * title : msganalyseutil.java 
  7.  * author : vibe xie @
  8.  * time : mar 21, 2015 3:35:16 pm
  9.  * 凯发app官方网站 copyright: 凯发app官方网站 copyright (c) 2015
  10.  * description:分析message的工具类
  11.  */
  12. public class msganalyseutil {
  13.     private string msg;
  14.     private string sender;
  15.     private string receiver;
  16.     private string message;
  17.     string[] tmp=new string[3];
  18.     
  19.     public msganalyseutil(string msg){
  20.         this.msg=msg;
  21.         tmp=pattern.compile("").split(msg,3);
  22.         sender=tmp[0];
  23.         receiver=tmp[1];
  24.         message=tmp[2];
  25.     }
  26.     
  27.     public string getsender() {
  28.         return sender;
  29.     }
  30.     
  31.     public string getreceiver() {
  32.         return receiver;
  33.     }
  34.     
  35.     public string getmessage() {
  36.         return message;
  37.     }
  38. }

客户端代码：

qqclient.java

  1. package cn.com.xiebiao.smallqqclient;

  3. import java.io.bufferedreader;
  4. import java.io.bufferedwriter;
  5. import java.io.ioexception;
  6. import java.io.inputstreamreader;
  7. import java.io.outputstreamwriter;
  8. import java.io.pipedreader;
  9. import java.net.socket;
  10. /**
  11.  *
  12.  * title : qqclient.java 
  13.  * author : vibe xie @
  14.  * time : mar 22, 2015 3:27:29 pm
  15.  * 凯发app官方网站 copyright: 凯发app官方网站 copyright (c) 2015
  16.  * description:
  17.  */
  18. public class qqclient {
  19.     //服务器域名
  20.     private static string domain="localhost";
  21.     //服务器端口
  22.     private static int server_port=8999;
  23.     //socket
  24.     private static socket socket;
  25.     //发送者
  26.     private static string sender;
  27.     //接收者
  28.     private static string recerver;
  29.     //消息
  30.     private static string msg;
  31.     //用户是否想退出
  32.     private static string isloginout="n";
  33.     //接收后台返回好友是否存在指令的管道
  34.     private static pipedreader pipedreader;
  35.     //好友是否在线
  36.     private static boolean isfriendonline=false;
  37.     public static void main(string[] args) {
  38.         // todo auto-generated method stub
  39.         try{
  40.             socket=new socket(domain,server_port);
  41.             
  42.             bufferedreader in=new bufferedreader(new inputstreamreader(system.in));
  43.             bufferedwriter writer=new bufferedwriter(new outputstreamwriter(socket.getoutputstream()));
  44.             //reader仅仅为了用户验证，不用作后台接收消息
  45.             bufferedreader reader=new bufferedreader(new inputstreamreader(socket.getinputstream()));
  46.             boolean flag=true;
  47.             
  48.             system.out.printf("/********************************************\n"
  49.                              "/*************smallqq version1.0*************\n"
  50.                              "/*************@author vibexie *************\n"
  51.                              "/*************@email vibexie@qq.com**********\n"
  52.                              "/********************************************\n");
  53.             /******************登录验证模块，用户名已存在，则放回fail,否则返回success************************/
  54.             //开启客户端，发送用户名
  55.             system.out.print("请输入用户名(临时):");
  56.             sender=msg=in.readline();
  57.             writer.write(msg);
  58.             writer.newline();
  59.             writer.flush();
  60.             while(reader.readline().equals("fail")){
  61.                 system.out.print("用户已存在，请输入用户名(临时):");
  62.                 sender=msg=in.readline();
  63.                 writer.write(msg);
  64.                 writer.newline();
  65.                 writer.flush();
  66.             }
  67.             system.out.println("登录成功,您的用户名为:"sender);
  68.             
  69.             //启动接收消息线程
  70.             new thread(new clientthread(socket)).start();
  71.             //连接管道
  72.             pipedreader=new pipedreader(clientthread.getpipedwriter());
  73.             /******************登录验证模块*************************************************************/
  74.             
  75.             /******************聊天模块************************/
  76.             
  77.             while(isloginout.equals("n")){
  78.                 
  79.                 /************************好友在线验证，在线则开始聊天，否则重新输入好友*****************************************/
  80.                 while(isfriendonline==false){
  81.                     system.out.print("请输入好友:");
  82.                     recerver=in.readline();
  83.                     //规范判断好友在线指令格式
  84.                     string instruction="/instruction"recerver"tmp";
  85.                     //发送指令
  86.                     writer.write(instruction);
  87.                     writer.newline();
  88.                     writer.flush();
  89.                     //通过管道接收后台线程的返回值
  90.                     char[] charreader=new char[1];
  91.                     pipedreader.read(charreader,0,1);
  92.                     
  93.                     msg=new string(charreader);
  94.                     //分解消息
  95.                     if(msg.equals("n")){
  96.                         isfriendonline=false;
  97.                         system.out.println("sorry,好友"recerver"现在不在线，请重新输入好友...");
  98.                     }else {
  99.                         isfriendonline=true;
  100.                     }
  101.                 }
  102.                 
  103.                 system.out.println("与"recerver"连接成功，开始聊天!");
  104.                 /************************好友在线验证，在线则开始聊天，否则重新输入好友*****************************************/
  105.     
  106.                 while(flag){
  107.                     
  108.                     system.out.print("向"recerver"发送消息:");
  109.                     msg=in.readline();
  110.                     
  111.                     if(msg.equalsignorecase("bye") || msg==null){
  112.                         //规范消息格式
  113.                         msg=sender""recerver""msg;
  114.                         writer.write(msg);
  115.                         writer.newline();
  116.                         writer.flush();
  117.                         
  118.                         //判断是否退出
  119.                         system.out.print("结束与"sender"的聊天?(y/n):");
  120.                         isloginout=in.readline();
  121.                         while(isloginout.equals("n")==false && isloginout.equals("y")==false){
  122.                             system.out.printf("您的输入错误，请重新输入\n结束与"sender"的聊天?(y/n):");
  123.                             isloginout=in.readline();
  124.                         }
  125.                         if(isloginout.equals("n")){
  126.                             flag=true;
  127.                         }else {
  128.                             system.out.println("已退出！！！");
  129.                             flag=false;
  130.                         }
  131.                         
  132.                     }else {
  133.                         //规范消息格式
  134.                         msg=sender""recerver""msg;
  135.                         
  136.                         writer.write(msg);
  137.                         writer.newline();
  138.                         writer.flush();
  139.                     }
  140.                 }
  141.             }
  142.             /******************聊天模块************************/
  143.         }catch(exception ex){
  144.             ex.printstacktrace();
  145.         }finally{
  146.             try {
  147.                 socket.close();
  148.                 pipedreader.close();
  149.             } catch (ioexception e) {
  150.                 // todo auto-generated catch block
  151.                 e.printstacktrace();
  152.             }
  153.         }
  154.     }
  155. }

clientthread.java

  1. package cn.com.xiebiao.smallqqclient;

  3. import java.io.bufferedreader;
  4. import java.io.ioexception;
  5. import java.io.inputstreamreader;
  6. import java.io.pipedwriter;
  7. import java.net.socket;

  9. /**
  10.  *
  11.  * title : clientthread.java 
  12.  * author : vibe xie @
  13.  * time : mar 22, 2015 3:28:08 pm
  14.  * 凯发app官方网站 copyright: 凯发app官方网站 copyright (c) 2015
  15.  * description:
  16.  */
  17. public class clientthread implements runnable{
  18.     private socket socket;
  19.     private static string sender;
  20.     private static string msg;
  21.     private static string message;
  22.     private static boolean running=true;
  23.     //通往qqclient的管道
  24.     private static pipedwriter pipedwriter=new pipedwriter();
  25.     public static pipedwriter getpipedwriter() {
  26.         return pipedwriter;
  27.     }
  28.     
  29.     public clientthread(socket socket) {
  30.         // todo auto-generated constructor stub
  31.         this.socket=socket;
  32.     }
  33.     
  34.     @override
  35.     public void run() {
  36.         // todo auto-generated method stub
  37.         try {
  38.             bufferedreader reader=new bufferedreader(new inputstreamreader(socket.getinputstream()));
  39.             while(running){
  40.                 msg=reader.readline();
  41.                 msganalyseutil msganalyseutil=new msganalyseutil(msg);
  42.                 sender=msganalyseutil.getsender();
  43.                 message=msganalyseutil.getmessage();
  44.                 
  45.                 //得到回复用户是否在线的指令，通过管道回写给qqclient
  46.                 if(sender.equals("/instruction")){
  47.                     if(message.equals("bye")){
  48.                         running=false;
  49.                     }else {
  50.                         pipedwriter.write(message);
  51.                     }
  52.                 }else {
  53.                     system.out.printf("\n来自"sender"的信息:"message"\n");
  54.                 }
  55.             }
  56.         } catch (ioexception e) {
  57.             // todo auto-generated catch block
  58.             e.printstacktrace();
  59.         }

  61.     }
  62. }
另外客户端还有一个文件msganalyseutil.java是服务器端是一样的。



阅读(1822) | 评论(0) | 转发(0) |
0

上一篇：

下一篇：

给主人留下些什么吧！~~
| | | | |

凯发app官方网站 copyright 2001-2010 chinaunix.net all rights reserved 北京皓辰网域网络信息技术有限公司. 凯发k8官网下载客户端中心的版权所有

感谢所有关心和支持过chinaunix的朋友们
")); function link(t){ var href= $(t).attr('href'); href ="?url=" encodeuricomponent(location.href); $(t).attr('href',href); //setcookie("returnouturl", location.href, 60, "/"); }
网站地图