网络编程_手写聊天室

实现功能

多好友间正常聊天，登录退出提示**
如图

此处涉及到之前的容器
点击跳转
只写了一部分以后再更容器

关闭流工具类

package 网络编程_手写聊天室_群聊过渡板;public class MultiClient {public static void main(String[] args) throws UnknownHostException, IOException {BufferedReader str=new BufferedReader(new InputStreamReader(System.in));//获取用户名System.out.println("请输入用户名: ");String name=str.readLine();Socket  client = new Socket("localhost",8888);new Thread(new Sent(client,name)).start();new Thread(new Receive(client)).start();}
}

客户端接收类

package 网络编程_手写聊天室_群聊过渡板;public class Receive implements Runnable{private Socket client;private boolean isRunning;private DataInputStream in;public Receive(Socket client) {this.client=client; try {in=new DataInputStream(client.getInputStream());} catch (IOException e) {System.out.println("接收时出错！");release();}}@Overridepublic void run() {isRunning =true;while(isRunning) {String str="";try {str = in.readUTF();} catch (IOException e) {System.out.println("读取时出错");}if(str!=null) {System.out.println(str);}}this.release();}public  void release() {CloseUtlis utlis =new CloseUtlis();utlis.close(in);isRunning=false;}}

客户端发送类

package 网络编程_手写聊天室_群聊过渡板;public class Sent implements Runnable{private Socket client;private BufferedReader console;private DataOutputStream out;private boolean isRunning;public Sent(Socket client,String name) {this.client=client;console=new BufferedReader(new InputStreamReader(System.in));try {out =new DataOutputStream(client.getOutputStream());sent(name);//将名称发送到服务器} catch (IOException e) {System.out.println("发送数据时出错");}}@Overridepublic void run() {isRunning =true;while(isRunning) {String str="";try {str = console.readLine();} catch (IOException e) {System.out.println("读取时出错");release();}if(str!=null) {sent(str);}    }release();}public void sent(String mess) {try {out.writeUTF(mess);out.flush();} catch (IOException e) {System.out.println("发送时失败！");release();}}public  void release() {CloseUtlis utlis =new CloseUtlis();utlis.close(console,out);isRunning=false;}}

客户端

package 网络编程_手写聊天室_群聊过渡板;public class MultiClient {public static void main(String[] args) throws UnknownHostException, IOException {BufferedReader str=new BufferedReader(new InputStreamReader(System.in));//获取用户名System.out.println("请输入用户名: ");String name=str.readLine();Socket  client = new Socket("localhost",8888);new Thread(new Sent(client,name)).start();new Thread(new Receive(client)).start();}
}

服务器

package 网络编程_手写聊天室_群聊过渡板;public class MultiServer {private static CopyOnWriteArrayList<channel> all =new CopyOnWriteArrayList<MultiServer.channel>();//channel类型的容器public static void main(String[] args) throws IOException {System.out.println("服务器开始工作");ServerSocket server=new ServerSocket(8888);boolean isRunning =true;while(isRunning) {Socket client = server.accept();channel c=new channel(client);all.add(c);//管理每一个成员new Thread(c).start();}}static class channel implements Runnable{//与服务器连接的客户端private String name;private  Socket client;private DataInputStream in;private DataOutputStream out;private int port;private boolean iSsys;//是否为官方消息private boolean isRunning;channel(Socket client) throws IOException{this.client=client;out =new DataOutputStream(new BufferedOutputStream(client.getOutputStream()));in =new DataInputStream(client.getInputStream());String name=receive();this.name=name;sent("欢迎来到聊天室");sentothers(name+"加入了聊天室", true);}@Overridepublic void run() {try {System.out.println("建立了一个连接");while(true) { String mes=receive();//输入   sentothers(mes,false);//向所有用户输出}} catch (IOException e) {System.out.println("多线程中出错");}   }public String receive() throws IOException {String mes="";mes=in.readUTF();return mes;}public void sentothers(String mes,boolean iSsys) throws IOException {for(channel other:all) {if(other==this) {continue;}if(!iSsys) {other.sent(this.name+"对全体成员说: "+mes);}else {other.sent(mes);}}}public void sent(String mes) throws IOException {out.writeUTF(mes);out.flush();}public  void release() {//释放资源并退出聊天室isRunning=false;CloseUtlis utlis =new CloseUtlis();utlis.close(in,client);all.remove(this);try {sentothers(this.name+" 离开了群聊",true );} catch (IOException e) {System.out.println("释放时出错");}}}
}

效果

网络编程_手写聊天室_群聊过渡板相关推荐

springboot+websocket构建在线聊天室（群聊+单聊）
系列导读: 1.springboot+websocket构建在线聊天室(群聊+单聊) 2.Spring Boot WebSocket:单聊(实现思路) 3.Websocket Stomp+Rabbit ...
06 java GUI 网络编程：图形界面聊天室
仿照第4篇笔记的形式,笔者决定将GUI和网络编程部分用综合练习的方式来总结.练习项目是有图形界面的聊天室,用到了GUI中的javax.swing包和网络编程中的TCP/socket编程.GUI部分的难 ...
网络编程基础_5.3聊天室-多人聊天室
聊天室-多人聊天室 #include <stdio.h>// 1. 包含必要的头文件和库, 必须位于 windows之前 #include <WinSock2.h> #prag ...
网络编程项目—— 多人聊天室-＞双人聊天
一.Coding前的思考和步骤梳理 1. 又开始思考这个问题,拿到一个需求,是调用java底层的代码写1000行实现,还是直接调第三方库写50行实现? 都一样. 发现第一次写shell的时候其实思考过 ...
Java用TCP手写聊天室可以私聊版加群聊版
一:引言想要私聊必须有规定的格式:@名字:要说的话二:上码 1.服务端 package com.wyj.talkhome; /** * 实现一个用户可以接发多条消息 * * */ import j ...
linux网络编程TCP多人聊天室
用socket实现一个多人聊天室的思路很简单,即在服务器端定义一个fd的int型数组,用来存储已经连接的客户端的socket连接套接字fd(因为发送和接收数据都只需要借助连接套接字fd),当服务器接收 ...
Go实现简易聊天室（群聊）
参考:Go 群聊 ( goroutine ) · 语雀基于websocket的聊天室,可进一步参考: (1) go实现聊天室(WebSocket方式) (2) Golang代码搜集-基于websoc ...
socket聊天室实现-群聊，私聊，好友列表，完整版
效果图登录.好友上线,下线均提示. 点击好友列表所有人,发送消息,既为群聊点击好友列表,好友名字,既为选中此好友进行私聊服务器端代码 ChatRoomServer package sram.se ...
django+vue3实现websocket聊天室（群聊）
1.如何实现聊天功能 2.什么是websocket 2.1解释什么叫全双工,半双工,单工 3.websocker的概念 4.websocket的优点 5.django ,vue如何实现websocke ...
Node + WebSocket + Vue 聊天室创建群聊/加入群聊功能 – 第五章
前言本次算是做了一个小小的专题吧,"Nodejs + WebSocket + Vue实现聊天室功能",目前还在一步一步推进,之前已经可以一对一.一对多聊天了,今天就来创建群聊组, ...

网络编程_手写聊天室_群聊过渡板

实现功能

关闭流工具类

客户端接收类

客户端发送类

客户端

服务器

效果

网络编程_手写聊天室_群聊过渡板相关推荐

最新文章

热门文章