1. 介绍
1.1 简介
WAMP,全称The Web Application Messaging Protocol,最初是在Websocket协议基础上的应用层协议标准,提供了下列功能:
- 1) RPC(Remote Procedure Calls)功能
- 2) Publish & Subscribe功能
1.2 支持语言
JS (Node & browser >= IE10)
Python
C++
Java
Objective-C
PHP
C#
注:跨语言,不同语言之间的库可以交互使用
1.3 功能介绍
1.3.1 RPC(Remote Procedure Calls)功能
RPC功能用于实现调用远程客户端注册的方法并返回方法值,调用过程对用户来说是透明的。
1.3.2 Publish & Subscribe功能
客户端通过主题发布消息,其余的客户端通过主题订阅消息。
2. 原理
2.1 术语
2.1.1. WAMP Client
用于实现RPC或Publish/Subscribe功能的客户端,参考图1和图2中水绿色的client模块。
客户端与WAMP Router相连,见下面
2.1.2 WAMP Router
担任Broker或Dealer的角色,所有客户端都连接到WAMP Router上,通过WAMP Router实现RPC或Publish/Subscribe功能。参考图1、图2中淡紫色的模块。
2.1.3 Realms
一个Realm相当于一个域或者命名空间,只有该Realm内的客户端才可以相互通讯,Realm之间相互隔离。
2.1.4 Sessions
一个Session指的是一个Client和Router之间的一次临时会话。
2.1.5 Transports
一个Transport适用于连接一个Client和Router的通讯,并提供一个channel,通过它进行消息的双向发送。显然Session是运行在Transport之上的。
默认Transport是WebSocket,除此之外还有Raw TCP、HTTP Long-polling等。
2.1.6 Roles
RPC功能包含的角色为:Caller(client1)、Callee(client2)、Dealer(router)
Publish & Subscribe功能包含的角色为:Publisher(client3)、Subscriber(client4和client5)、broker(router)。
注:一个客户端可以使用一种role或多种role的组合,本例子中一个客户端对应一个role。
2.1.7 标识符 Identifiers
根据图3可知,当RPC或者Publish & Subscribe的时候,必须提供方法名(procedure)或主题名(topic),统称为标识符(Identifer)。此外,标识符Identifer还包含错误名。
举例如下:
com.myapp.mytotopic1
com.myapp.myprocedure1
com.myapp.myerror1
为了避免命名冲突,采用java包名的命名规则,其中WAMP协议内部是以`wamp.`开头的命名方式,需要避免以此开头。系统内部标识符如下所示:
- wamp.error.not_authorized
- wamp.error.procedure_already_exists
2.2 消息机制
WAMP client端和router端的通讯方式均通过消息进行。
2.2.1 消息负载
消息负载支持List和Dictionary两种格式。
2.2.2 消息序列化
支持两种序列化方式:JSON和MsgPack
2.2.3 建立连接
客户端发送的HELLO消息体为:[HELLO.id, Realm|uri, Details|dict]
2.2.4 断开连接
2.2.5 Publish & Subscribe
2.2.6 RPC
3. 使用说明
因为WAMP的库比较多,有些库还在开发之中,bug可能会比较多,在以前的项目中也踩到了一些坑。
router推荐使用crossbar.io
client推荐使用autobahn,目前使用比较稳定
写过一个node-red的客户端的库,参见:https://flows.nodered.org/node/node-red-contrib-wamp
注:图3、图5、图6、图7、图8来自于网络,若侵删,谢谢