Solon v3.0.3

Socket.D 协议转为 Mvc 接口

</> markdown

此内容 v2.6.0 后支持

1、协议转换

我们基于 sd:ws 协议为例。引入依赖包： (如果是 sd:ws，也可以从 websocket 升级转换。参考：《WebSocket 协议转换为 Socket.D》 )

<!-- socket.d 的 solon 服务启动插件 -->
<dependency>
    <groupId>org.noear</groupId>
    <artifactId>solon-boot-socketd</artifactId>
</dependency>

<!-- 引用 sd:ws 协议传输包，它会使用独立的端口 -->
<dependency>
    <groupId>org.noear</groupId>
    <artifactId>socketd-transport-java-websocket</artifactId>
    <version>${socketd.version}</version>
</dependency>

尝试把 “应答场景” 的 /mvc/ 频道，转为 solon 控制器模式开发。（其它频道不受影响）

  • 通过 ToHandlerListener ，转换为 Solon Handler 接口。从而实现控制器模式开发（即支持 Mvc、Rpc 开发模式）
//协议转换处理
@ServerEndpoint("/mvc/")
public class SocketdAsMvc extends ToHandlerListener {
    @Override
    public void onOpen(Session s){
        //如果有需要，加个鉴权（如果不需要，去掉）
        if("a".equals(s.param("u")) == false){
            s.close(); return;
        }
        
        //这个一定要调
        super.onOpen();
    }
}

//控制器
@Controller
public class HelloController {
    @Socket //不加限定注解的话，可同时支持 http 请求
    @Mapping("/mvc/hello")
    public Result hello(long id, String name) { //{code:200,...}
        return Result.succeed();
    }
}

启动后端口是什么？可参考：《Sokcet.D 与 Solon 集成》

2、使用 Socket.D 进行客户端调用

  • 以 Java 原生接口方式示例

引入依赖包

<!--  提供 sd:ws 传输编解码支持（不同的传输协议，用不同的包） -->
<dependency>
    <groupId>org.noear</groupId>
    <artifactId>socketd-transport-java-websocket</artifactId>
    <version>${socketd.version}</version>
</dependency>

let clientSession = SocketD.createClient("sd:ws://localhost:28082/mvc/?u=a")
        .open();

let request = new StringEntity("{id:1,name:'noear'}").metaPut("Content-Type","text/json"),
let response = clientSession.sendAndRequest("/mvc/hello",  entity).await();

// event 相当于 http path（注意这个关系）
// data  相当于 http body
// meta  相当于 http header
  • 以 Java Rpc 代理模式示例

再多引入一个依赖包

<!--  提供 SocketdProxy 类 -->
<dependency>
    <groupId>org.noear</groupId>
    <artifactId>nami.channel.socketd</artifactId>
</dependency>

代码示例（以 rpc 代理的方式展示）

//[客户端] 调用 [服务端] 的 mvc
//
HelloService rpc = SocketdProxy.create("sd:ws://localhost:28082/mvc/?u=a", HelloService.class);

System.out.println("MVC result:: " + mvc.hello("noear"));

<script src="/js/socket.d.js"></script>

const clientSession = await SocketD.createClient("sd:ws://127.0.0.1:28082/mvc/?u=a")
        .open();

//添加用户（加个内容类型，方便与 Mvc 对接）
const entity = SocketD.newEntity("{id:1,name:'noear'}").metaPut("Content-Type","text/json"),
clientSession.sendAndRequest("/mvc/hello",  entity).thenReply(reply=>{
    alert(reply.dataAsString());
})

// event 相当于 http path（注意这个关系）
// data  相当于 http body
// meta  相当于 http header