Web消息通知

框架内部实现消息通知与推送机制，底层采用websocket和stomp协议实现，客户浏览器端中包括消息计数，消息列表，消息通知面板和消息列表及详情部分，相关效果如下图标红部分。服务器端message -support提供rest接口，允许系统或者客户推送消息给浏览器端，推送报文中含有推送人标识，如所有人则填*，是否需要存自身系统数据库（需要根据给定的sql脚本对自身数据库建表）做对应操作。然后消息根据报文简单处理后分别落入本地数据库及推送给浏览器客户端。

设计概述

涉及技术包括：html5 websocket及stomp协议，rabbitmq及stomp扩展插件，spring-message，spring-websocket，cxf(restful)，参考构件图活动图：

客户浏览器端初始化消息数据：读取系统数据库，初始化数据未读条数；
客户浏览器端发起让服务器端创建用户队列，指定time to live消息过期时间5分钟，queue length limit数量为11；
客户浏览器端监听通知消息：用户消息(wsuserid)；
监听到消息后计算消息数量，消息类型然后消息提示框提示消息信息；
发送消息：系统调用rest接口发送消息，消息对必输字段和合法性做基本校验（不合法返回给调用客户端错误信息），如果需要做对应系统存储，则存储对应系统；
校验合法的信息发送给名字为message的（type=topic）rabbitmq exchange ；
message 交换机根据routingkey路由到database_queue(#)队列和clientmessage（type=topic）(#.ws.user.#)) 交换机以及broadcastmsg(type=fanout)(#.ws.broadcast.#)交换机；
监听到database_queue队列消息后message-support存消息到本地数据库；
消息路由到clientmessage后根据routingkey（ws.[userid]）路由到ws_[userid]_queue
消息路由到broadcastcastmsg路由后，广播到到所有ws_[userid]_queue

路由详情参看如下图：

构件图如下：

接口调用

接口包括两部分，服务器端（用于展示消息）和客户端（用于发送消息），参见esb对接接口文档；

服务器端：

1.消息类型汇总计数 url:xxx/message/total 对应字段为

2.消息列表 url:xxx/message/list 对应字段为

3.消息设置已读 url:xxx/message/read 对应字段为

4.消息设置未读 url:xxx/message/unread 对应字段为

5.消息删除 url:xxx/message/delete 对应字段为

6.获取stomp连接信息。客户端：

① 发送单条消息 url:/xxx/message/sendto/{userId} 对应字段为

② 发送广播消息 url:/xxx/message/broadcast 对应字段为

使用方法

配置项修改

客户端对接需要引入message-support依赖，并配置mqconfig.properties队列路由信息，增加message路由队列如下。

# 多个mq时候需要配置queue.list,多个配置以“,”分割，如queue.list=message,XXX
queue.list=message
# 消息队列broker的地址.用,分割
message.queue.addresses=
# 消息队列上的虚拟主机标识
message.queue.vhost=
# 连接时的用户名
message.queue.username=
# 连接时的密码
message.queue.password=
mq.message.prefix=message
mq.message.qos=2
# stomp端口
mq.message.port=15674
# 队列前缀标识
mq.message.test.id=test

配置 xxx.properties，配置消息队列前缀标识
```
maven.mq.message.test.id=test
```

服务发布

server端发布具体发布代码如下：

<jaxrs:server beanNames="simpleMessageInfoService" address="/${ws.protocol.rest.path}/simpleMessageInfoService">
    <jaxrs:providers>
        <bean class="com.halo.core.fastjson.support.FastJsonProvider"/>
    </jaxrs:providers>
</jaxrs:server>
<!-- database queue服务处理 -->
<bean id="messageDataDBService" class="com.newcore.supports.service.impl.server.MessageDataDBServiceImpl"></bean>
<!-- 配置服务器中广播级别消息推送队列和发送对应的exchange -->
<bean class="com.newcore.supports.service.impl.server.MessageInitFactoryImpl"></bean>
<bean id="messageCenterService" class="com.newcore.supports.service.impl.server.MessageCenterServiceImpl"></bean>
<!-- 发布cxf的restfulService-->
<jaxrs:server beanNames="messageCenterService" address="/${ws.protocol.rest.path}/messageCenterService">
    <jaxrs:providers>
        <bean class="com.halo.core.fastjson.support.FastJsonProvider"/>
    </jaxrs:providers>
</jaxrs:server>

client端发布具体发布代码如下：

<!--RESTFul WebService客户端注册 -->
<jaxrs-client:client id="simpleMessageInfoService" serviceClass="com.newcore.supports.service.api.client.SimpleMessageInfoService" address="http://${ws.client.ipbps.address}/${ws.protocol.rest.path}/simpleMessageInfoService">
    <jaxrs-client:providers>
        <bean class="com.halo.core.fastjson.support.FastJsonProvider"/>
    </jaxrs-client:providers>
</jaxrs-client:client>

<!--RESTFul WebService客户端注册 -->
<jaxrs-client:client id="messageCenterService" serviceClass="com.newcore.supports.service.api.server.MessageCenterService" address="http://${ws.client.ipbps.address}/${ws.protocol.rest.path}/messageCenterService">
    <jaxrs-client:providers>
        <bean class="com.halo.core.fastjson.support.FastJsonProvider"/>
    </jaxrs-client:providers>
</jaxrs-client:client>

客户端对接消息

客户端可以直接调用柜面系统的接口，发送消息（不能存本地数据库），消息只能存入柜面数据库（这种方式自身不用任何配置，也不需要引用message-support）；
示例：
参见example下/example-web-app/src/main/webapp/example/message/js/message.js
客户端引用message-support包，页面调用对应发送消息的controller；
示例：
参见example下/example-web-app/src/main/webapp/example/sendmsg/js/message.js
客户端引用message-support包，service-app中把发送消息作为普通service直接调用接口；
示例：
参见support下/message-support/src/test/java/com/newcore/test/service/ TestSendMessage.java
客户端引用message-support包，service-app中把发送消息作为web-service调用接口；

Previouskafka 支持 Next认证与授权

Last updated 6 years ago