如何在Java实现TCP方式发送和接收Socket消息(多线程模式)

目录

  • 导言:
  • 正文:
    • 1. 创建Server端:
    • 2. 创建Client端:
    • 3. 多线程模式:
  • 代码示例
    • Server端代码示例:
    • Client端代码示例:
      • 同步模式发送TCP消息
      • 异步模式
  • 结论:

导言:

在Java编程中,使用TCP协议进行Socket通信是非常常见的场景。本文将详细介绍如何在Java中实现TCP方式发送和接收Socket消息,并且利用多线程模式来提高通信效率。
在这里插入图片描述

正文:

1. 创建Server端:

首先,我们需要创建一个Server端来处理接收到的Socket连接请求。以下是实现的步骤:

  • 创建一个ServerSocket对象,并指定监听的端口号。
  • 使用accept()方法监听客户端的连接请求,并为每个连接创建一个新的线程进行处理。
  • 在线程中,使用Socket对象的getInputStream()方法获取输入流,可以读取客户端发送的消息。
  • 实现业务逻辑,处理收到的消息。
  • 使用Socket对象的getOutputStream()方法获取输出流,可以向客户端发送响应消息。
  • 关闭Socket连接和相关资源。

2. 创建Client端:

接下来,我们需要创建一个Client端来发送Socket消息到Server端。以下是实现的步骤:

  • 创建一个Socket对象,并指定Server端的IP地址和端口号。
  • 使用Socket对象的getOutputStream()方法获取输出流,可以向Server端发送消息。
  • 实现业务逻辑,发送需要传输的消息。
  • 使用Socket对象的getInputStream()方法获取输入流,可以读取Server端的响应消息。
  • 关闭Socket连接和相关资源。

3. 多线程模式:

在上述的Server端实现中,我们为每个连接创建了一个新的线程来处理消息。这样可以并发地处理多个客户端的请求,提高通信效率。以下是实现的步骤:

  • 创建一个Runnable接口的实现类,实现run()方法。
  • 在run()方法中实现Server端的逻辑:监听客户端连接、接收消息、处理消息、发送响应。
  • 在Server端的主线程中,创建一个线程池(ThreadPoolExecutor)来管理线程的执行。
  • 使用线程池的execute()方法提交任务,每次有新的连接请求时,创建一个新的任务并执行。
  • 关闭线程池和相关资源。

代码示例

当然,以下是一个简单的示例代码,展示了如何在Java中实现TCP方式发送和接收Socket消息(多线程模式):

Server端代码示例:

import java.io.*;
import java.net.*;public class Server {public static void main(String[] args) {try {ServerSocket serverSocket = new ServerSocket(12345);System.out.println("Server started, waiting for client...");while (true) {Socket socket = serverSocket.accept();System.out.println("Client connected: " + socket.getInetAddress().getHostAddress());Thread thread = new Thread(new ClientHandler(socket));thread.start();}} catch (IOException e) {e.printStackTrace();}}private static class ClientHandler implements Runnable {private Socket socket;public ClientHandler(Socket socket) {this.socket = socket;}@Overridepublic void run() {try {BufferedReader reader = new BufferedReader(new InputStreamReader(socket.getInputStream()));BufferedWriter writer = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));String message = reader.readLine();System.out.println("Received message from client: " + message);// 处理消息(这里仅做回显)String response = "Server: " + message.toUpperCase();writer.write(response);writer.newLine();writer.flush();System.out.println("Sent response to client: " + response);// 关闭连接socket.close();System.out.println("Connection closed");} catch (IOException e) {e.printStackTrace();}}}
}

Client端代码示例:

同步模式发送TCP消息

import java.io.*;
import java.net.*;public class Client {public static void main(String[] args) {try {Socket socket = new Socket("localhost", 12345);System.out.println("Connected to server");BufferedReader reader = new BufferedReader(new InputStreamReader(socket.getInputStream()));BufferedWriter writer = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));String message = "Hello from client";writer.write(message);writer.newLine();writer.flush();System.out.println("Sent message to server: " + message);String response = reader.readLine();System.out.println("Received response from server: " + response);// 关闭连接socket.close();System.out.println("Connection closed");} catch (IOException e) {e.printStackTrace();}}
}

异步模式

以下是客户端添加异步方式发送Socket消息并接收服务端响应消息的代码示例:

import java.io.*;
import java.net.*;
import java.util.concurrent.*;public class Client {public static void main(String[] args) {try {Socket socket = new Socket("localhost", 12345);System.out.println("Connected to server");// 异步发送消息ExecutorService executorService = Executors.newSingleThreadExecutor();Future<Void> sendFuture = executorService.submit(() -> {BufferedWriter writer = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));String message = "Hello from client";writer.write(message);writer.newLine();writer.flush();System.out.println("Sent message to server: " + message);return null;});// 异步接收响应Future<String> receiveFuture = executorService.submit(() -> {BufferedReader reader = new BufferedReader(new InputStreamReader(socket.getInputStream()));String response = reader.readLine();System.out.println("Received response from server: " + response);return response;});// 等待发送和接收完成sendFuture.get();String response = receiveFuture.get();// 关闭连接socket.close();executorService.shutdown();System.out.println("Connection closed");} catch (IOException | InterruptedException | ExecutionException e) {e.printStackTrace();}}
}

在这个异步模式的示例中,我们使用了ExecutorService来创建一个线程池,并利用submit()方法异步地执行发送和接收任务。Future对象用于获取异步任务的结果。

通过这种方式,客户端可以并行地发送消息和接收响应,提高通信效率。请注意,在实际应用中,您可能需要根据具体需求对代码进行修改和调整以满足项目的要求。

在上述示例中,Server端监听12345端口,接受客户端的连接请求,并为每个连接创建一个新的线程进行处理。Client端连接到Server端,发送消息,并接收Server端的响应。Server端仅将客户端发来的消息转换为大写并回显。

请注意,在实际应用中,您可能需要根据具体需求对代码进行修改和扩展,以满足更复杂的场景和功能要求。

结论:

通过以上步骤,我们可以在Java中实现TCP方式发送和接收Socket消息,并且利用多线程模式提高通信效率。这样可以满足大规模并发的需求,使得服务器能够同时处理多个客户端的请求。

需要注意的是,在实际应用中,我们还需要考虑网络异常、数据传输的安全性等问题,并进行相应的处理和优化。

希望本文对您理解如何在Java中实现TCP方式发送和接收Socket消息以及多线程模式有所帮助。如有任何疑问,请随时向我提问。如果您喜欢本文,欢迎点赞、收藏。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/48184.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

MySQL 和 MariaDB 版本管理的历史背景及差异

在本文中&#xff0c;我们将探讨 MySQL 和 MariaDB 服务生命周期和版本管理方式两个方面目前的状况及相关历史背景。 作者&#xff1a;Peter Zaitsev 本文来源&#xff1a;Percona 官网博客 爱可生开源社区出品。 需要说明的是 MySQL 和 MariaD B都有社区版和企业版。对于 MyS…

vue3自定义指令防止表单重复提交

可以设置在某个事件段内不允许重复提交&#xff1b;或者点击提交后设置提交flag&#xff0c;flag为true则不能再次提交 <template><div><h1>防止表单重复提交</h1><button click"submitForm" v-throttle>提交</button></di…

SpringBoot 的 RedisTemplate、Redisson

一、Jedis、Lettuce、Redisson的简介 优先使用Lettuce&#xff0c; 需要分布式锁&#xff0c;分布式集合等分布式的高级特性&#xff0c;添加Redisson结合使用。 对于高并发&#xff0c;1000/s的并发&#xff0c;数据库可能由行锁变成表锁&#xff0c;性能下降会厉害。 1.1、…

再JAVA中如何使用qsort对类进行排序?

目录 结论&#xff1a; 解析&#xff1a; 结论&#xff1a; import java.util.Arrays;class Person implements Comparable<Person>{public String name;public int age;public Person(String name, int age) {this.name name;this.age age;}Overridepublic Stri…

[保研/考研机试] KY11 二叉树遍历 清华大学复试上机题 C++实现

题目链接&#xff1a; 二叉树遍历_牛客题霸_牛客网编一个程序&#xff0c;读入用户输入的一串先序遍历字符串&#xff0c;根据此字符串建立一个二叉树&#xff08;以指针方式存储&#xff09;。题目来自【牛客题霸】https://www.nowcoder.com/share/jump/43719512169254700747…

机器学习笔记之优化算法(十五)Baillon Haddad Theorem简单认识

机器学习笔记之优化算法——Baillon Haddad Theorem简单认识 引言 Baillon Haddad Theorem \text{Baillon Haddad Theorem} Baillon Haddad Theorem简单认识证明过程证明&#xff1a;条件 1 ⇒ 1 \Rightarrow 1⇒ 条件 2 2 2证明&#xff1a;条件 3 ⇒ 3 \Rightarrow 3⇒条件 1…

css3+js 画出爱心特效

要使用CSS3和JavaScript绘制爱心特效&#xff0c;可以使用CSS3的动画和过渡效果来创建爱心的形状&#xff0c;并使用JavaScript来控制动画的触发和交互。以下是一个简单的示例代码&#xff1a; HTML: <div class"heart"></div> <button onclick&quo…

玩转单元测试之gmock

引言 前文我们学习了gtest相关的使用&#xff0c;单靠gtest&#xff0c;有些场景仍然无法进行测试&#xff0c;因此就诞生了gmock。 gmock快速入门 在引入gtest时&#xff0c;gmock也同样引入了&#xff0c;因此只需要在编译时加上合适的编译选项即可&#xff0c;注意不同版…

算法通关村十一关 | 位运算实现加法和乘法

1.位实现加法和乘法 在计算机中&#xff0c;位运算的效率要比加减乘除的效率更高&#xff0c;因此在高性能软件中源码中大量使用&#xff0c;计算机里各种运算基本上都是位运算。 学习下面内容之前建议先学习位运算规则&#xff1a;算法通关村十一关 | 位运算的规则_我爱学算…

【MaxKey对接一】对接gitlab的oauth登录

MaxKey的Oauth过程 引导进入 GET http://{{maxKey_host}}/sign/authz/oauth/v20/authorize?client_idYOUR_CLIENT_ID&response_typecode&redirect_uriYOUR_REGISTERED_REDIRECT_URI 登录后回调地址 YOUR_REGISTERED_REDIRECT_URI/?code{{code}} 换取Access Token GET…

winform使用usercontrol 构建了一个复杂的列表,列表速度慢该如何优化?

当使用 WinForms 构建复杂的列表时&#xff0c;可能会面临性能问题&#xff0c;特别是在数据量大或 UI 复杂的情况下。以下是一些优化策略&#xff0c;可以帮助您改善列表的性能&#xff1a; 1. **虚拟模式 (Virtual Mode)**&#xff1a;对于大型数据集&#xff0c;考虑使用虚…

「UG/NX」Block UI 曲线收集器CurveCollector

✨博客主页何曾参静谧的博客📌文章专栏「UG/NX」BlockUI集合📚全部专栏「UG/NX」NX二次开发「UG/NX」BlockUI集合「VS」Visual Studio「QT」QT5程序设计「C/C+&#

docker 01(初识docker)

一、docker概念 Docker是一个开源的应用容器引擎&#xff1b;诞生于2013年初&#xff0c;基于Go 语言实现&#xff0c;dotCloud公司出品(后改名为Dockerlnc);Docker 可以让开发者打包他们的应用以及依赖包到一个轻量级、可移植的容器中&#xff0c;然后发布到任何流行的Linux …

网络安全设备篇——加密机

加密机是一种专门用于数据加密和解密的网络安全设备。它通过使用密码学算法对数据进行加密&#xff0c;从而保护数据的机密性和完整性。加密机通常被用于保护敏感数据&#xff0c;如金融信息、个人身份信息等。 加密机的主要功能包括&#xff1a; 数据加密&#xff1a;加密机使…

探究Java spring中jdk代理和cglib代理!

面对新鲜事物&#xff0c;我们要先了解在去探索事物的本质-默 目录 一.介绍二者代理模式 1.1.Jdk代理模式 1.2cglib代理模式 1.3二者区别 1.3.1有无接口 1.3.2灵活性 1.4对于两种代理模式的总结 1.4.1jdk代理模式 1.4.2cglib代理模式 二.两种代理模式应用场景 2.1jd…

数学建模-多元线性回归笔记

数学建模笔记 1.学模型✅ 2.看专题论文并复习算法 多元线性回归 无偏性&#xff1a;预测值与真实值非常接近一致性&#xff1a;样本量无限增大&#xff0c;收敛于待估计参数的真值如何做&#xff1a;控制核心解释变量和u不相关 四类模型回归系数的解释 截距项不用考虑一元线性…

搜狗拼音占用了VSCode及微信小程序开发者工具快捷键Ctrl + Shit + K 搜狗拼音截图快捷键

修改搜狗拼音的快捷键 右键--更多设置--属性设置--按键--系统功能快捷键--系统功能快捷键设置--取消Ctrl Shit K的勾选--勾选截屏并设置为Ctrl Shit A 微信开发者工具设置快捷键 右键--Command Palette--删除行 微信开发者工具快捷键 删除行&#xff1a;Ctrl Shit K 或…

【开源项目】Stream-Query的入门使用和原理分析

前言 无意间发现了一个有趣的项目&#xff0c;Stream-Query。了解了一下其基本的功能&#xff0c;可以帮助开发者省去Mapper的编写。在开发中&#xff0c;我们会编写entity和mapper来完成业务代码&#xff0c;但是Stream-Query可以省去mapper&#xff0c;只写entity。 快速入…

CSDN编程题-每日一练(2023-08-22)

CSDN编程题-每日一练(2023-08-22) 一、题目名称:最长递增区间二、题目名称:K树三、题目名称:小Q的价值无向图一、题目名称:最长递增区间 时间限制:1000ms内存限制:256M 题目描述: 给一个无序数组,求最长递增的区间长度。如:[5,2,3,8,1,9] 最长区间 2,3,8 长度为 3。…

分布式事务理论基础

今天啊&#xff0c;本片博客我们一起来学习一下微服务中的一个重点和难点知识&#xff1a;分布式事务。 我们会基于Seata 这个框架来学习。 1、分布式事务问题 事务&#xff0c;我们应该比较了解&#xff0c;我们知道所有的事务&#xff0c;都必须要满足ACID的原则。也就是 …