基于Java网络编程和多线程的多对多聊天系统
更新时间：2021年04月19日 09:44:18 作者：Dev-Flow
这篇文章主要介绍了基于Java网络编程和多线程的多对多聊天系统,文中有非常详细的代码示例,对正在学习java网络编程的小伙伴们有非常好的帮助,需要的朋友可以参考下
1.前言
程序实现基于星型结构（服务器接收来自各个客户端发送的信息，然后将信息传递给其他客户端界面并在其他客户端界面显示发送的信息）
2.类图
3.代码
客户端代码：
package netProgram;
import java.io.IOException;
import java.net.Socket;
import java.net.SocketAddress;
public class Client implements ScreenInputInterface{
private SocketHandler socketHandler;
public void start(){
new Thread(new ScreenInputRunIns(this)).start();
try {
socketHandler = new SocketHandler(new Socket("127.0.0.1",666),null);
new Thread(socketHandler).start();
} catch (IOException e) {
e.printStackTrace();
}
}
@Override
public void send(String msg) {
socketHandler.sendMsg(msg);
}
/* @Override
public void send(String msg, SocketAddress address) {
socketHandler.sendMsg(msg);
}*/
}
服务端代码：
package netProgram;
import java.io.IOException;
import java.net.ServerSocket;
import java.net.SocketAddress;
import java.util.ArrayList;
import java.util.List;
public class Server implements ScreenInputInterface{
private List<SocketHandler> clients = new ArrayList<>();
private ServerSocket serverSocket;
public void start(){
// new Thread(new ScreenInputRunIns(this)).start();
try {
serverSocket = new ServerSocket(666);
while (true){
SocketHandler socketHandler = new SocketHandler(serverSocket.accept(),this);
clients.add(socketHandler);
System.out.println(socketHandler.getSocket().getRemoteSocketAddress()+"进入聊天系统");
new Thread(socketHandler).start();
}
} catch (IOException e) {
e.printStackTrace();
}
}
@Override
public void send(String msg) {
for (SocketHandler s:clients) {
s.sendMsg(msg);
}
}
/* @Override
public void send(String msg, SocketAddress address) {
for (SocketHandler s:clients) {
if (s.getSocket().getRemoteSocketAddress().equals(address)){
continue;
}
s.sendMsg(msg);
}
}*/
public static void main(String[] args) {
new Server().start();
}
}
屏幕输入信息接口：
package netProgram;
import java.net.SocketAddress;
public interface ScreenInputInterface {
void send(String msg);
// void send(String msg, SocketAddress address);
}
用于各个端口输入信息的创建的线程对象：
package netProgram;
import java.util.Scanner;
public class ScreenInputRunIns implements Runnable{
private ScreenInputInterface screenInputInterface;
private Scanner input = new Scanner(System.in);
public ScreenInputRunIns(ScreenInputInterface screenInputInterface) {
this.screenInputInterface = screenInputInterface;
}
@Override
public void run() {//屏幕实时输入
while (true){
String msg = input.nextLine();
// screenInputInterface.send(msg,null);
screenInputInterface.send(msg);
}
}
}
套接字处理器（用于传输数据：实际发送信息到输出流并实时监听各个端口的输入且负责显示）：
package netProgram;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;
public class SocketHandler implements Runnable{
private String clientName;
private Socket socket;
private PrintWriter writer;
private Server server;
public SocketHandler(Socket socket,Server server) throws IOException {
this.socket = socket;
this.server = server;
clientName = "<"+socket.getLocalSocketAddress()+">";
writer = new PrintWriter(this.socket.getOutputStream());
}
public Socket getSocket() {
return socket;
}
public void sendMsg(String msg){
if (server!=null) writer.println(msg);
else writer.println(clientName+":"+msg);
writer.flush();
}
@Override
public void run() {
while(true){//监听输入流的输入
try {
BufferedReader reader = new BufferedReader(new InputStreamReader(socket.getInputStream()));
String receiveMsg = null;
System.out.println();
if ((receiveMsg = reader.readLine())!=null&&!(receiveMsg.equals(""))){
if (server!=null){
// server.send(receiveMsg,socket.getRemoteSocketAddress());
server.send(receiveMsg);
}else {
System.out.println(receiveMsg);
}
}
} catch (IOException e) {
e.printStackTrace();
}
}
}
}
负责启动的各个端口的客户端代码：
package netProgram;
public class ClientLinked {
public static void main(String[] args) {
new Client().start();
}
}
package netProgram;
public class ClientLinked1 {
public static void main(String[] args) {
new Client().start();
}
}
package netProgram;
public class ClientLinked2 {
public static void main(String[] args) {
new Client().start();
}
}
服务端启动代码在服务端类的main方法中。
到此这篇关于基于Java网络编程和多线程的多对多聊天系统的文章就介绍到这了,更多相关java实现多对多聊天系统内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！
相关文章
随着项目的不断演进和业务需求的增长,很多场景下需要实现系统的动态性和灵活性,本文主要介绍了Spring Boot动态加载Jar包与动态配置实现,具有一定的参考价值,感兴趣的可以了解一下2024-02-02
在 JetBrains Mono 的设计阶段，它就充分考虑到了长时间工作可能导致的眼睛疲劳问题，比如字母的大小和形状、空间量、自然等宽平衡、不必要的细节、连字、以及难以区分的符号等，从而最终设计出了这么一款字体2021-06-06
解决BeanUtils.copyProperties不支持复制集合的问题
这篇文章主要介绍了解决BeanUtils.copyProperties不支持复制集合的问题，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教2021-06-06
这篇文章主要给大家介绍了Spring IOC基于注解启动的相关资料，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面来一起学习学习吧2023-02-02
这篇文章主要介绍了Java并发编程之原子性-Atomic的使用方式，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教2022-03-03
这篇文章主要介绍了Java8 forEach常用场景代码实例,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下2020-09-09
使用springboot单元测试对weblistener的加载测试
这篇文章主要介绍了使用springboot单元测试对weblistener的加载测试，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教2021-10-10
Java matches类，Pattern类及matcher类用法示例
这篇文章主要介绍了Java matches类，Pattern类及matcher类用法,结合实例形式分析了java matches类，Pattern类及matcher类针对字符串常见操作技巧与相关注意事项,需要的朋友可以参考下2019-03-03
这篇文章主要为大家详细介绍了java局域网聊天小程序，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2019-01-01
JVM(Java虚拟机)一种用于计算设备的规范，可用不同的方式（软件或硬件）加以实现。接下来通过本文给大家简单介绍Java JVM虚拟机运行机制，感兴趣的朋友一起看看吧2017-03-03
最新评论