共计 4229 个字符,预计需要花费 11 分钟才能阅读完成。
基于 java 做一个 socket.io 客户端
前言
最近公司这边让我去订阅一个第三方机构的 websocket server,也是头疼,免不了和对方各种沟通,大家都很忙,收到回复很慢,开发方向也不知道。先是做了一个普通 websocket 的客户端,但后面了解到对方是基于 socket.io 做的一个 server,又重新做了一个基于 socket.io-client-java 开源库的客户端。涉及到公司商业机密,所以做了一个 demo,转自 https://blog.csdn.net/q56231293811/article/details/84873776
<!–more–>
1. Client(Socket.IO Client Library for Java)
先上代码
package com.dasnnj.practice.share.socket;
import io.socket.client.IO;
import io.socket.client.Socket;
import java.util.Arrays;
/**
* Description <P> TODO : socket.io client 端 <P>
*
* @author DASNNJ <a href="mailto:dasnnj@outlook.com"> dasnnj@outlook.com </a>
* @date 2019-04-27 18:32
*/
public class Client {public static void main(String[] args) {
String url = "http://localhost:9999";
try {IO.Options options = new IO.Options();
options.transports = new String[]{"websocket"};
// 失败重试次数
options.reconnectionAttempts = 10;
// 失败重连的时间间隔
options.reconnectionDelay = 1000;
// 连接超时时间(ms)
options.timeout = 500;
final Socket socket = IO.socket(url, options);
// 监听自定义 msg 事件
socket.on("msg", objects -> System.out.println("client: 收到 msg->" + Arrays.toString(objects)));
// 监听自定义订阅事件
socket.on("sub", objects -> System.out.println("client:" + "订阅成功,收到反馈 ->" + Arrays.toString(objects)));
socket.on(Socket.EVENT_CONNECT, objects -> {socket.emit("sub", "我是訂閲對象");
System.out.println("client:" + "连接成功");
});
socket.on(Socket.EVENT_CONNECTING, objects -> System.out.println("client:" + "连接中"));
socket.on(Socket.EVENT_CONNECT_TIMEOUT, objects -> System.out.println("client:" + "连接超时"));
socket.on(Socket.EVENT_CONNECT_ERROR, objects -> System.out.println("client:" + "连接失败"));
socket.connect();} catch (Exception ex) {ex.printStackTrace();
}
}
}
流程:
- 启动 client 会创建 scoket, 并将 uri,options 等参数 set 进去
- 监听一些事件(可自定义),也就是将 event 为 key,回调为 value,put 进 callbacks(其为 ConcurrentMap)
- connect 主动连接
- 当连接成功时候会触发
Socket.EVENT_CONNECT
事件,执行了socket.emit("sub", "我是訂閲對象");
订阅操作
2. Server(Socket.IO 服务器的开源 Java 实现。基于 Netty 服务器框架。)
这边 server 只监听了 sub 事件(server 监听 client emit(提交)的 sub 事件, 而 client 监听的是 server emit(反馈)的 sub 事件)和断开连接事件,并循环发送广播消息(smg 事件)
package com.dasnnj.practice.share.socket;
import com.corundumstudio.socketio.Configuration;
import com.corundumstudio.socketio.SocketIOServer;
import java.util.Map;
/**
* Description <P> TODO : socket.io server 端 <P>
*
* @author DASNNJ <a href="mailto:dasnnj@outlook.com"> dasnnj@outlook.com </a>
* @date 2019-04-27 18:31
*/
public class Server {public static void main(String[] args) {Configuration config = new Configuration();
config.setHostname("localhost");
config.setPort(9999);
SocketIOServer server = new SocketIOServer(config);
server.addConnectListener(client -> {System.out.println("server:" + client.getRemoteAddress() + "客户端连接成功");
});
// 添加 sub 事件
server.addEventListener("sub", String.class, (client, data, ackRequest) -> {String c= client.getRemoteAddress().toString();
// 获取客户端 url 参数
Map params = client.getHandshakeData().getUrlParams();
System.out.println("server:" + c+ ":客户端:订阅成功,订阅信息為 ->" + data);
//sub 事件成功反馈
client.sendEvent("sub", c+ "客户端你好,我是服务端,你订阅成功了");
});
// 添加客户端断开连接事件
server.addDisconnectListener(client -> {String c= client.getRemoteAddress().toString();
// 获取设备 ip
String clientIp = c.substring(1, c.indexOf(":"));
System.out.println("server:" + clientIp + "-------------------------" + "客户端已断开连接");
});
server.start();
int i = 0;
while (true) {
try {Thread.sleep(1500);
// 广播消息
i++;
server.getBroadcastOperations().sendEvent("msg", "30", "hello" + i, "false");
} catch (InterruptedException e) {e.printStackTrace();
}
}
}
}
3. pom.xml
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<groupId>com.dasnnj.practice</groupId>
<artifactId>practice</artifactId>
<version>1.0-SNAPSHOT</version>
<build>
<plugins>
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-compiler-plugin</artifactId>
<configuration>
<source>8</source>
<target>8</target>
</configuration>
</plugin>
</plugins>
</build>
<dependencies>
<dependency>
<groupId>io.socket</groupId>
<artifactId>socket.io-client</artifactId>
<version>1.0.0</version>
</dependency>
<dependency>
<groupId>com.corundumstudio.socketio</groupId>
<artifactId>netty-socketio</artifactId>
<version>1.7.16</version>
</dependency>
<dependency>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-nop</artifactId>
<version>1.7.2</version>
</dependency>
</dependencies>
</project>
4. 再次感谢
转自 java netty-socketio 与 io.socket 的使用,当时看了这位大佬的教程解决了问题
正文完