厦门市住房和城乡建设局网站首页,沈阳网站建设工作,整合营销网络推广,芜湖县建设局网站群聊实现的关键#xff1a; 群聊的思想#xff1a;客户端发送消息后#xff0c;所有客户端都可以接收到 客户端----服务端#xff08;子#xff09;----客户端#xff08;online#xff09; online的客户端#xff1a;需要一个集合存储
package Wechat;imp…群聊实现的关键 群聊的思想客户端发送消息后所有客户端都可以接收到 客户端----服务端子----客户端online online的客户端需要一个集合存储
package Wechat;import java.io.DataOutputStream;
import java.io.OutputStream;
import java.net.InetAddress;
import java.net.Socket;
import java.util.Scanner;public class Cilent {//1.客户端public static void main(String[] args) throws Exception {
// 1. 创建客户端的Socket对象套接字对象请求与 服务端的连接Socket socket new Socket(InetAddress.getLocalHost(),8888);//127.0.0.1//创建一个独立的线程负责从socket中接收服务器发送过来的消息ClentReaderThread clentReaderThread new ClentReaderThread(socket);clentReaderThread.start();
// 2. 使用socket对象调用getOutputStream()方法得到字节输出流OutputStream os socket.getOutputStream();
// 3. 使用数据输出流其他高级流也行这个最适合完成数据的发送DataOutputStream dos new DataOutputStream(os);//需要实现用户键盘输入什么发送什么输入exit时退出Scanner sc new Scanner(System.in);while (true) {System.out.println(请输入信息);String message sc.nextLine();if(exit.equals(message)){System.out.println(客户端已退出);dos.close();socket.close();//客户端退出关闭所有资源break;}dos.writeUTF(message);dos.flush();dos.writeUTF(客户端发送成功);}}
}
package Wechat;import java.io.DataInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.net.Socket;public class ClentReaderThread extends Thread{//客户端接收读取线程private Socket socket;//每个子线程拿到套接字public ClentReaderThread(Socket socket){this.socket socket;}//负责描述子线程中该套接字的任务Overridepublic void run(){//该套接字负责读取客户端的信息try {InputStream is socket.getInputStream();DataInputStream dis new DataInputStream(is);while (true) {try {String message dis.readUTF();//拿到消息需要把消息分发到每一个客户端包括自己System.out.println(message);System.out.println(-------------------------);} catch (Exception e) {System.out.println(自己下线了 socket.getRemoteSocketAddress());dis.close();socket.close();break;}}} catch (IOException e) {throw new RuntimeException(e);}}
}
package Wechat;import java.net.ServerSocket;
import java.net.Socket;
import java.util.ArrayList;
import java.util.List;public class Server {//定义一个集合存放在线的客户端管道public static ListSocket onlineSockets new ArrayList();//客户端public static void main(String[] args) throws Exception {
// 5. 创建ServerSocket的对象同时为服务端注册端口ServerSocket serverSocket new ServerSocket(8888);while (true) {
// 6. 使用serverSocket对象调用accept方法等待客户端的连接请求得到socket对象Socket socket serverSocket.accept();//拿到套接字onlineSockets.add(socket);//添加上线客户端System.out.println(有用户上线了 socket.getRemoteSocketAddress());new ServerReaderThread(socket).start();//把套接字交给子线程并启动}}
} package Wechat;import java.io.*;
import java.net.Socket;public class ServerReaderThread extends Thread{//服务端读取线程private Socket socket;//每个子线程拿到套接字public ServerReaderThread(Socket socket){this.socket socket;}//负责描述子线程中该套接字的任务Overridepublic void run(){//该套接字负责读取客户端的信息try {InputStream is socket.getInputStream();DataInputStream dis new DataInputStream(is);while (true) {try {String message dis.readUTF();//拿到消息需要把消息分发到每一个客户端包括自己sendMsgToAll(message);System.out.println(message);System.out.println(-------------------------);} catch (IOException e) {System.out.println(有用户下线 socket.getRemoteSocketAddress());Server.onlineSockets.remove(socket);dis.close();socket.close();break;}}} catch (IOException e) {throw new RuntimeException(e);}}private void sendMsgToAll(String message) throws IOException {//发送给所有的在线的socket管道客户端//方向服务端子线程--- socket管道outputstream输出流发送for (Socket onlinesocket : Server.onlineSockets){OutputStream os onlinesocket.getOutputStream();DataOutputStream dos new DataOutputStream(os);dos.writeUTF(message);dos.flush();}}
}
