消息接入步骤

步骤一

定义远程调用Feign接口

@Component
@FeignClient(value = "message-service", configuration = FeignConfig.class)
public interface MessageFeignService {

    /**
     * 发送消息
     *
     * @param dto
     * @return
     */
    @PostMapping(value = "/openApi/sendInside")
    JsonResult sendInside(@Valid @RequestBody OpenApiMessageDTO dto);

}

步骤二

编写业务逻辑发送消息通知

public JsonResult sendMsg(){
            // 发送系统通知
            OpenApiMessageDTO msg = new OpenApiMessageDTO();
            msg.setMessageTitle("测试通知");
            msg.setMessageOrg("1");
            msg.setTags("测试通知");
            msg.setMessageType("1");
            List<String> userIds = userMapper.getAllUserIds();
            msg.setUserIds(userIds);
            // 站内信
            msg.setSendChannel("inMail");
            msg.setReceiveObject(userId);
            msg.setMessageContent("这是消息内容");
            try {
                // 远程调用消息服务发送消息
                messageFeignService.sendInside(msg);
                log.info("[通知管理]:发送系统消息成功,发送消息:{}",msg);
            }catch (Exception e){
                log.error("[通知管理]:发送系统消息失败,原因:",e);
            }
}

提示

不清楚相关参数配置，请移步这里