20 lines
611 B
Java
20 lines
611 B
Java
package com.simulationservice.mapper;
|
|
|
|
import org.springframework.data.redis.connection.Message;
|
|
import org.springframework.data.redis.connection.MessageListener;
|
|
import org.springframework.stereotype.Component;
|
|
|
|
@Component
|
|
public class RedisSubscribe implements MessageListener {
|
|
|
|
@Override
|
|
public void onMessage(Message message, byte[] pattern) {
|
|
//消息体
|
|
String body = new String(message.getBody());
|
|
//渠道名称
|
|
String topic = new String(pattern);
|
|
System.out.println("消息体：" + body);
|
|
System.out.println("主题名称：" + topic);
|
|
}
|
|
}
|