Java网络编程，模拟QQ群聊功能

一、网络编程知识点简介：

1.C/S架构:Client客户端/Server服务器:

涉及到的应用:桌面的应用软件,QQ,王者荣耀涉及到的技术:Socket网络编程

2.网络:

各个孤立的工作站或主机相连在一起,从而达到资源共享和通信的目的

2.1 网络分为局域网和广域网:

局域网:

在局域网里可以实现数据的共享优点:规模小,容易搭建,传输速度快比如:公司的局域网,学校宿舍里的网络

广域网:

因特网就是世界范围内最大的广域网(WWW)

3.网络协议:

****TCP(Transmis Control Protocol,传输控制协议)—>(面向连接)****UDP(User Datagram Protocol,用户数据报协议)—>(面向非连接)

4.端口和套接字:

端口(port):可以认为是设备与外界通信交流的出口,范围是0-65535之间的整数Java提供了IP地址的封装类InetAddress,它位于java.net包中,主要封装ip地址

二、题目要求：

实现QQ群聊功能：

客户端之间的聊天,本质是客户端发送一条消息后,由服务器转发到另外的所有客户端

三、简述步骤：

1.在服务器TCPServer类中定义List集合用来存放所有连接进来的客户端2.ClientThread的run方法中,当构建好PrintWriter对象后,将对象加入到List集合中3.在接收客户端消息的地方,调用sendMsg方法,将消息发送给除了自己以外的所有的客户端4.完成sendMsg方法

四、代码实现：

1.创建客户端类：

1.1 封装打开客户端的方法

public class TCPClient01 { /* * 封装打开客户端的方法 */ public void open() { try { //创建客户端，并连接服务器 Socket client = new Socket("localhost",9999); System.out.println("连接服务器成功！"); //获取客户端输入流的对象 InputStream is = client.getInputStream(); //创建并启动读取服务器发送消息的线程 new ReadFromServer(is).start(); //获取客户端输出流对象 OutputStream os = client.getOutputStream(); //创建并启动向服务器发送消息的线程 new WriteToServer(os).start(); } catch (Exception e) { e.printStackTrace(); } } public static void main(String[] args) { TCPClient01 client = new TCPClient01(); client.open(); } }

1.2 封装读取服务器发送消息的线程：

class ReadFromServer extends Thread{ //封装服务器发送过来消息的输入流 InputStream is; public ReadFromServer(InputStream is) { this.is = is; } //重写run方法 @Override public void run() { //使用BufferedReader读取服务器的消息 BufferedReader br = new BufferedReader(new InputStreamReader(is)); String line = null; try { //开始读取 while((line=br.readLine())!=null){ System.out.println(line); } //关流 br.close(); } catch (IOException e) { e.printStackTrace(); } } }

1.3 封装客户端向服务器发送消息的线程：

class WriteToServer extends Thread{ OutputStream os; //客户端向服务器发送消息的输出流 public WriteToServer(OutputStream os) { super(); this.os=os; } //重写run方法 @Override public void run() { //创建键盘扫描器 Scanner key = new Scanner(System.in); //写入消息 PrintWriter pw = new PrintWriter(os); while(true) { //接收用户输入的内容 String line = key.nextLine(); //写入 pw.println(line); //强制刷新 pw.flush(); } } }

2.创建服务器类：

2.1创建并启动服务器的方法：

public class TCPServer01 { //以客户端的昵称作为key值，以发送的消息作为value //定义一个变量 Map<String,PrintWriter> allout; /* * 创建并启动服务器的方法 */ public void start() { //初始化变量 allout = new HashMap<String,PrintWriter>(); try { //创建服务器 ServerSocket server = new ServerSocket(9999); System.out.println("服务器启动成功，等待用户接入..."); //创建while循环，保证服务器一直开启并且一直等待客户端连接 while(true) { //调用accept方法 Socket client = server.accept(); //得到连接的客户端的IP地址 System.out.println("有客户接入，客户的IP为："+client.getInetAddress()); //启动线程 new ClientThread(client,allout).start(); } } catch (IOException e) { e.printStackTrace(); } } public static void main(String[] args) { TCPServer01 server = new TCPServer01(); server.start(); } }

2.2 向客户端发送消息，接收客户端发送过来的消息

class ClientThread extends Thread{ //连接到服务器端的客户端 Socket client; Map<String,PrintWriter> allout; public ClientThread(Socket client, Map<String, PrintWriter> allout) { super(); this.client = client; this.allout = allout; } @Override public void run() { try { //向客户端发送数据 //获取输出流对象 OutputStream out = client.getOutputStream(); PrintWriter pw = new PrintWriter(out); //发消息 pw.println("~~~欢迎来到云轩棋牌聊天室~~~~"); pw.println("请先输入您的聊天昵称:"); //强制刷新 pw.flush(); //接收客户端发送的消息 InputStream in = client.getInputStream(); BufferedReader br = new BufferedReader(new InputStreamReader(in)); //获取昵称 String name = br.readLine(); //将客户端输出流对象加入到集合中 allout.put(name, pw); String line = null; while((line=br.readLine())!=null){ //向其他所有的客户端发送消息,pw代表当前自己 sendMsg(name+"说:"+line,pw); } //关流 br.close(); } catch (IOException e) { e.printStackTrace(); } }

2.3 向其他所有的客户端发送消息的方法：

private void sendMsg(String line, PrintWriter pw) { //遍历map集合 Set<String> names = allout.keySet(); for(String name:names){ //根据key获取到对应的value值 PrintWriter p = allout.get(name); if(p != pw){ p.println(line); //刷新 p.flush(); } } } }

五、运行结果展示：

*温馨提示：运行时，首先启动服务器，然后启动客户端哟

结语：技术无他，唯有熟尔。知其然，也知其所以然；不要着急，你想要的，岁月都会给你。