package com.iplatform.tcp.support; import com.walker.tcp.Connection; import com.walker.tcp.ConnectionCallback; import org.slf4j.Logger; import org.slf4j.LoggerFactory; /** * 测试 Tcp 或 Websocket 连接回调实现。 * @author 时克英 * @date 2023-08-26 */ public class TestConnectionCallback implements ConnectionCallback { private final transient Logger logger = LoggerFactory.getLogger(getClass()); @Override public void onIdle(Connection connection) { } @Override public void onAfterLogin(Connection connection) { logger.info("连接认证成功,已发送登录响应,这里可以直接再次发送业务消息。"); // String userId = connection.getName(); // // 用户是否,门户前端用户? // boolean isFrontUser = false; // if(isFrontUser){ // connection.write(Response); // } } }