Producer 消息生产者，生产者的作用就是将消息发送到MQ，生产者本身既可以产生消息，如读取文本信息等。也可以对外提供接口，由外部应用来调用接口，再由生产者将收到的消息发送到MQ。 Producer Group 生产者组，简单来说就是多个发送同一类消息的生产者称之为一个生产者组。在这里可以不用关心，只要知道有这么一个概念即可。 Consumer 消息消费者，简单来说，消费MQ上的消息...
Lemon
Cancel
RocketMQ术语
RocketMQ实际部署
上传安装包 解压RocketMQ压缩包 在安装目录下创建存储路径 mkdir -p data/store/{commitlog,consumequeue,index} 进入conf目录下修改日志配置文件 mkdir -p /home/weblogic/apache-rocketm...
RocketMQ如何在控制台查看死信队列
RocketMQ的ACK机制其中涉及到了消息消费重试，当重试次数达到默认的16次后（可以通过配置文件修改）如果对应的消息还没被成功消费的话，该消息就会投递到DLQ死信队列。 不过，在使用控制台查询死信消息队列的时候会报错org.apache.rocketmq.client.exception.MQClientException: Can not find Message Queue f...
RocketMQ配置项
客户端的公共配置类：ClientConfig 参数名 默认值 说明 NamesrvAddr NameServer地址列表，多个NameServer地址用分号隔开 clientIP 本机IP 客户端本机IP地址，...
关于RocketMQ
RocketMQ队列的长度 RocketMQ没有内存Buffer概念，RocketMQ的队列都是持久化磁盘，数据定期清除。RocketMQ同其他MQ有非常显著的区别，RocketMQ的内存Buffer抽象成一个无限长度的队列，不管有多少数据进来都能装得下，这个无限是有前提的，Broker会定期删除过期的数据，例如Broker只保存3天的消息，那么这个Buffer虽然长度无限，但是3天前的数据...
CentOS7安装RocketMQ
上传安装包 JDK1.8 (注意一定要使用1.8以上版本，1.7版本不能识别RocketMQ中的metaspace特性，该特性由1.8最新提出) 。 RocketMQ压缩包，下载选择binary版。 解压RocketMQ压缩包 修改配置文件 在conf文件中可以看到以下文件夹，对应rocketmq的不同部署模式：...
删除下载未完整的依赖文件
set REPOSITORY_PATH=E:\repository rem 正在搜索... for /f "delims=" %%i in ('dir /b /s "%REPOSITORY_PATH%\*lastUpdated*"') do ( del /s /q %%i ) rem 搜索完毕 pause 记得路径修改为你自己所在依赖包的位置，然后把.txt文件后缀改为.bat ，双击运...
IntelliJ IDEA Maven菜单模块为灰色
Idea用maven搭建聚合项目时，出现了如下的问题：即Maven工具栏中的某一个模块是灰色的，同时导致了新的问题：在pom文件中引入jar包，但是在Java代码里，找不到这个类。然后我看了一下Dependencies目录，jar是下载好的。 jar包是下载好的，但是引用类文件的地方还是有红色报错：提示要Add library to classpath。解决办法：Preferences...
IntelliJ IDEA离线使用Maven仓库的方法
首先将相关的Maven依赖在外网的环境中下载好，然后将整个repository打包后拷贝到内网的机器上并解压。 然后将外网的settings文件也拷贝到内网使用，或者也可以将内网 settings 文件中的镜像配置部分改成和外网一样。 <mirrors> <mirror> <id>nexus-aliyun</id> &...
Spring MVC
现在主流的Web MVC框架除了Struts这个主力外，其次就是Spring MVC了，因此这也是作为一名程序员需要掌握的主流框架，框架选择多了，应对多变的需求和业务时，可实行的方案自然就多了。不过要想灵活运用Spring MVC来应对大多数的Web开发，就必须要掌握它的配置及原理。 web.xml <?xml version="1.0" encoding="UTF-8"?> ...