TCP案例之单聊与群聊

embedded/2024/10/19 7:27:11/

TCP案例之单聊与群聊

一、TCP案例之单聊

在基于TCP协议的单聊应用中，通常涉及客户端和服务器端的交互。

服务器端

  1. 建立服务器：
    • 服务器端创建一个TCP Socket并绑定到一个特定的端口，开始监听来自客户端的连接请求。
  2. 接受连接：
    • 服务器端接受客户端的连接请求，建立TCP连接。
  3. 接收消息：
    • 服务器端接收客户端发送的消息数据。
  4. 处理消息：
    • 服务器端处理接收到的消息，可以进行消息转发、存储、验证等操作。
  5. 发送响应：
    • 服务器端可以向客户端发送响应，如确认消息接收、错误提示等。

客户端

  1. 建立连接：
    • 客户端创建一个TCP Socket并连接到服务器端的IP地址和端口。
  2. 发送消息：
    • 客户端向服务器端发送消息数据。
  3. 接收响应：
    • 客户端接收服务器端的响应数据。
  4. 处理响应：
    • 客户端处理接收到的响应，可以展示在界面上或者进行其他操作。
  5. 关闭连接：
    • 客户端和服务器端在通信结束后关闭连接。

示例场景

  • Alice和Bob是两个用户，他们分别运行客户端应用程序。
  • 服务器端监听在特定端口上，等待客户端连接。
  • Alice连接到服务器端，发送一条消息给Bob。
  • 服务器端接收Alice的消息，转发给Bob。
  • Bob接收到消息后可以进行回复，服务器再将消息转发给Alice。

示例代码

客服端：

java">import java.io.IOException;
import java.io.PrintStream;
import java.net.Socket;
import java.net.UnknownHostException;
import java.util.Scanner;public class Client {/*** 知识点：TCP案例 之 优化单聊*/public static void main(String[] args) throws UnknownHostException, IOException {Socket socket = new Socket("127.0.0.1", 9082);new ReceiveThread(socket).start();Scanner scan = new Scanner(System.in);PrintStream ps = new PrintStream(socket.getOutputStream());while(true){ps.println("小雷：" + scan.next());}}
}

服务器端：

java">import java.io.IOException;
import java.io.PrintStream;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Scanner;public class Server {public static void main(String[] args) throws IOException {ServerSocket server = new ServerSocket(9082);Socket socket = server.accept();new ReceiveThread(socket).start();Scanner scan = new Scanner(System.in);PrintStream ps = new PrintStream(socket.getOutputStream());while(true){ps.println("小杨：" + scan.next());}}
}

接收线程（相当于中转站）：

java">import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.UnsupportedEncodingException;
import java.net.Socket;public class ReceiveThread extends Thread{private Socket socket;public ReceiveThread(Socket socket) {this.socket = socket;}@Overridepublic void run() {try {BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream(), "GBK"));while(true){String readLine = br.readLine();System.out.println(readLine);}} catch (UnsupportedEncodingException e) {e.printStackTrace();} catch (IOException e) {e.printStackTrace();}}
}

二、TCP案例之群聊

基于TCP协议的群聊应用涉及多个客户端与服务器之间的交互，实现了群组内的消息广播功能。

服务器端

  1. 建立服务器：
    • 服务器端创建一个TCP Socket并绑定到一个特定的端口，开始监听来自客户端的连接请求。
  2. 接受连接：
    • 服务器端接受客户端的连接请求，建立TCP连接。
  3. 加入群组：
    • 客户端可以向服务器发送加入群组的请求，服务器更新群组成员列表。
  4. 接收消息：
    • 服务器端接收客户端发送的消息数据。
  5. 消息广播：
    • 服务器端将接收到的消息广播给所有群组成员。
  6. 处理退出：
    • 客户端可以发送退出群组的请求，服务器更新群组成员列表并通知其他成员。

客户端

  1. 建立连接：
    • 客户端创建一个TCP Socket并连接到服务器端的IP地址和端口。
  2. 加入群组：
    • 客户端向服务器发送加入群组的请求。
  3. 发送消息：
    • 客户端向服务器发送消息数据。
  4. 接收广播：
    • 客户端接收服务器端广播的消息数据。
  5. 处理消息：
    • 客户端展示接收到的消息数据。
  6. 退出群组：
    • 客户端可以发送退出群组的请求。

示例场景

  • 服务器端维护一个群组成员列表，包括Alice、Bob、Charlie等用户。
  • Alice、Bob、Charlie分别连接到服务器端，加入群组。
  • Alice发送一条消息给所有群组成员。
  • 服务器端接收Alice的消息，将消息广播给Bob、Charlie等成员。
  • Bob和Charlie接收到消息后可以进行回复或者其他操作。
  • Bob决定退出群组，发送退出请求给服务器端。

示例代码

服务器端：

java">import java.io.IOException;
import java.io.PrintStream;
import java.net.Socket;
import java.net.UnknownHostException;
import java.util.Scanner;public class Client {/*** 知识点：TCP案例 之 群聊*/public static void main(String[] args) throws UnknownHostException, IOException {Socket socket = new Socket("127.0.0.1", 7080);new ReceiveThread(socket).start();Scanner scan = new Scanner(System.in);PrintStream ps = new PrintStream(socket.getOutputStream());while(true){ps.println("小杨：" + scan.next());}}
}

服务器端：

java">import java.io.IOException;
import java.io.PrintStream;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.concurrent.ConcurrentHashMap;public class Server {public static final ConcurrentHashMap<String, PrintStream> map = new ConcurrentHashMap<>();public static void main(String[] args) throws IOException {ServerSocket server = new ServerSocket(7080);while(true){Socket socket = server.accept();String ip = socket.getInetAddress().toString();PrintStream ps = new PrintStream(socket.getOutputStream());map.put(ip, ps);new ServerThread(socket).start();}}
}

服务器线程：

java">import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintStream;
import java.io.UnsupportedEncodingException;
import java.net.Socket;
import java.util.Map.Entry;
import java.util.Set;public class ServerThread extends Thread{private Socket socket;public ServerThread(Socket socket) {this.socket = socket;}@Overridepublic void run() {try {//接受当前客户端的消息BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream(), "GBK"));while(true){String readLine = br.readLine();System.out.println(readLine);//发送给其他客户端消息Set<Entry<String,PrintStream>> entrySet = Server.map.entrySet();for (Entry<String, PrintStream> entry : entrySet) {String ip = entry.getKey();PrintStream ps = entry.getValue();if(!socket.getInetAddress().toString().equals(ip)){ps.println(readLine);}}}} catch (UnsupportedEncodingException e) {e.printStackTrace();} catch (IOException e) {e.printStackTrace();}}
}

接受线程：

java">import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.UnsupportedEncodingException;
import java.net.Socket;public class ReceiveThread extends Thread{private Socket socket;public ReceiveThread(Socket socket) {this.socket = socket;}@Overridepublic void run() {try {BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream(), "GBK"));while(true){String readLine = br.readLine();System.out.println(readLine);}} catch (UnsupportedEncodingException e) {e.printStackTrace();} catch (IOException e) {e.printStackTrace();}}
}

TCP群聊理解图：
TCP群聊理解图


http://www.ppmy.cn/embedded/20776.html

相关文章

四、Flask进阶

四、Flask进阶

Flask-Cache pip install flask-caching安装flask_cache初始化 # ext.py from flask_sqlalchemy import SQLAlchemy from flask_migrate import Migrate from flask_caching import Cachedb SQLAlchemy() migrate Migrate() cache Cache(config{CACHE_TYPE: simple # 缓存…
阅读更多...
探索矿业数字化平台：实现智能化采矿与管理

探索矿业数字化平台：实现智能化采矿与管理

随着信息技术的迅猛发展&#xff0c;矿业领域也在逐步实现数字化转型。数字化平台的出现为矿业企业带来了更高效、更智能的采矿与管理方式。本文将探讨矿业数字化平台的意义、特点以及未来发展方向。 ### 1. 数字化平台的意义 传统的矿业生产和管理方式存在诸多问题&#xff…
阅读更多...
《数据结构》（学习笔记）（王道）

《数据结构》（学习笔记）（王道）

一、绪论 1.1 数据结构的基本概念 数据&#xff1a;是信息的载体&#xff0c;是描述客观事物属性的数、字符以及所有输入到计算机中并被计算机程序识别和处理的符号的集合。&#xff08;计算机程序加工的原料&#xff09;数据元素&#xff1a;数据的基本单位&#xff0c;由若干…
阅读更多...
机器学习-期末复习

机器学习-期末复习

本文的内容按照作者的课程考试要求书写&#xff0c;仅供复习参考。&#x1f337;&#x1f337;&#x1f337;欢迎大家指正&#xff01; 机器学习是一种人工智能&#xff08;AI&#xff09;的分支领域&#xff0c;它致力于开发能够通过数据学习和改进的算法和模型。简而言之&…
阅读更多...
AtCoder Regular Contest 176 C. Max Permutation（计数 分类讨论）

AtCoder Regular Contest 176 C. Max Permutation（计数 分类讨论）

题目 思路来源 乱搞ac 题解 1. 如果有边的权值是1&#xff0c;意味着有两个点的权值都是1&#xff0c;无解 2. 如果一个点i被多个max条件控制&#xff0c;它的值不能超过这些max里最小的那个&#xff0c;记做up[i] 3. 如果同一个权值w对应的边不少于2条&#xff0c;这些边…
阅读更多...
SpringBoot集成Log2j4指定外部配置文件源码解读

SpringBoot集成Log2j4指定外部配置文件源码解读

一、背景 程序读取外部log4j2.xml配置文件方式为启动命令添加了--logging.config/path/log4j2.xml&#xff0c;因系统安全整改&#xff0c;将/var/log/目录改为了700&#xff0c;程序使用非root启动时log4j2报错无法在/var/log目录下创建日志文件。经排查发现jar包的classpath…
阅读更多...
力扣HOT100 - 199. 二叉树的右视图

力扣HOT100 - 199. 二叉树的右视图

解题思路&#xff1a; 相当于层序遍历&#xff0c;然后取每一层的最后一个节点。 class Solution {public List<Integer> rightSideView(TreeNode root) {if (root null) return new ArrayList<Integer>();Queue<TreeNode> queue new LinkedList<>…
阅读更多...
Ubuntu中放行端口

Ubuntu中放行端口

人的故乡&#xff0c;并不止于一块特定的土地&#xff0c;而是一种辽阔无比的心情&#xff0c;不受空间和时间的限制&#xff1b;这心情一经唤起&#xff0c;就是你已经回到了故乡。 ——史铁生《我与地坛》 在Ubuntu中放行端口&#xff0c;通常是通过配置防火墙来实现的。Ubun…
阅读更多...
最新文章

Copyright @ 2022~2023