事件没有触发？在服务器上使用 java socket.io 客户端和 netty-socketio答案

【问题标题】：Events not firing? Using java socket.io client & netty-socketio on server事件没有触发？在服务器上使用 java socket.io 客户端和 netty-socketio
【发布时间】：2023-03-17 02:07:01
【问题描述】：

我知道客户端和服务器正在连接，因为我的连接/断开连接事件正在触发。但是，我的自定义事件不是。我在服务器上使用 socket.io java 客户端和 netty-socketio。我通常使用无缝工作的 socket.io javascript 库，所以我对为什么会发生这种情况有点迷茫。我正在用 Kotlin 写这篇文章。

客户端

fun connectToServer(ipAddress : String)
    {
        socket = IO.socket("$ipAddress")

        socket!!.on(Socket.EVENT_CONNECT) {  obj ->


            println("Connected To Server!!!")

        }.on(EventNames.signOn) { obj ->

            println(EventNames.signOn)
            //cast value to string from server, hope for encrypted password
            val encryptedPassword = obj[0] as String


            when(encryptedPassword)
            {
                "no user" -> {

                }

                else -> {

                    val result = encryptedPassword!!.split("OR")
                    val isMatch = passwordTextField.text == dataProcessing.Encryption3().decryptValue("decrypt", result[0],result[1])

                    if(isMatch)
                    {

                    }
                }
            }

            println("Encrypted Password: "+encryptedPassword)
        }

//        socket!!.on(Socket.EVENT_DISCONNECT, object : Emitter.Listener {
//
//            override fun call(vararg args: Any) {}
//
//        })


        socket!!.connect()
//        socket!!.open()

//        socket!!.emit(Socket.EVENT_CONNECT, "Hello!")


        socket!!.send("hey")
       socket!!.emit(EventNames.requestClientSignOn, usernameTextField.text)

    }

服务器端

@Throws(InterruptedException::class, UnsupportedEncodingException::class)

    fun server()
    {
        val config = Configuration()
        config.setHostname("localhost")
        config.setPort(PORT)
        server = SocketIOServer(config)

        server!!.addConnectListener {
            println("Hello World!")
        }


            server!!.addEventListener(EventNames.requestClientSignOn, String::class.java) { client, data, ackRequest ->

               println("Hello from  requestClientSignOn..")

        }
        server!!.addDisconnectListener {

                    println("Client Disconnecting...")

        }

        server!!.addConnectListener {

            println("client connected!! client: $it")
        }

        server!!.start()

【问题讨论】：

标签： socket.io socket.io-java-client netty-socketio

【解决方案1】：

你不能在你的事件监听器中使用 lambda 表达式，在服务器上使用 netty-socketio。

使用传统的 EventListener 解决了这个问题。我还将服务器转换为 Kotlin，因为使用演示项目作为参考更容易。

server.addEventListener(EventNames.requestClientSignOn, String.class, new DataListener<String>() {


            @Override
            public void onData(SocketIOClient client, String username, AckRequest ackRequest) {


                String isEncryptedPassword = new KOTS_EmployeeManager().getKOTS_User(KOTS_EmployeeManager.kotsUserType.CLIENT, username)

                if(isEncryptedPassword != null)
                {
                    //send back ack with encrypted password
                    ackRequest.sendAckData(isEncryptedPassword);

                }else{
                    //send back ack with no user string
                    ackRequest.sendAckData("no user");
                }
            }

        });

【讨论】：