java实现小型局域网群聊功能(C/S模式)

时间:2021-05-19

本文实例为大家分享了java群聊功能,供大家参考,具体内容如下

Java 对TCP协议的支持:
--> java.net包中定义了两个类ServerSocket 和Socket ,分别用来实现双向连接的server 端和client 端。
--> Client 类定义客户端

package com.dragon.java.tcpchat;import java.io.IOException;import java.net.Socket;import java.net.UnknownHostException;/** * 客户端 * * @author Auser * */public class Client { public static void main(String args[]) throws UnknownHostException, IOException { Socket client = new Socket("192.168.1.188", 10000); // 穿件发送信息的线程 new ClientSend(client).start(); // 创建接收信息的线程 new ClientReceive(client).start();     // 因为要实现聊天功能,而不是只发送一次信息,所以输出流和客户端都不能关闭。 // client.shutdownOutput(); // client.close(); }}

--> ClientSend 类 定义客户端向服务端发送信息的线程

package com.dragon.java.tcpchat;import java.io.IOException;import java.io.PrintStream;import java.net.Socket;import java.util.Scanner;/** * 客户端向服务端发送信息的线程 * * @author Auser * */public class ClientSend extends Thread { private Scanner scanner; private Socket socket; public ClientSend(Socket socket) { this.socket = socket; } @Override public void run() { scanner = new Scanner(System.in); try { PrintStream ps = new PrintStream(socket.getOutputStream()); String line = ""; // 阻塞式发送信息 while ((line = scanner.nextLine()) != null) { ps.println(line); } } catch (IOException e) { e.printStackTrace(); } }}

--> ClientReceive 类 定义客户端接收服务端信息的线程

package com.dragon.java.tcpchat;import java.io.BufferedReader;import java.io.InputStreamReader;import java.net.Socket;/** * 客户端接收信息的线程 * * @author Auser * */public class ClientReceive extends Thread { private Socket socket; public ClientReceive(Socket socket) { this.socket = socket; } @Override public void run() { try { BufferedReader br = new BufferedReader(new InputStreamReader( socket.getInputStream())); // 按行接收信息 String line = ""; while ((line = br.readLine()) != null) { System.out.println(line); } } catch (Exception e) { e.printStackTrace(); } }}

--> Server 类定义服务端

package com.dragon.java.tcpchat;import java.io.IOException;import java.net.ServerSocket;import java.net.Socket;import java.util.ArrayList;import java.util.List;/** * 服务器 * * @author Auser * */public class Server { public static void main(String[] args) throws IOException, InterruptedException { List<Socket> list = new ArrayList<>(); // 创建服务器端的套接字 ServerSocket server = new ServerSocket(10000); while (true) { // 接收客户端的阻塞方法 Socket socket = server.accept(); // 设计到多个线程可能会对集合进行增删的操作,要进行同步的处理 synchronized (list) { list.add(socket); } // 启动一个新的线程去处理这个客户端的交流 new HandleSocket(socket, list).start(); }     // 因为不知道客户端什么时候发送信息,所以服务端要一直开启不能关闭。 }}

--> HandleSocket 类对连接到服务端的客户端进行操作(上下线通知、屏蔽拉黑、将信息发送到每个客户端等...)

package com.dragon.java.tcpchat;import java.io.BufferedReader;import java.io.IOException;import java.io.InputStreamReader;import java.io.PrintStream;import java.net.InetAddress;import java.net.Socket;import java.util.List;/** * 处理每个(单个)连接到服务器的客户端的线程 * * @author Auser * */public class HandleSocket extends Thread { private Socket socket; private List<Socket> list; /** * 构造方法 * * @param socket * 当前连接的客户端 * @param list * 存储已连接客户端的集合 */ public HandleSocket(Socket socket, List<Socket> list) { this.socket = socket; this.list = list; } /** * 线程run方法 */ @Override public void run() { InetAddress address = socket.getInetAddress(); // 获取连接到服务器的这的客户端的地址 String ip = address.getHostAddress(); System.out.println(ip + "上线了!"); if (ip.equals("192.168.1.117")) { synchronized (list) { sendToAll(ip + "由于违规操作,已被拉入黑名单!"); list.remove(socket); } return; } try { BufferedReader br = new BufferedReader(new InputStreamReader( socket.getInputStream(), "gbk")); String line = ""; while ((line = br.readLine()) != null) { String msg = ip + ":" + line; System.out.println(msg); // 输出到服务器端的控制台 // 把这个客户端说的话,发给其他所有的客户端 sendToAll(msg); } } catch (IOException e) { // e.printStackTrace(); System.out.println(ip + "下线了!"); synchronized (list) { list.remove(socket); } } } /** * 把信息发送给所有的客户端,去除当前socket * * @param msg * 发送的信息 */ private void sendToAll(String msg) { synchronized (list) { for (Socket s : list) { if (s != socket) { try { PrintStream ps = new PrintStream(s.getOutputStream()); ps.println(); } catch (IOException e) { e.printStackTrace(); } } } } }}

--> 注意:因为要实现客户端连接到服务端,即客户端要先找到服务端,所以服务端要先开启,再开启服务端...

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持。

声明:本页内容来源网络,仅供用户参考;我单位不保证亦不表示资料全面及准确无误,也不保证亦不表示这些资料为最新信息,如因任何原因,本网内容或者用户因倚赖本网内容造成任何损失或损害,我单位将不会负任何法律责任。如涉及版权问题,请提交至online#300.cn邮箱联系删除。

相关文章