Broker模块¶

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

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

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

前置条件¶

区块链FISCO-BCOS节点

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

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

可选配置。

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

可选配置。当使用了JsonRPC或者RESTful协议的订阅功能起来Zookeeper主备切换。

推荐使用Zookeeper 3.5.5版本。具体安装步骤，请参见Zookeeper安装。

获取安装包¶

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

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

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

解压后的目录如下：

$ cd ./weevent-broker-1.0.0
$ tree  -L 2
|-- apps
|   `-- weevent-broker-1.0.0.jar
|-- broker.sh
|-- check-service.sh
|-- conf
|   |-- v2
|   |-- application-prod.properties
|   |-- application.properties
|   |-- banner.txt
|   |-- ca.crt
|   |-- client.keystore
|   |-- fisco.properties
|   |-- log4j2.xml
|   |-- server.p12
|   `-- weevent.properties
|-- deploy-topic-control.sh

修改配置文件¶

区块链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 1
deploy contract[TopicController] success, address: 0xd99253697e61bf19206ceb4704fc9914d0a4116c
```
- 修改配置文件
  
  在配置文件./conf/fisco.properties中，替换为生成的合约地址。例如：
```
  topic-controller.address=1:0xd99253697e61bf19206ceb4704fc9914d0a4116c;
```
  1.3版本的合约地址设置如下:
```
  topic-controller.address=0xd99253697e61bf19206ceb4704fc9914d0a4116c
```
  更多关于群组和合约部署的细节，请参考多群组。
- 注意
  
  每条区块链只需要部署一次合约。当重新部署使用新的合约时，相当于切换了数据视图，原来合约地址关联的数据都无法继续访问（除非切回原合约地址）。
配置Broker监听端口

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

配置Redis缓存

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

# redis服务访问链接
redis.server.ip=${ip}
# redis服务访问端口
redis.server.port=${port}
# redis服务访问密码 为了安全，必须使用密码访问
redis.server.password=${password}
# 基于redis的broker进程缓存容量，当缓存数据大于这个值时，使用LRU淘汰策略
lru.cache.capacity=65536

配置Zookeeper服务

配置文件./conf/weevent.properties中broker.zookeeper.*配置项。

# zookeeper服务访问链接 示例：127.0.0.1:8080
broker.zookeeper.ip=${ip}:${port}
# zookeeper上数据存储路径
broker.zookeeper.path=/event_broker
# 连接zookeeper超时时间 单位：毫秒
broker.zookeeper.timeout=3000

配置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协议访问用户名
stomp.user.login=${username}
# stomp协议访问密码
stomp.user.passcode=${password}
# 发送心跳时间间隔 单位:秒
stomp.heartbeats=30

配置MQTT Broker

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

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

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

服务启停¶

启动服务

通过./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
```

加入Nginx反向代理¶

将部署好的Broker配置到Nginx提供对外服务。Nginx子模块的安装及详细配置参见Nginx模块安装及配置。

如需部署其更多实例，将上述步骤安装好的Broker目录拷贝到目标位置，启动即可。