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: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();
        }
    }
}

流程：

1. 啓動client會建立scoket,並將uri,options等參數set進去
2. 監聽一些事件（可自定義），也就是將event爲key，回調爲value，put 進callbacks(其爲ConcurrentMap)
3. connect 主動鏈接
4. 當鏈接成功時候會觸發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的使用，當時看了這位大佬的教程解決了問題