给公众号和APP发送消息时用消息队列来发送好处：
1.保证消息的有序性,就是能确保消息是有序的。
2.保证消息可靠性，能确保消息准确的传输。
3.保证消息不被重复消费。
这个流程主要是用来订阅主题。
//先定义一个接口
public interface pushService{
void push（String top,String message);
}
//定义一个实现类实现该接口
public class pushServiceImpl implements push{
@Autowired
private RedisTemplate redisTemplate;
@Override
public void push(String topic,String message) {
logger.info("发布消息：{}", message);
//调用redis模板的API这个方法是通道的方法，top可以创建个枚举类来存放
redisTemplate.convertAndSend(topic,message);
}
}
//
消费主题则是用到redis监听器，然后用监听器转发给消费者消费。
//写个redis监听器方法继承监听器消息方法
public interface redisListener extends MessageListener{
String getTopic();
}
//在写个监听器实现类
@Component
public class redisListener implements redisListener {
@Autowired
private RedisTemplate redisTemplate;
@Override
public void onMessage(final Message message, final byte[] pattern ) {
logger.info("监听器---------------------------------");
RedisSerializer serializer = redisTemplate.getValueSerializer();
String text = serializer.deserialize(message.getBody()).toString();
Gson gson = new Gson();
//这里主要利用gson把test属性反射到A类中。
A a= gson.fromJson(text, A.class);
}
}
}
// JSONObject json = new JSONObject();
// json.put("a",a);
// json.put("b",b);
// json.put("c",c);
// json.put("d",d);
// json.put("e",e);
//test是生产者调用push方法订阅redis（top，json.toString()）存的消息
