activemq与websocket结合无法向前台推送 10C

activemq接收到消息后,调用websocket的convertAndSend接口向前台发送消息,前台接收不到。但是通过在controller里面编写测试代码,调用convertAndSend进行发送,前台是可以接收到信息的。请问是怎么回事呢。
activemq的接收端代码:
@Service
public class CalculateQueueReceiver implements MessageListener {
@Autowired
private MessageSendMaster messageSendMaster;

@Override
public void onMessage(Message message) {
    ActiveMQBytesMessage bytesMessage = (ActiveMQBytesMessage) message;
    String s = new String(bytesMessage.getContent().getData());
    System.out.println(new Date() + s);
    messageSendMaster.sendMessage(s);
}

}
@Component
public class MessageSendMaster {
private static Logger logger = Logger.getLogger(MessageSendMaster.class);
@Autowired
private SimpMessagingTemplate template;

public void sendMessage(String  message){
    try {
        template.convertAndSend("/topic/calculate", message);
    } catch (Exception e) {
        logger.error(e.getMessage(), e);
        e.printStackTrace();
    }
}

}

1个回答

断点看一下 有没有报错 或者堵塞

Jennyleee
jennyleee 解决了吗朋友,我遇到同样的问题
接近 2 年之前 回复
wc936248
wc936248 发送消息的socket和接收消息的socket对象是同一个对象吗
2 年多之前 回复
Csdn user default icon
上传中...
上传图片
插入图片
抄袭、复制答案,以达到刷声望分或其他目的的行为,在CSDN问答是严格禁止的,一经发现立刻封号。是时候展现真正的技术了!
立即提问
相关内容推荐