开发 WebSocket ,需要引入相关的 solon.boot 插件:

  • 或者 solon.boot.websocket (端口为:主端口 + 10000)
  • 或者 solon.boot.undertow
  • 或者 solon.boot.jetty + solon.boot.jetty.add.websocket

1、启用

public class DemoApp {
    public static void main(String[] args) {
        Solon.start(DemoApp.class, args, app->{
            //启用 WebSocket 服务
            app.enableWebSocket(true);
        });
    }
}

2、监听模式

以地址 ws://localhost:18080/ws/demo/12?token=xxx 为例:

@ServerEndpoint(path = "/ws/demo/{id}")
public class WebSocketServerImp implements Listener {
    @Override
    public void onOpen(Session session) {
        //path var
        String id = session.param("id") 
        //query var
        String token = session.param("token") 
        
        /*此处可以做签权;会话的二次组织等...*/
    }
    
    @Override
    public void onMessage(Session session, Message message) {
        //message.setHandled(true); //设为true,则不进入mvc路由
        
        session.send("我收到了:" + message);
    }
}

这个模式方便做会话的组织和收集,比如做聊天室,做应用推送等。

3、控制器模式

一般只适用于应答模式。比如Rpc开发,或者客户端定时刷新之类开发。

@Controller
public class WsDemoController {
    @WebSocket
    @Mapping("/ws/demo/{id}")
    public String demo(String id, String cmd) throws Exception {
        //id 为 path var;cmd 为 query var
        
        return "Hello world!";
    }
}

分类:

技术点:

相关文章: