Broker模块¶

本节介绍WeEvent的子模块Broker的详细安装步骤。快速安装请参见WeEvent快速安装。在一台机器上详细安装，和通过快速安装然后把目标路径中的broker子目录打包拷贝到这台机器，效果是一样的。

Broker是WeEvent的核心子模块，负责事件的发布订阅以及对区块链FISCO-BCOS的访问。支持RESTful、JsonRPC、STOMP、MQTT多种接入协议，也提供了Java SDK。

如果是第一次安装WeEvent，参见这里的系统要求。以下安装以CentOS 7.2为例。

前置条件¶

Zookeeper服务

必选配置。服务注册和发现会使用到。

推荐使用Zookeeper 3.5.5版本。具体安装步骤，请参见Zookeeper安装。
区块链FISCO-BCOS节点

必选配置。Broker通过区块链FISCO-BCOS持久化数据。

推荐使用FISCO-BCOS 2.1.0版本。具体安装步骤，请参见FISCO-BCOS 2.1.0安装。
Redis缓存

可选配置。

推荐使用Redis 5.0+版本。具体安装步骤，请参见Redis安装。

获取安装包¶

从github下载安装包weevent-broker-1.1.0.tar.gz，并且解压到/usr/local/weevent/下。

$ cd /usr/local/weevent/
$ wget https://github.com/WeBankFinTech/WeEvent/releases/download/v1.1.0/weevent-broker-1.1.0.tar.gz
$ tar -zxf weevent-broker-1.1.0.tar.gz

如果github下载速度慢，可以尝试国内下载链接。

解压后的目录如下：

$ cd ./weevent-broker-1.1.0
$ tree  -L 1
|-- apps
|-- broker.sh
|-- check-service.sh
|-- conf
|-- deploy-fabric-topic-control.sh
|-- deploy-topic-control.sh
|-- gen-cert-key.sh
`-- lib

修改配置文件¶

配置Zookeeper服务

可选配置。./conf/application-prod.properties中spring.cloud.zookeeper配置项。

# spring cloud zookeeper
spring.cloud.zookeeper.enabled=true
spring.cloud.zookeeper.connect-string=127.0.0.1:2181

区块链FISCO-BCOS节点
- 区块链节点配置文件fisco.properties
  
  修改nodes=127.0.0.1:20200配置项，nodes为区块链节点channel访问入口。
- 访问节点的证书文件
  
  2.0版本的证书文件ca.crt、node.crt、node.key放在./conf/v2目录下。
  
  1.3版本的证书文件ca.crt、client.keystore放在./conf目录下。
  
  证书文件生成及获取请参见FISCO-BCOS 2.0安装

部署系统合约

运行脚本./deploy-topic-control.sh部署合约。例如:

  $ ./deploy-topic-control.sh
    2019-08-19 17:59:31 topic control address in every group:
    1	0xc6fc72f0fe6ebf9881a2103f2829d0e98d020062	[new]
    2	0xd85d3345f8a21f4fd6197c72266ae3e3106e5e1c	[new]

脚本会检查之前是否部署过合约，重复执行不影响。

配置Broker监听端口

可选配置。./conf/application-prod.properties中server.port配置项，默认监听端口7000，根据业务需要配置。

配置Redis缓存

可选配置。./conf/application-prod.properties中spring.redis.*配置项，配置缓存可以提高WeEvent的通知性能。

# redis数据库索引（默认为0）
spring.redis.database=0
# redis服务访问链接
spring.redis.host=${ip}
# redis服务访问端口
spring.redis.port=${port}
# redis服务访问密码 为了安全，必须使用密码访问
spring.redis.password=${password}
# 连接超时时间（毫秒）
spring.redis.timeout=5000

可选配置。./conf/weevent.properties中基于内存的缓存配置项

# 基于内存的缓存容量，当缓存数据大于这个值时，使用LRU淘汰策略
lru.cache.capacity=65536

配置IP白名单

可选配置。./conf/weevent.properties中配置了值就会开启白名单验证。
```
# 配置ip白名单,多个ip使用分号分割 示例:127.0.0.1;127.0.0.2
ip.check.white-table=${ip}
```
ip.check.white-table默认为空，允许任何客户端IP访问。
配置STOMP

可选配置。./conf/weevent.properties中stomp.*配置项。
```
# 发送心跳时间间隔 单位:秒
stomp.heartbeats=30
```

配置MQTT Broker

可选配置。配置文件./conf/weevent.properties中mqtt.*配置项。

# 客户端使用WebSocket协议访问MQTT Broker端口
mqtt.broker.port=7001
# 心跳时间 单位:秒
mqtt.broker.keepalive=60
# 客户端使用WebSocket协议访问MQTT Broker链接
mqtt.websocket.path=/weevent/mqtt

更多系统详细配置参见配置说明

服务启停¶

启动服务

通过./broker.sh start命令启动服务，正常启动如下：
```
$ ./broker.sh start
start broker success (PID=89054)
add the crontab job success
```
通过./broker.sh stop命令停止服务。

进程启动后，会自动加入集群，同时添加crontab监控任务./broker.sh monitor。
验证服务

通过./check-service.sh 命令检查服务功能是否正常。
```
$ ./check-service.sh
check broker service
broker service is ok
```