生涯消息RocketMq、Kafka
生涯消息和生涯事件远程API类似,不仅可以调用API,还可以发消息,目前支持的消息类型有RocketMq和Kafka,此外还可以扩展开发支持其他消息队列MQ。 生涯事件定义触发后的行为,可以将用户数据发送消息到服务器对应的topic上。
对接步骤
1、提供RocketMq服务地址和Topic名字,acl的accessKey和secretKey。如果是Kafka,则需要SASL_PLAINTEXT方式下的username和password。对应生涯的消息平台的AppID和SecretID。
2、新建对应的生涯事件和消息平台,设置生涯事件对应的topic信息。
3、进行测试,触发对应的生涯规则(如用户信息变化,依据规则配置),生涯会自动发送对应topic消息。
标准MQ消息格式
定义的Topic格式如下,根据标准的字段名可以动态添加,参数支持标准定义,可以根据实际需要自由选取和自定义参数名字。
参数 | 类型 | 必须 | 说明 |
---|---|---|---|
metaData | object | true | 字段信息定义 |
└─operationType | string | true | 操作类型有insert(添加) 、delete(删除)、update(更新),表示用户是否修改添加和删除 |
└─XM | string | true | 姓名 |
└─SFZJLXM | string | true | 身份证件类型中文名称 |
└─SFLBDM | string | true | 身份类别码中文名称 |
└─IDCARD | string | true | 身份证件号中文名称 |
└─RYZT | string | true | 人员状态中文名称 |
└─XB | string | true | 性别中文名称 |
└─YGZT | string | true | 员工状态中文名称 |
└─CSRQ | string | true | 出生日期中文名称 |
└─...... | string | true | 更多标准字段中文名称 |
userInfo | object | true | 用户信息 |
└─XM | string | true | 姓名 |
└─SFZJLXM | string | true | 身份证件类型 |
└─SFLBDM | string | true | 身份类别码 |
└─IDCARD | string | true | 身份证件号 |
└─RYZT | string | true | 人员状态 |
└─XB | string | true | 性别 |
└─YGZT | string | true | 员工状态 |
└─CSRQ | string | true | 出生日期 |
└─...... | string | true | 更多标准字段(可从页面配置添加) |
{
"metaData":{
"operationType":"insert"
"XM":"姓名",
"GJ":"国籍",
"RYZT":"人员状态",
"XB":"性别",
"YGZT":"员工状态",
"CSRQ:"出生日期",
"SFZJLXM":"身份证件类型",
},
"userInfo": {
"XM":"老汪",
"IDCARD":"411381202106040017",
"RYZT":"01",
"XB":"1",
"YGZT":"08",
"CSRQ:"1996-02-04",
"SFZJLXM":"居民身份证",
...
}
}
生涯配置如下
1、新增消息平台
新建立消息平台
2、在远程服务信息下新增对应的消息topic
消息平台下增加topic信息
添加topic配置所需字段
3、新建生涯事件,并选择消息服务平台里面接口topic,作为发送消息目标
配置生涯触发条件
选择发布消息,再选择对应的消息平台topic
进行测试
由上图可知,生涯触发方式为姓名发生变更,到用户管理去编辑用户,修改用户的姓名,则可以看到生涯事件被触发,观察topic消息,可以看到数据发过来。