消息队列MQ

1.解耦

消息队列MQ

2.异步 

消息队列MQ

3.削峰/限流

消息队列MQ

当前使用较多的消息队列有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