Java编程Socket实现多个客户端连接同一个服务端代码
作者:大智若愚的小懂 发布时间:2023-12-27 05:32:11
标签:java,socket,客户端
Java Socket(套接字)通常也称作"套接字",用于描述IP地址和端口,是一个通信链的句柄。应用程序通常通过"套接字"向网络发出请求或者应答网络请求。
使用Socket实现多个客户端和同一客户端通讯;首先客户端连接服务端发送一条消息,服务端接收到消息后进行处理,完成后再回复客户端一条消息。本人通过自己的思维编写了一份服务端和客户端实现的代码,望能与大家相互学习,共同进步。
服务端代码
/**
* Socket服务端
* 功能说明:
*
*/
public class Server {
/**
* 入口
*
* @param args
* @throws IOException
*/
public static void main(String[] args) throws IOException {
// 为了简单起见,所有的异常信息都往外抛
int port = 8899;
// 定义一个ServiceSocket监听在端口8899上
ServerSocket server = new ServerSocket(port);
System.out.println("等待与客户端建立连接...");
while (true) {
// server尝试接收其他Socket的连接请求,server的accept方法是阻塞式的
Socket socket = server.accept();
/**
* 我们的服务端处理客户端的连接请求是同步进行的, 每次接收到来自客户端的连接请求后,
* 都要先跟当前的客户端通信完之后才能再处理下一个连接请求。 这在并发比较多的情况下会严重影响程序的性能,
* 为此,我们可以把它改为如下这种异步处理与客户端通信的方式
*/
// 每接收到一个Socket就建立一个新的线程来处理它
new Thread(new Task(socket)).start();
}
// server.close();
}
/**
* 处理Socket请求的线程类
*/
static class Task implements Runnable {
private Socket socket;
/**
* 构造函数
*/
public Task(Socket socket) {
this.socket = socket;
}
@Override
public void run() {
try {
handlerSocket();
}
catch (Exception e) {
e.printStackTrace();
}
}
/**
* 跟客户端Socket进行通信
*
* @throws IOException
*/
private void handlerSocket() throws Exception {
// 跟客户端建立好连接之后,我们就可以获取socket的InputStream,并从中读取客户端发过来的信息了
/**
* 在从Socket的InputStream中接收数据时,像上面那样一点点的读就太复杂了,
* 有时候我们就会换成使用BufferedReader来一次读一行
*
* BufferedReader的readLine方法是一次读一行的,这个方法是阻塞的,直到它读到了一行数据为止程序才会继续往下执行,
* 那么readLine什么时候才会读到一行呢?直到程序遇到了换行符或者是对应流的结束符readLine方法才会认为读到了一行,
* 才会结束其阻塞,让程序继续往下执行。
* 所以我们在使用BufferedReader的readLine读取数据的时候一定要记得在对应的输出流里面一定要写入换行符(
* 流结束之后会自动标记为结束,readLine可以识别),写入换行符之后一定记得如果输出流不是马上关闭的情况下记得flush一下,
* 这样数据才会真正的从缓冲区里面写入。
*/
BufferedReader br = new BufferedReader(
new InputStreamReader(socket.getInputStream(), "UTF-8"));
StringBuilder sb = new StringBuilder();
String temp;
int index;
while ((temp = br.readLine()) != null) {
if ((index = temp.indexOf("eof")) != -1) {
// 遇到eof时就结束接收
sb.append(temp.substring(0, index));
break;
}
sb.append(temp);
}
System.out.println("Form Cliect[port:" + socket.getPort()
+ "] 消息内容:" + sb.toString());
// 回应一下客户端
Writer writer = new OutputStreamWriter(socket.getOutputStream(),
"UTF-8");
writer.write(String.format("Hi,%d.天朗气清,惠风和畅!", socket.getPort()));
writer.flush();
writer.close();
System.out.println(
"To Cliect[port:" + socket.getPort() + "] 回复客户端的消息发送成功");
br.close();
socket.close();
}
}
}
客户端代码
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.io.Reader;
import java.io.Writer;
import java.net.Socket;
/** * Socket客户端
* 功能说明: * * @author 大智若愚的小懂 * @Date 2016年8月30日 * @version 1.0 */
public class Client {
/** * 入口 * @param args */
public static void main(String[] args) {
// 开启三个客户端,一个线程代表一个客户端
for (int i = 0; i < 3; i++) {
new Thread(new Runnable() {
@Override public void run() {
try {
TestClient client = TestClientFactory.createClient();
client.send(String.format("Hello,Server!I'm %d.这周末天气如何。", client.client.getLocalPort()));
client.receive();
}
catch (Exception e) {
e.printStackTrace();
}
}
}
).start();
}
}
/** * 生产测试客户端的工厂 */
static class TestClientFactory {
public static TestClient createClient() throws Exception {
return new TestClient("127.0.0.1", 8899);
}
}
/** * 测试客户端 */
static class TestClient {
/** * 构造函数 * @param host 要连接的服务端IP地址 * @param port 要连接的服务端对应的监听端口 * @throws Exception */
public TestClient(String host, int port) throws Exception {
// 与服务端建立连接
this.client = new Socket(host, port);
System.out.println("Cliect[port:" + client.getLocalPort() + "] 与服务端建立连接...");
}
private Socket client;
private Writer writer;
/** * 发送消息 * @param msg * @throws Exception */
public void send(String msg) throws Exception {
// 建立连接后就可以往服务端写数据了
if(writer == null) {
writer = new OutputStreamWriter(client.getOutputStream(), "UTF-8");
}
writer.write(msg);
writer.write("eof\n");
writer.flush();
// 写完后要记得flush
System.out.println("Cliect[port:" + client.getLocalPort() + "] 消息发送成功");
}
/** * 接收消息 * @throws Exception */
public void receive() throws Exception {
// 写完以后进行读操作
Reader reader = new InputStreamReader(client.getInputStream(), "UTF-8");
// 设置接收数据超时间为10秒
client.setSoTimeout(10*1000);
char[] chars = new char[64];
int len;
StringBuilder sb = new StringBuilder();
while ((len = reader.read(chars)) != -1) {
sb.append(new String(chars, 0, len));
}
System.out.println("Cliect[port:" + client.getLocalPort() + "] 消息收到了,内容:" + sb.toString());
reader.close();
// 关闭连接
writer.close();
client.close();
}
}
}
接下来模拟一下:
1.首先运行服务端
2.接着运行客户端(开三个客户端请求)
为了演示有所区分,服务端我使用的是Eclipse工具,客户端使用的是IntelliJ IDEA工具。这时可以看到客户端在控制台打印出来的消息
一个Port端口号代表一个客户端,回过来看下服务端在控制台打印出来的消息
来源:https://www.2cto.com/kf/201609/543865.html
0
投稿
猜你喜欢
- 本节作为主要讲解Spring Data的环境搭建JPA Spring Data :致力于减少数据访问层(DAO)的开发量。开发者唯一要做的就
- 本文实例讲述了C#异步调用的方法。分享给大家供大家参考。具体如下:using System;using System.Collections
- 这篇文章主要介绍了break在scala和java中的区别解析,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,
- 目录Map的computeIfAbsent使用场景和方法常规实现使用computeIfAbsent方法实现Map中computeIfAbse
- 本文实例为大家分享了android recyclerview模拟聊天界面的具体代码,供大家参考,具体内容如下效果图:实现代码:package
- 在Unity中实现简单的伪时间同步,只是读取数据库所在电脑的当前时间using UnityEngine;using System.Colle
- 废话不多说了,直接给大家贴代码,具体代码如下所示://菜单树形结构 public JSONArray treeMenuList(JSONAr
- 之前看过一句话,说的特别好。有人问阅读源码有什么用?学习别人实现某个功能的设计思路,提高自己的编程水平。是的,大家都实现一个功能,不同的人有
- 在实际工作中,重试重发请求处理是一个非常常见的场景,比如:1、发送消息失败。2、调用远程服务失败。3、争抢锁失败。这些错误可能是因为网络波动
- 前言我又搞回笃NET啦!java之路真是命运多舛,好事多磨。不过,也许我已经进入无招胜有招,博取众家之长、融会贯通的地步了。对于WebApi
- 本文实例为大家分享了Android ViewPager实现页面左右切换的具体代码,供大家参考,具体内容如下主界面viewpager.xml:
- 目录多通道分离API操作通道合并API操作结果源码多通道分离APIpublic static void split(Mat m, List&
- 一、项目运行环境配置:Jdk1.8 + Tomcat8.5 + Mysql + HBuilderX(Webstorm也行)+ Eclispe
- 1. 你知道volatile是如何保证可见性吗?我们先看一组代码:public class VolatileVisibleDemo { &n
- 本文实例为大家分享了java实现猜数字小游戏的具体代码,供大家参考,具体内容如下介绍:电脑随机生成一个1-100的随机数,用户输入一个数;电
- Java本身都是值传递式的调用,对于对象传递的是地址值。给地址值重新赋值等于重新指向,不会影响外层。而且这里Integer对象也有特殊性。其
- 里氏替换原则,OCP作为OO的高层原则,主张使用“抽象(Abstraction)”和“多态(Polymorphism)”将设计中的静态结构改
- Spring的注解@Qualifier小结近期在捯饬spring的注解,现将遇到的问题记录下来,以供遇到同样问题的童鞋解决~先说明下场景,代
- 本文实例为大家分享了java实现简易飞机大战的具体代码,供大家参考,具体内容如下整体思路1.创建游戏窗体,添加面板JPanel,重写JPan
- 需求: 给定一个URL地址, 例如: http://www.cncounter.com/tools/shorturl.php, 解析对应的I