java网络通信（聊天室之多人聊天）0603

本文主要是介绍java网络通信（聊天室之多人聊天）0603，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

上一次我们搭建了一个简单的服务机器，并且用telnet命令进行成功通信，今天我们的目标是完成一个虚拟房间，它可以容纳多用户在房间内进行聊天，形式上类似于早期的QQ聊天室（有些年头了，可能大家不太熟悉），即像现在的微信群组，大家进入到群组后可以看到群内成员的发言。
在这里插入图片描述

在这里插入图片描述
（图片内容均来自百度图片，与本人无关，如有侵权，联系必删）

废话不多，开干。

第一步：设计模型

在这里插入图片描述
如model所示，每一个进入服务器的client（Socket）都会创建并且启动一个新的线程，这样每个客户端就不必等待前一个客户端关闭连结之后才能通信。

第二步：编写“线程类”

public class ServerThread extends Thread{private java.net.Socket client ;//线程对象要处理的连接变量private OutputStream out ;//输出流变量private InputStream ins ;//输入流变量//创建线程对象时候，传入一个要处理的连接对象public ServerThread(java.net.Socket client) {this.client = client;try {out = this.client.getOutputStream();ins = this.client.getInputStream();}catch(Exception ef) {ef.printStackTrace();}//将要发送的消息代码 封装到一个方法中，这样每次发送消息时候调用比较方便public void sendmes(String mes) throws Exception{mes+="\r\n";byte[]  data = mes.getBytes();out.write(data);//用输出对象发送out.flush();//强制输出}public void run() {//在线程run中调用处理连接的方法processChat(this.client);//在上一篇中已经提到处理连接的方法//处理方法执行完毕之后，线程自己退出}private void processChat(java.net.Socket client){try {String s = "Welcome to the Clubhouse!"+"\r\n"+"Plese singn your username"+"\r\n";this.sendmes(s);//当客户端连接，线程启动随机向客户端发送消息String username =readString(ins);//定义username为客户端发给服务端的一条消息String b = username+",你已经进入Clubhouse，尽情享受聊天的乐趣吧"+"\r\n";this.sendmes(b);//发送消息，告诉客户的username已经成功登陆System.out.println("世界上最好看的"+username+"已经上线"+"\r\n");//在服务端进行用户上线提示String inputs =readString(ins);//读取客户端发来的消息，并将字while(!inputs.equals("bye")) {tool.sendAll(username+"："+inputs+"\r\n");//将读取到的客户端消息发送给所有连接上的客户端System.out.println(username+"："+inputs+"\r\n");//在服务端记录客户发送的消息inputs= readString(ins);//再次读取}s="相聚有时，后会有期，我们还会再见的！"+"\r\n";this.sendmes(s);//当客户下线时，发送结束语给客户端client.close();//关闭}catch(Exception ef) {ef.printStackTrace();}}//从输入流对象中读取字节，拼成一个字符串返回//如果读到一个字节为13，则认为以前是一个字符串private String readString(InputStream ins)throws Exception{StringBuffer stb =new StringBuffer();//创建一个线程缓冲区，StringBuffer在线程中是安全的char c = 0;while(c!=13) {//如果遇到换行，就说明之前是一句话int i =ins.read();//读取客户端发来的每一个字节c=(char)i;//将输入的字节转为charstb.append(c);//将读到的字节组转为字符串}String inputs  = stb.toString().trim();return inputs;}public void setUpServer(int pork) {try {java.net.ServerSocket server = new java.net.ServerSocket(pork);System.out.println("服务器创建成功"+pork);while(true) {java.net.Socket client = server.accept();ServerThread st = new ServerThread(client);st.start();System.out.println("已经启动了一个线程去处理这个链接对象");}}catch(Exception ef) {ef.printStackTrace();}public void setUpServer(int pork) {try {java.net.ServerSocket server = new java.net.ServerSocket(pork);System.out.println("服务器创建成功"+pork);while(true) {java.net.Socket client = server.accept();ServerThread st = new ServerThread(client);st.start();System.out.println("已经启动了一个线程去处理这个链接对象");}}catch(Exception ef) {ef.printStackTrace();}}

第三步客户端之间能收发消息（实现聊天功能）

其实这一步很简单，只要将读取到的客户消息发送给所有客户就可以。

public class tool {private static java.util.ArrayList<ServerThread> cts=new ArrayList<ServerThread>();//首先创建一个线程数组，用于保存线程对象public static  void addcc(ServerThread ct) throws Exception{//将线程对象保存于数组里cts.add(ct);int u =cts.size()+125; sendAll("Online Number："+u);//这里 创建了个在线人数为125+1，用于当客户机连接上服务器时候即可以接收到 在线人数 的消息。}//把消息发送所有在线的客户端public static void sendAll(String mes) throws Exception{for(int i=0;i<cts.size();i++){ServerThread aaa=cts.get(i);//读取到数组里的所有线程对象（即所有客户）aaa.sendmes(mes);//将消息发送到所有客户机上，以达到客户之间的聊天功能}}}

第三步在服务端中加入创建线程并且启动

public class ChatServer {public void setSercer(int port) {try {ServerSocket server =new ServerSocket(port);//1.创建服务器对象:绑定在一个端口上,定位一个服务System.out.println("1.服务器创建成功");//2.等待连接进入，开机，进入待机状态while(true) {System.out.println("2.等待用户连接");java.net.Socket client = server.accept();//阻塞状态(nioSystem.out.println("3.已有客户连接上");//当客户端连接上服务器，创建并且启动线程对象ServerThread  ab  = new ServerThread(client);ab.start();//启动线程tool.addcc(ab);}}catch(Exception ef) {ef.printStackTrace();}}public static void main (String [] args) {ChatServer ac = new ChatServer();ac.setSercer(9090);}}