Socket-io server java để chat realtime

thanghanu98 · December 22, 2020, 8:31am

Có anh nào từng làm phía server về vụ này mà sử dụng java chưa ạ? cho e hỏi nên dùng dependency nào? Nếu là bên dưới đây

thì làm sao để connect server, sử dụng các method để emit room chat … E chưa hiểu cách config hay connect ạ
E dùng spring để config
Nếu có thể, xin các anh hãy giảng flow cho e hiểu cách thức nó hoạt động!

Uni · December 22, 2020, 8:47am

Không đọc kỹ README của họ à bạn , rõ ràng họ có link doc đàng hoàng trong mà: https://socketio.github.io/engine.io-server-java/

Có hẳn cả mục cách config với Spring luôn kìa!

thanghanu98 · December 22, 2020, 8:57am

mấy cái đó ok mà, chỉ là cái đoạn server này đc init như nào hay config như nào đó.

library · December 23, 2020, 2:37am

Tip cho cậu: Muốn biết cách sử dụng 1 cái gì đó, ngoài doc thì cậu nên tìm tới test case.

Ví dụ:
Class dưới đây mô tả cách config EngineIoServer.

github.com

socketio/engine.io-server-java/blob/master/engine.io-server-test/src/test/java/io/socket/engineio/server/ServerWrapper.java

package io.socket.engineio.server;

import org.apache.commons.io.IOUtils;
import org.eclipse.jetty.http.pathmap.ServletPathSpec;
import org.eclipse.jetty.server.Handler;
import org.eclipse.jetty.server.Server;
import org.eclipse.jetty.server.handler.HandlerList;
import org.eclipse.jetty.servlet.ServletContextHandler;
import org.eclipse.jetty.servlet.ServletHolder;
import org.eclipse.jetty.util.log.Log;
import org.eclipse.jetty.util.log.Logger;
import org.eclipse.jetty.websocket.server.WebSocketUpgradeFilter;

import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletRequestWrapper;
import javax.servlet.http.HttpServletResponse;
import java.io.File;
import java.io.FileInputStream;

This file has been truncated. show original

Cách dùng:

github.com

socketio/engine.io-server-java/blob/master/engine.io-server-test/src/test/java/io/socket/engineio/server/WebSocketTest.java

package io.socket.engineio.server;

import io.socket.engineio.parser.Packet;
import org.junit.Test;

import static org.junit.Assert.assertEquals;

/**
 * Test server against JS client.
 */
@SuppressWarnings("Duplicates")
public final class WebSocketTest {

    @Test
    public void connectTest() throws Exception {
        ServerWrapper serverWrapper = new ServerWrapper();
        try {
            serverWrapper.startServer();
            assertEquals(0, Utils.executeScriptForResult("src/test/resources/testWebSocket_connect.js", serverWrapper.getPort()));
        } finally {

This file has been truncated. show original

Hope it helps!