10-11 使用RocketMQ解耦点赞通知功能，点赞->发MQ->收MQ->推送WS消息->弹出通知

src/main/java/io/github/yubincloud/fairywiki/rocketmq/VoteTopicConsumer.java

 package io.github.yubincloud.fairywiki.rocketmq;
 
+import io.github.yubincloud.fairywiki.websocket.WebSocketServer;
 import org.apache.rocketmq.common.message.MessageExt;
 import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
 import org.apache.rocketmq.spring.core.RocketMQListener;
@@ -7,15 +8,21 @@ import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.stereotype.Service;
 
+import javax.annotation.Resource;
+
 @Service
 @RocketMQMessageListener(consumerGroup = "default", topic = "VOTE_TOPIC")
 public class VoteTopicConsumer implements RocketMQListener<MessageExt> {
 
     private static final Logger LOG = LoggerFactory.getLogger(VoteTopicConsumer.class);
 
+    @Resource
+    private WebSocketServer webSocketServer;
+
     @Override
     public void onMessage(MessageExt messageExt) {
         byte[] body = messageExt.getBody();
         LOG.info("ROCKETMQ 收到消息：{}", new String(body));
+        webSocketServer.sendInfo(new String(body));
     }
 }
\ No newline at end of file