下面代码路径：source->rocketmq->common->selectorDefaultTopicSelector.java类publicclassDefaultTopicSelectorT>implementsTopicSelectorT>{privatefinalStringtopicName;privatefinalStringtagName;publicDefaultTopicSelector(finalStringtopicName){this(topicName,"");}publicDefaultTopicSelector(StringtopicName,Stringta
下面代码路径：source->rocketmq->common->selectorDefaultTopicSelector.java类publicclassDefaultTopicSelectorT>implementsTopicSelectorT>{privatefinalStringtopicName;privatefinalStringtagName;publicDefaultTopicSelector(finalStringtopicName){this(topicName,"");}publicDefaultTopicSelector(StringtopicName,Stringta
1、适用场景kafka:适用于日志处理rocketmq:适用于业务处理结论：两者没有区别，根据具体业务定夺2、性能kafka：单机写入TPS号称在百万条/秒rocketmq：大约在10万条/秒结论：性能方面，kafka单机性能更高3、可靠性kafka：异步刷盘，异步Replicationrocketmq：支持异步/同步刷盘，异步/同步Replication结论：可靠性方面，rocketmq支持同步，可靠性更高4、实时性kafka和rocketmq均支持pull长轮询，rocketmq消息实时性更高结论：rocketmq实时性会更高5、支持的队列数kafka：单机超过64个队列/分区，消息发送
点击上方「蓝字」关注我们SpringBoot项目集成rocketmq-client org.apache.rocketmq rocketmq-client 4.7.0项目启动时会在${user.home}/logs目录下创建一个rocketmq_client.log日志文件，文件全路径是：${user.home}/logs/rocketmqlogs/rocketmq_client.log。如果一个系统部署多个微服务话，会导致所有的微服务的RocketMQ的日志都会打印到该文件里，不容易定位到底是哪个微服务的RocketMQ Client出现了错误。所以需要配置rocketm
点击上方「蓝字」关注我们SpringBoot项目集成rocketmq-client org.apache.rocketmq rocketmq-client 4.7.0项目启动时会在${user.home}/logs目录下创建一个rocketmq_client.log日志文件，文件全路径是：${user.home}/logs/rocketmqlogs/rocketmq_client.log。如果一个系统部署多个微服务话，会导致所有的微服务的RocketMQ的日志都会打印到该文件里，不容易定位到底是哪个微服务的RocketMQ Client出现了错误。所以需要配置rocketm
🍊Java学习：Java从入门到精通总结🍊深入浅出RocketMQ设计思想：深入浅出RocketMQ设计思想🍊绝对不一样的职场干货：大厂最佳实践经验指南📆最近更新：2022年10月15日🍊个人简介：通信工程本硕💪、Java程序员🌕。做过科研paper，发过专利，优秀的程序员不应该只是CRUD🍊点赞👍收藏⭐留言📝都是我最大的动力！文章目录平均分配算法环形平均分配算法一致性哈希算法指定机房算法就进机房算法手动配置负载均衡参数平均
k8s。《Kubernetes~k8s从入门到入坑。》文章目录k8s。8.数据存储。8.1基本存储。8.1.1EmptyDir。8.1.2HostPath。8.1.3NFS。8.2高级存储。8.2.1PV。8.2.2PVC。8.2.3生命周期。8.3配置存储。8.3.1ConfigMap。8.3.2Secret。9.安全认证。9.1访问控制概述。9.2认证管理。9.3授权管理。9.4准入控制。10.DashBoard。10.1部署Dashboard。10.2使用DashBoard。8.数据存储。在前面已经提到，容器的生命周期可能很短，会被频繁地创建和销毁。那么容器在销毁时，保存在容器中的数据也
rocketmq是一个分布式消息中间件，分布式的意思就是多台机器可以通过网络连接协同工作，因此rocketmq可以运行在多台机器上，以达到超越单机的服务能力。rocketmq的架构图如下所示我们首先搭建一个最小的rocketmq集群，需要启动一个nameserver和一个broker。这里我们选择在linux下使用docker来搭建集群，我们需要启动三个容器首先需要拉取三个镜像dockerpullfoxiswho/rocketmq:server-4.5.1dockerpullfoxiswho/rocketmq:broker-4.5.1dockerpullapacherocketmq/rocke
目录一、准备工作二、代码实现1.添加依赖2.创建一个常量类存放公共参数3.调用TCP协议的SDK发送消息4.调用TCP协议的SDK订阅消息三、配置main的日志输出级别四、测试效果五、完成代码一、准备工作登录阿里云官网，先申请rocketMQ，再申请Topic、GroupID，然后就是参考阿里云的JAVASDK进行编程实现。环境要求：安装JDK1.8或以上版本安装Maven安装JavaSDK参照阿里云官方文档，来一步一步操作。文档提供的SDK有TCP和Http协议，这里使用TCP协议来实现rocketMQ消息的发送与消费。二、代码实现调用TCP协议的SDK收发普通消息1.添加依赖创建Sprin
使用Docker安装RocketMQ使用docker安装rocketmq使用Docker安装RocketMQ能够更加方便的部署和管理，以下是基本步骤：1、拉取RocketMQ镜像：2、运行RocketMQ实例：3、测试RocketMQ：使用Docker安装RocketMQ能够更加方便的部署和管理，以下是基本步骤：RocketMQ是一个分布式的消息中间件，由NameServer和Broker两个角色组成，是一种典型的基于发布/订阅模式的消息通信解决方案。NameServer是RocketMQ的命名服务，可以理解为类似于DNS的服务，它主要负责记录Topic的路由信息和Broker的地址信息。每个
