netty-websocket-spring-boot-starter使用案例

netty-websocket-spring-boot-starter是一个基于Netty实现的WebSocket框架，可以方便地在Spring Boot应用中集成WebSocket功能。使用该框架可以快速构建实时通信、消息推送等功能。

下面是一个使用netty-websocket-spring-boot-starter的简单案例：

1. 在pom.xml中添加依赖：

<dependency>
    <groupId>com.github.wujiuye</groupId>
    <artifactId>netty-websocket-spring-boot-starter</artifactId>
    <version>1.0.0.RELEASE</version>
</dependency>

2. 编写WebSocket处理器

@ServerEndpoint("/websocket/{userId}")
@Component
public class WebSocketHandler {

    private static final Logger logger = LoggerFactory.getLogger(WebSocketHandler.class);

    private Session session;
    private String userId;

    @OnOpen
    public void onOpen(Session session, @PathParam("userId") String userId) {
        this.session = session;
        this.userId = userId;
        logger.info("WebSocket连接建立，userId: {}", userId);
    }

    @OnMessage
    public void onMessage(String message) {
        logger.info("收到来自客户端的消息：{}", message);
        sendMessage("服务端已收到消息：" + message);
    }

    @OnClose
    public void onClose() {
        logger.info("WebSocket连接关闭，userId: {}", userId);
    }

    @OnError
    public void onError(Throwable t) {
        logger.error("WebSocket连接异常，userId: {}", userId, t);
    }

    public void sendMessage(String message) {
        try {
            this.session.getBasicRemote().sendText(message);
        } catch (IOException e) {
            logger.error("发送WebSocket消息失败，userId: {}", userId, e);
        }
    }
}

3. 配置WebSocket

在配置类中添加@EnableWebSocket注解，启用WebSocket功能，同时，也可以配置WebSocket的一些参数，例如端口号、路径等。

@Configuration
@EnableWebSocket
public class WebSocketConfig implements WebSocketConfigurer {

    @Autowired
    private WebSocketHandler webSocketHandler;

    @Override
    public void registerWebSocketHandlers(WebSocketHandlerRegistry registry) {
        registry.addHandler(webSocketHandler, "/websocket/{userId}")
                .setAllowedOrigins("*");
    }
}

4. 测试WebSocket

使用浏览器或WebSocket客户端连接WebSocket服务端，例如：ws://localhost:8080/websocket/123，其中123为userId。

以上就是一个简单的netty-websocket-spring-boot-starter使用案例。