电脑知识|欧美黑人一区二区三区|软件|欧美黑人一级爽快片淫片高清|系统|欧美黑人狂野猛交老妇|数据库|服务器|编程开发|网络运营|知识问答|技术教程文章 - 好吧啦网

您的位置:首頁技術文章
文章詳情頁

基于Java的Socket多客戶端Client-Server聊天程序的實現

瀏覽:12日期:2022-09-04 15:28:29

任務要求

編寫一個簡單的Socket多客戶端聊天程序:

客戶端程序,從控制臺輸入字符串,發送到服務器端,并將服務器返回的信息顯示出來 服務器端程序,從客戶機接收數據并打印,同時將從標準輸入獲取的信息發送給客戶機 滿足一個服務器可以服務多個客戶

低配版本鏈接

實現代碼

工具類

import java.io.DataOutputStream;import java.io.IOException;import java.io.OutputStream;import java.net.Socket;public class SocketUtils {public static void writeToSocket(Socket socket, String message) throws IOException {writeToOutputStream(socket.getOutputStream(), message);}public static void writeToDataOutputStream(DataOutputStream dos, String message) throws IOException {dos.writeUTF(message);dos.flush();}public static void writeToOutputStream(OutputStream os, String message) throws IOException {writeToDataOutputStream(new DataOutputStream(os), message);}}

服務器端線程

import java.io.DataInputStream;import java.io.DataOutputStream;import java.io.IOException;import java.net.Socket;import java.text.SimpleDateFormat;import java.util.Date;import java.util.Map;public class ChatServerRunnable implements Runnable {private Socket socket;private DataOutputStream dos;private DataInputStream dis;private String currentUserNickName;public ChatServerRunnable(Socket socket) throws IOException {this.socket = socket;this.dos = new DataOutputStream(socket.getOutputStream());this.dis = new DataInputStream(socket.getInputStream());}@Overridepublic void run() {try {write('歡迎來到聊天室!');login();System.out.println(currentUserNickName + '用戶登錄成功');write(currentUserNickName + ', 您已登錄。n輸入【list users】可以查看當前登錄用戶列表n輸入【to all 消息內容】可以群發消息n輸入【to 某個用戶 消息內容】可以給指定用戶發送消息n輸入【exit】可以退出聊天');String input = dis.readUTF();while (!ChatServer.EXIT.equals(input)) {System.out.println(currentUserNickName + '輸入了' + input);if (input.startsWith('to ')) {sendMessage(input);} else if ('list users'.equals(input)) {showOnlineUsers();} else {write('您輸入的命令不合法,請重新輸入!');}input = dis.readUTF();}} catch (IOException e) {e.printStackTrace();} finally {ChatServer.nickNameSocketMap.remove(currentUserNickName);try {dis.close();} catch (IOException e) {e.printStackTrace();}try {dos.close();} catch (IOException e) {e.printStackTrace();}try {socket.close();} catch (IOException e) {e.printStackTrace();}}}private void login() throws IOException {write('請輸入你的昵稱:');while (true) {String nickName = dis.readUTF();System.out.println('用戶輸入了昵稱:' + nickName);synchronized (ChatServerRunnable.class) {if (!ChatServer.nickNameSocketMap.containsKey(nickName)) {currentUserNickName = nickName;ChatServer.nickNameSocketMap.put(nickName, socket);break;} else {write('您輸入的昵稱已存在,請重新輸入:');}}}}private void sendMessage(String input) throws IOException {int receiverEndIndex = input.indexOf(' ', 3);String receiver = input.substring(3, receiverEndIndex);String message = input.substring(receiverEndIndex + 1);if ('all'.equals(receiver)) {broadcast(message);} else {sendIndividualMessage(receiver, message);}}private void sendIndividualMessage(String receiver, String orignalMessage) throws IOException {Socket receiverSocket = ChatServer.nickNameSocketMap.get(receiver);if (receiverSocket != null) {SocketUtils.writeToSocket(receiverSocket, formatMessage('你', orignalMessage));} else {write('您要單獨聊天的用戶【' + receiver + '】不存在或者已經下線');}}private String formatMessage(String receiver, String originalMessage) {StringBuilder messageBuilder = new StringBuilder();messageBuilder.append(currentUserNickName).append(' 對 ').append(receiver).append(' 說:n').append(originalMessage).append('n發送時間:').append(new SimpleDateFormat('yyyy-MM-dd HH:mm:ss').format(new Date()));return messageBuilder.toString();}private void broadcast(String orignalMessage) throws IOException {for (Map.Entry<String, Socket> entry : ChatServer.nickNameSocketMap.entrySet()) {if (!currentUserNickName.equals(entry.getKey())) {SocketUtils.writeToSocket(entry.getValue(), formatMessage('所有人', orignalMessage));}}}private void showOnlineUsers() throws IOException {StringBuilder users = new StringBuilder();users.append('當前在線的用戶有:n');for (String nickName : ChatServer.nickNameSocketMap.keySet()) {users.append('【').append(nickName).append('】n');}write(users.toString());}private void write(String message) throws IOException {SocketUtils.writeToDataOutputStream(dos, message);}}

客戶端線程

import java.io.DataInputStream;import java.io.IOException;public class ClientMessageReceiver implements Runnable {private DataInputStream dis;private boolean timeToStop = false;public ClientMessageReceiver(DataInputStream dis) {this.dis = dis;}@Overridepublic void run() {while (!timeToStop) {try {System.out.println(dis.readUTF());} catch (IOException e) {if ('Connection reset'.equals(e.getMessage())) {System.out.println('與服務器的連接已中斷!');break;}if (!timeToStop) {e.printStackTrace();}}}}public void stop() {timeToStop = true;}}

服務器端程序

import java.io.IOException;import java.net.ServerSocket;import java.net.Socket;import java.util.HashMap;import java.util.Map;public class ChatServer {public static final String EXIT = 'exit';public static final int PORT = 8888;static Map<String, Socket> nickNameSocketMap = new HashMap<>();public static void main(String[] args) {try (ServerSocket ss = new ServerSocket(PORT)) {System.out.println('聊天室服務器端已啟動,正在監聽' + PORT + '端口');while (true) {try {Socket socket = ss.accept();System.out.println('有新用戶連接到服務器端,信息為:' + socket);new Thread(new ChatServerRunnable(socket)).start();} catch (Exception e) {e.printStackTrace();}}} catch (IOException e) {e.printStackTrace();}}}

客戶端程序

import java.io.DataInputStream;import java.io.DataOutputStream;import java.io.IOException;import java.net.Socket;import java.util.Scanner;public class ChatClient {private static Scanner scanner = new Scanner(System.in);public static void main(String[] args) {try (Socket socket = new Socket('127.0.0.1', 8888);DataInputStream dis = new DataInputStream(socket.getInputStream());DataOutputStream dos = new DataOutputStream(socket.getOutputStream())) {ClientMessageReceiver messageReceiver = new ClientMessageReceiver(dis);new Thread(messageReceiver).start();String input = null;do {input = scanner.nextLine();write(dos, input);} while (!ChatServer.EXIT.equals(input));messageReceiver.stop();} catch (IOException e) {e.printStackTrace();}}private static void write(DataOutputStream dos, String message) throws IOException {dos.writeUTF(message);dos.flush();}}

運行說明

啟動服務器:

基于Java的Socket多客戶端Client-Server聊天程序的實現

啟動第一個客戶端,輸入客戶昵稱:

基于Java的Socket多客戶端Client-Server聊天程序的實現

服務器監聽到了這個事件:

基于Java的Socket多客戶端Client-Server聊天程序的實現

獲取所有用戶列表,發送給所有用戶“hhh”的信息:

基于Java的Socket多客戶端Client-Server聊天程序的實現

服務器端接收到了這個事件:

基于Java的Socket多客戶端Client-Server聊天程序的實現

新的客戶端登錄,注冊用戶昵稱:

基于Java的Socket多客戶端Client-Server聊天程序的實現

服務器接收到這個事件:

基于Java的Socket多客戶端Client-Server聊天程序的實現

用戶1向用戶2發送私聊消息:

基于Java的Socket多客戶端Client-Server聊天程序的實現

用戶2收到用戶1的消息:

基于Java的Socket多客戶端Client-Server聊天程序的實現

客戶2向所有用戶發送消息:

基于Java的Socket多客戶端Client-Server聊天程序的實現

客戶1收到客戶2的群發消息:

基于Java的Socket多客戶端Client-Server聊天程序的實現

服務器監聽到了這些事件:

基于Java的Socket多客戶端Client-Server聊天程序的實現

客戶2退出:

基于Java的Socket多客戶端Client-Server聊天程序的實現

客戶1顯示的在線列表只有1人了:

基于Java的Socket多客戶端Client-Server聊天程序的實現

客戶1也退出:

基于Java的Socket多客戶端Client-Server聊天程序的實現

客戶端用戶退出的時候,該線程終止。

沒客戶端用戶,服務器也正常跑自己的事。

到此這篇關于基于Java的Socket多客戶端Client-Server聊天程序的實現的文章就介紹到這了,更多相關Java Socket多客戶端Client-Server聊天內容請搜索好吧啦網以前的文章或繼續瀏覽下面的相關文章希望大家以后多多支持好吧啦網!

標簽: Java
相關文章:
主站蜘蛛池模板: 远程会诊系统-手术示教系统【林之硕】医院远程医疗平台 | 衬氟止回阀_衬氟闸阀_衬氟三通球阀_衬四氟阀门_衬氟阀门厂-浙江利尔多阀门有限公司 | 螺旋压榨机-刮泥机-潜水搅拌机-电动泥斗-潜水推流器-南京格林兰环保设备有限公司 | 二手Sciex液质联用仪-岛津气质联用仪-二手安捷伦气质联用仪-上海隐智科学仪器有限公司 | 滑石粉,滑石粉厂家,超细滑石粉-莱州圣凯滑石有限公司 | 有声小说,听书,听小说资源库-听世界网 | 高效节能电机_伺服主轴电机_铜转子电机_交流感应伺服电机_图片_型号_江苏智马科技有限公司 | 沟盖板_复合沟盖板厂_电力盖板_树脂雨水篦子-淄博拜斯特 | 威海防火彩钢板,威海岩棉复合板,威海彩钢瓦-文登区九龙岩棉复合板厂 | 高效节能电机_伺服主轴电机_铜转子电机_交流感应伺服电机_图片_型号_江苏智马科技有限公司 | 北京律师事务所_房屋拆迁律师_24小时免费法律咨询_云合专业律师网 | 耐磨陶瓷,耐磨陶瓷管道_厂家-淄博拓创陶瓷科技 | 顺景erp系统_erp软件_erp软件系统_企业erp管理系统-广东顺景软件科技有限公司 | 防水套管厂家_刚性防水套管_柔性防水套管_不锈钢防水套管-郑州中泰管道 | BHK汞灯-百科|上海熙浩实业有限公司| 圆形振动筛_圆筛_旋振筛_三次元振动筛-河南新乡德诚生产厂家 | 上海赞永| 高通量组织研磨仪-多样品组织研磨仪-全自动组织研磨仪-研磨者科技(广州)有限公司 | 锂辉石检测仪器,水泥成分快速分析仪-湘潭宇科分析仪器有限公司 | 天津中都白癜风医院_天津白癜风医院_天津治疗白癜风 | 厌氧工作站-通用型厌氧工作站-上海胜秋科学仪器有限公司 | 钣金加工厂家-钣金加工-佛山钣金厂-月汇好 | 智能垃圾箱|垃圾房|垃圾分类亭|垃圾分类箱专业生产厂家定做-宿迁市传宇环保设备有限公司 | 南溪在线-南溪招聘找工作、找房子、找对象,南溪综合生活信息门户! | 道达尔润滑油-食品级润滑油-道达尔导热油-合成导热油,深圳道达尔代理商合-深圳浩方正大官网 | 深圳3D打印服务-3D打印加工-手板模型加工厂-悟空打印坊 | 精益专家 - 设备管理软件|HSE管理系统|设备管理系统|EHS安全管理系统 | 除湿机|工业除湿机|抽湿器|大型地下室车间仓库吊顶防爆除湿机|抽湿烘干房|新风除湿机|调温/降温除湿机|恒温恒湿机|加湿机-杭州川田电器有限公司 | 304不锈钢无缝管_不锈钢管厂家 - 隆达钢业集团有限公司 | 硬齿面减速机[型号全],ZQ减速机-淄博久增机械 | 水冷式工业冷水机组_风冷式工业冷水机_水冷螺杆冷冻机组-深圳市普威机械设备有限公司 | 大型工业风扇_工业大风扇_大吊扇_厂房车间降温-合昌大风扇 | 包装设计公司,产品包装设计|包装制作,包装盒定制厂家-汇包装【官方网站】 | 智慧消防-消防物联网系统云平台 智能化的检漏仪_气密性测试仪_流量测试仪_流阻阻力测试仪_呼吸管快速检漏仪_连接器防水测试仪_车载镜头测试仪_奥图自动化科技 | 幂简集成 - 品种超全的API接口平台, 一站搜索、试用、集成国内外API接口 | 超细粉碎机|超微气流磨|气流分级机|粉体改性设备|超微粉碎设备-山东埃尔派粉碎机厂家 | 不锈钢反应釜,不锈钢反应釜厂家-价格-威海鑫泰化工机械有限公司 不干胶标签-不干胶贴纸-不干胶标签定制-不干胶标签印刷厂-弗雷曼纸业(苏州)有限公司 | 干式变压器厂_干式变压器厂家_scb11/scb13/scb10/scb14/scb18干式变压器生产厂家-山东科锐变压器有限公司 | 导电银胶_LED封装导电银胶_半导体封装导电胶厂家-上海腾烁 | 「安徽双凯」自动售货机-无人售货机-成人用品-自动饮料食品零食售货机 | 广东护栏厂家-广州护栏网厂家-广东省安麦斯交通设施有限公司 |