サーバーインスタンス

サーバーの作成

Socket.IO サーバーを開始するには、次を作成します Configuration、バインドアドレスとポートを設定してからサーバーを起動します。

Configuration config = new Configuration();
config.setHostname("localhost");
config.setPort(9092);

SocketIOServer server = new SocketIOServer(config);

次のようなフレームワークを使用する場合 Spring Boot、次をインポートしていることを確認してください com.socketio4j.socketio.Configuration と同名のフレームワーククラス（例えば org.springframework.context.annotation.Configuration）ではなく、インポートの競合を避けるためです。

サーバーの起動

同期

server.start()

非同期

サーバーの停止

シャットダウン時は常にサーバーを正常に停止してください。

server.stop();

socketio4j はサーバー起動後にシャットダウンフックを追加しますが、特定のシナリオでは正常にサーバーを停止しますが、すべてではありません。サーバーを明示的に停止することを常に推奨します。

完全な例

Server.java

import com.socketio4j.socketio.Configuration;
import com.socketio4j.socketio.SocketIOServer;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

public class SocketIoServerMain {
    
    private static final Logger log = LoggerFactory.getLogger(SocketIoServerMain.class);
    
    public static void main(String[] args) throws Exception {
        // 設定を作成
        Configuration config = new Configuration();
        config.setHostname("localhost");
        config.setPort(9092);

        // サーバーを作成
        SocketIOServer server = new SocketIOServer(config);
        
        server.addConnectListener(client -> {
            log.info("[/] connected -> " + client.getSessionId());
        });
        server.addDisconnectListener(client -> {
            log.info("[/] disconnected -> " + client.getSessionId());
        });
        
        server.addEventListener("hi", String.class, (client, data, ack) -> {
            // クライアントで "reply" を監視
            log.info("received data : " + data);
            client.sendEvent("reply", "hello");
        });
        // サーバーを起動
        server.start();
        log.info("Socket.IO server started on port 9092");

        // JVM を維持
        Thread.currentThread().join();
    }
}

確認 イベント イベント処理に関するドキュメントについては

注意

• hostname は省略可能です。設定しない場合、サーバーはすべてのインターフェースにバインドされます（0.0.0.0 / ::0).

• port は サーバーを起動する前に設定する必要があります。

• スレッディング、トランスポート、およびその他の高度なオプションは、次を介してカスタマイズできます Configuration を呼び出す前に start().