java實現socket.io客戶端功能
基於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:[email protected]"> [email protected] </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:[email protected]"> [email protected] </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的使用 ,當時看了這位大佬的教程解決了問題