rabbitMQrocketMQkafka三大消息中间件的区别及简单使用

Posted 2021-08-27 道祖且长

在我的工作生涯中，基本上真正使用过的MQ只有RabbitMQ，像kafka是看视频学过，然后现在基本忘干净了，roketMQ也是现在才开始学，所以先总结一下三大MQ的区别和优缺点，复习一下rabbitMQ和kafka吧。

区别

通过上图，可以发现什么呢？

1、如果是大数据的环境下，那直接选择kafka没毛病，这一点大家包括我应该都是不需要多考虑
2、如果是在非大数据的情况下，使用rocketMQ最好。

其一，在技术上，因为我们是Java开发工程师，天然就更加亲近使用Java开发的roketMQ，也许使用起来没什么感觉，但是到了后期，工作3-5年后，技术增长已经陷入了瓶颈，就必须去研究各种框架、中间件的源码，那时就会发现roketMQ的好了。
其二，rocketMQ功能全面，适用几乎全场景，rabbitMQ之所以还有生存空间，只是由于其先行发布，影响力广，社区完整度高，在Java方向，以后基本上是rocketMQ的天下。

rocketMQ主要优势特性有：
• 支持事务型消息（消息发送和DB操作保持两方的最终一致性，rabbitmq和kafka不支持）
• 支持结合rocketmq的多个系统之间数据最终一致性（多方事务，二方事务是前提）
• 支持18个级别的延迟消息（rabbitmq和kafka不支持）
• 支持指定次数和时间间隔的失败消息重发（kafka不支持，rabbitmq需要手动确认）
• 支持consumer端tag过滤，减少不必要的网络传输（rabbitmq和kafka不支持）
• 支持重复消费（rabbitmq不支持，kafka支持）

具体如何使用

在具体使用上，如果要连接云服务器上的mq，如果使用rabbitMQ：
新建项目，处理web依赖，其他都可以不要，加上rabbitMQ的依赖：

项目启动时，初始化队列，交换机，并绑定：

import org.springframework.amqp.core.BindingBuilder;
import org.springframework.amqp.core.DirectExchange;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

import org.springframework.amqp.core.Queue;

/**
 * @Author YuanChangLiang
 * @Date 2021/7/26 22:37
 */
@Configuration
public class RabbitMqConfig {


    /**
     * 项目启动时初始化一个队列
     * @return 队列
     */
    @Bean
    public Queue getQueue() {
        return new Queue("testDirectQueue",true);
    }

    /**
     * 项目启动时初始化一个交换机
     * @return 交换机
     */
    @Bean
    DirectExchange testDirectExchange() {
        return new DirectExchange("testDirectExchange",true,false);
    }

    /**
     * 队列与交换机绑定
     * @return 绑定结果
     */
    @Bean
    Binding bindingDirect() {
        return BindingBuilder.bind(getQueue()).to(testDirectExchange()).with("testDirectRouting");
    }

}

定义一个接口，向队列中推送消息：

@GetMapping("/initMq")
public String initMq(){
    HashMap<String, String> stringStringHashMap = new HashMap<>(3);
    stringStringHashMap.put("id","123");
    stringStringHashMap.put("message","hello啊，亮哥");
    stringStringHashMap.put("createTime", LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"))) ;
    rabbitTemplate.convertAndSend("testDirectExchange","testDirectRouting",stringStringHashMap);
    return "初始化消息队列成功";
}

调用该接口，推送消息：

查看云服务器对应的rabbitMQ地址：http://云服务器ip:15672

完毕。

如果是rocketMQ：
https://www.cnblogs.com/gmhappy/p/13457026.html

–我是“道祖且长”,一个在互联网"苟且偷生"的Java程序员
“有任何问题，可评论，我看到就会回复”