业务服务向mq/websocket服务推送数据

//RabbitMQ消息队列
implementation 'org.springframework.boot:spring-boot-starter-amqp'

@RefreshScope
@Component
public class MQUtil {

    @Autowired
    private RabbitTemplate rabbitTemplate;

    public void send(Msg msg, String queueName) throws Exception {
        String jsonString = JSONUtil.toJSONString(msg);// 实体转换JSON字符串
        rabbitTemplate.convertAndSend(queueName, jsonString);// 向队列发送数据
    }
}

// ===============================发送站内消息===============================
Map<String, Object> sendMap = ObjectToMap.objectToMap(task);// 将实体转map对象
sendMap.put("createTime", LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));// 创建时间
JSONObject jsonObject = new JSONObject(sendMap);// 将Map对象转换为JSONObject
String jsonString = jsonObject.toString();// 将JSONObject转换为JSON字符串
/**
 * 推送当前审批层级人员提醒通知 CompletableFuture异步发送消息
 */
CompletableFuture<Void> future = CompletableFuture.runAsync(() -> {
    try {
        Msg msg = new Msg();
        msg.setType(8);// 推送待办已处理通知
        msg.setSendMethod(1);// 单发
        msg.setSendFormat(2);// 发送格式（2：json字符串）
        msg.setMessage(jsonString);// 发送内容
        msg.setToSid(taskNode.getUserId().toString());// 发送给PC端
        mQUtil.send(msg);// 推送用户
        msg.setToSid(taskNode.getUserId().toString()+"-PAD");// 发送给PAD端
        mQUtil.send(msg);// 推送用户
    } catch (Exception e) {
        log.error("推送待办已处理通知异常：{}", e);
    }
});
// ===============================发送站内消息===============================

private Integer sendMethod;// 发送方式（1：单发；2：群发）
private String toSid;// 接收者ID
private Integer type;// 发送类别（详见6）
private Integer sendFormat;// 发送格式（1：文本；2：JSON字符串）
private String message;// 消息内容（sendFormat=1时，前端、C/S端提示此内容；sendFormat=2时前端、C/S端解析消息内容处理）