Socket与SocketServer结合多线程实现多客户端与服务器通信

2024-01-01 07:38
文章标签 实现 服务器 多线程 结合 客户端 通信 socket socketserver

本文主要是介绍Socket与SocketServer结合多线程实现多客户端与服务器通信，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

需求说明：实现多客户端用户登录，实现多客户端登录一般都需要使用线程技术：

（1）创建服务器端线程类，run()方法中实现对一个请求的响应处理；

（2）修改服务器端代码，实现循环监听状态；

（3）服务器端每监听到一个请求，创建一个处理线程；

关于Socket与SocketServer介绍我这里不多说了，网上很多资料，这里推荐一个

http://www.cnblogs.com/rond/p/3565113.html

代码如下：

1、用户类

package com.j02.d04;
import java.io.Serializable;
/*
* 使用对象的思想进行客户端与服务端的通信
*/
public class User implements Serializable{
private String name;
private String pwd;
public User() {
super();
}
public User(String name, String pwd) {
super();
this.name = name;
this.pwd = pwd;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public String getPwd() {
return pwd;
}
public void setPwd(String pwd) {
this.pwd = pwd;
}
}

2、服务器类

package com.j02.d04;
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.ObjectInputStream;
import java.io.OutputStream;
import java.io.OutputStreamWriter;
import java.net.ServerSocket;
import java.net.Socket;
public class Server {
public static void main(String[] args) {
ServerSocket server=null;
Socket socket=null;
User user=new User();
try {
//创建ServerSocket端口
server=new ServerSocket(9001);
//创建通信连接
while(true){
socket=server.accept();
//创建线程执行响应操作
                
ServerThread st=new ServerThread(socket);
st.start();
}
} catch (IOException e) {
e.printStackTrace();
}
}
}

3、服务器线程类

package com.j02.d04;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStream;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.io.OutputStream;
import java.io.OutputStreamWriter;
import java.net.Socket;
/*
* 服务端的线程，处理多个客户端请求
*/
public class ServerThread extends Thread{
//定义一个客户端socket
private Socket socket;
public ServerThread(){
}
public ServerThread(Socket socket){
this.socket=socket;
}
//执行响应输出操作
public void run() {
try {
//获取客户端的输出流
InputStream is=socket.getInputStream();
ObjectInputStream ois=new ObjectInputStream(is);
User user=(User)ois.readObject();
System.out.println("我是服务器，接收到客户端的信息是："+user.getName()+"------"+user.getPwd());
//输出给客户端的响应
String reply="登陆成功！";
OutputStream os=socket.getOutputStream();
BufferedWriter oos=new BufferedWriter(new OutputStreamWriter(os));
oos.write(reply);
oos.flush();
//关闭流
            oos.close();
os.close();
ois.close();
is.close();
} catch (IOException e) {
e.printStackTrace();
} catch (ClassNotFoundException e) {
e.printStackTrace();
}
}
}

4、客户端1

package com.j02.d04;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.ObjectOutputStream;
import java.io.OutputStream;
import java.net.Socket;
import java.net.UnknownHostException;
/*
* 客户端
*/
public class Client {
public static void main(String[] args) {
Socket socket=null;
OutputStream os=null;
ObjectOutputStream oos=null;
User login=new User("admin","123456");
try {
//创建Socket指定访问地址和端口
socket=new Socket("localhost",9001);
//获取输出流对象
os=socket.getOutputStream();
oos=new ObjectOutputStream(os);
//输出的是对象的值
            oos.writeObject(login);
//读服务器返回的响应
InputStream is=socket.getInputStream();
BufferedReader br=new BufferedReader(new InputStreamReader(is));
String reply;
while((reply=br.readLine())!=null){
System.out.println("我是客户端，服务器返回的响应是："+reply);
}
} catch (UnknownHostException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
}
}

5、客户端2

package com.j02.d04;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.ObjectOutputStream;
import java.io.OutputStream;
import java.net.Socket;
import java.net.UnknownHostException;
/*
* 客户端
*/
public class Client2 {
public static void main(String[] args) {
Socket socket=null;
OutputStream os=null;
ObjectOutputStream oos=null;
User login=new User("kate","4rfv%TGB");
try {
//创建Socket指定访问地址和端口
socket=new Socket("localhost",9001);
//获取输出流对象
os=socket.getOutputStream();
oos=new ObjectOutputStream(os);
//输出的是对象的值
            oos.writeObject(login);
//读服务器返回的响应
InputStream is=socket.getInputStream();
BufferedReader br=new BufferedReader(new InputStreamReader(is));
String reply;
while((reply=br.readLine())!=null){
System.out.println("我是客户端，服务器返回的响应是："+reply);
}
} catch (UnknownHostException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
}
}

运行：先运行服务器类-客户端1-客户端2

然后在小电脑那里选择服务器类执行：

结果：

其它知识点补充：

获取客户机的IP地址

在线程那个类中添加代码：

//获取客户端的IP地址
InetAddress adress=socket.getInetAddress();//socket这个方法是获取一个返回套接字连接的地址。它返回的是一个此套接字连接到的远程 IP 地址
String ip=adress.getHostAddress();//InetAddress 套接字的类可以通过getHostName()方法获取获取此 IP 地址的主机名。
System.out.println("请求的客户机ip地址是："+ip);

结果如下：

 

这篇关于Socket与SocketServer结合多线程实现多客户端与服务器通信的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/558556。

相关文章

Python实现自动化Word文档样式复制与内容生成

Python实现自动化Word文档样式复制与内容生成

《Python实现自动化Word文档样式复制与内容生成》在办公自动化领域,高效处理Word文档的样式和内容复制是一个常见需求,本文将展示如何利用Python的python-docx库实现... 目录一、为什么需要自动化 Word 文档处理二、核心功能实现：样式与表格的深度复制1. 表格复制（含样式与内容）2
阅读更多...
python获取cmd环境变量值的实现代码

python获取cmd环境变量值的实现代码

《python获取cmd环境变量值的实现代码》：本文主要介绍在Python中获取命令行（cmd）环境变量的值,可以使用标准库中的os模块,需要的朋友可以参考下... 前言全局说明在执行py过程中，总要使用到系统环境变量一、说明1.1 环境:Windows 11 家庭版 24H2 26100.4061
阅读更多...
如何解决Druid线程池Cause:java.sql.SQLRecoverableException:IO错误:Socket read timed out的问题

如何解决Druid线程池Cause:java.sql.SQLRecoverableException:IO错误:Socket read timed out的问题

《如何解决Druid线程池Cause:java.sql.SQLRecoverableException:IO错误:Socketreadtimedout的问题》：本文主要介绍解决Druid线程... 目录异常信息触发场景找到版本发布更新的说明从版本更新信息可以看到该默认逻辑已经去除总结异常信息触发场景复
阅读更多...
Python中bisect_left 函数实现高效插入与有序列表管理

Python中bisect_left 函数实现高效插入与有序列表管理

《Python中bisect_left函数实现高效插入与有序列表管理》Python的bisect_left函数通过二分查找高效定位有序列表插入位置,与bisect_right的区别在于处理重复元素时... 目录一、bisect_left 基本介绍1.1 函数定义1.2 核心功能二、bisect_left 与
阅读更多...
VSCode设置python SDK路径的实现步骤

VSCode设置python SDK路径的实现步骤

《VSCode设置pythonSDK路径的实现步骤》本文主要介绍了VSCode设置pythonSDK路径的实现步骤,包括命令面板切换、settings.json配置、环境变量及虚拟环境处理,具有一定... 目录一、通过命令面板快速切换（推荐方法）二、通过 settings.json 配置（项目级/全局）三、
阅读更多...
pandas实现数据concat拼接的示例代码

pandas实现数据concat拼接的示例代码

《pandas实现数据concat拼接的示例代码》pandas.concat用于合并DataFrame或Series,本文主要介绍了pandas实现数据concat拼接的示例代码,具有一定的参考价值,... 目录语法示例：使用pandas.concat合并数据默认的concat：参数axis=0，join=
阅读更多...
java中BigDecimal里面的subtract函数介绍及实现方法

java中BigDecimal里面的subtract函数介绍及实现方法

《java中BigDecimal里面的subtract函数介绍及实现方法》在Java中实现减法操作需要根据数据类型选择不同方法,主要分为数值型减法和字符串减法两种场景,本文给大家介绍java中BigD... 目录Java中BigDecimal里面的subtract函数的意思？一、数值型减法（高精度计算）1.
阅读更多...
C#代码实现解析WTGPS和BD数据

C#代码实现解析WTGPS和BD数据

《C#代码实现解析WTGPS和BD数据》在现代的导航与定位应用中,准确解析GPS和北斗（BD）等卫星定位数据至关重要,本文将使用C#语言实现解析WTGPS和BD数据,需要的可以了解下... 目录一、代码结构概览1. 核心解析方法2. 位置信息解析3. 经纬度转换方法4. 日期和时间戳解析5. 辅助方法二、L
阅读更多...
使用Python和Matplotlib实现可视化字体轮廓(从路径数据到矢量图形)

使用Python和Matplotlib实现可视化字体轮廓(从路径数据到矢量图形)

《使用Python和Matplotlib实现可视化字体轮廓(从路径数据到矢量图形)》字体设计和矢量图形处理是编程中一个有趣且实用的领域,通过Python的matplotlib库,我们可以轻松将字体轮廓... 目录背景知识字体轮廓的表示实现步骤1. 安装依赖库2. 准备数据3. 解析路径指令4. 绘制图形关键
阅读更多...
RabbitMQ工作模式中的RPC通信模式详解

RabbitMQ工作模式中的RPC通信模式详解

《RabbitMQ工作模式中的RPC通信模式详解》在RabbitMQ中,RPC模式通过消息队列实现远程调用功能,这篇文章给大家介绍RabbitMQ工作模式之RPC通信模式,感兴趣的朋友一起看看吧... 目录RPC通信模式概述工作流程代码案例引入依赖常量类编写客户端代码编写服务端代码RPC通信模式概述在R
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2