生涯消息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、新增消息平台

新建立消息平台

1

2、在远程服务信息下新增对应的消息topic

消息平台下增加topic信息

1

添加topic配置所需字段

1

3、新建生涯事件,并选择消息服务平台里面接口topic,作为发送消息目标

1

配置生涯触发条件

2

选择发布消息,再选择对应的消息平台topic

3

进行测试

由上图可知,生涯触发方式为姓名发生变更,到用户管理去编辑用户,修改用户的姓名,则可以看到生涯事件被触发,观察topic消息,可以看到数据发过来。

1

©2020 锐捷网络股份有限公司 all right reserved,powered by Gitbook该文章修订时间: 2025-02-18 14:26:07

results matching ""

    No results matching ""