消息队列MQ
1.解耦
2.异步
3.削峰/限流
当前使用较多的消息队列有RabbitMQ、RocketMQ、ActiveMQ、Kafka、ZeroMQ、MetaMq等,而部分数据库如Redis、Mysql以及phxsql也可实现消息队列的功能。
消费者怎么从消息队列里边得到数据?有两种办法:
- 生产者将数据放到消息队列中,消息队列有数据了,主动叫消费者去拿(俗称push)
- 消费者不断去轮训消息队列,看看有没有新的数据,如果有就消费(俗称pull)
/** * 发送信息到Kafka */ private void sendInfoToKafka(String key, JSONObject object){ this.kafkaTemplate.send(key, CTools.getUUID(),JSONObject.toJSONString(object, SerializerFeature.WriteMapNullValue)); }
com.igap.bsp.kafka.KafkaServiceProvider 63