logback_broker.xml 代码中的使用 ...
分类：
其他好文 时间：
2018-05-20 16:44:46
阅读次数：
877
问题现象 今天忽然收到RocketMQ预警信息如下： 提醒有部分数据没有消费，产生堆积情况。 打开 RocketMq Console Ng 查看如下图形式： 备注： 第一反应是 Consumer Group内订阅了多个topic？ （为什么这么怀疑，下次分析）。 通过命令 statsAll 作用是查 ...
分类：
其他好文 时间：
2018-05-17 12:06:46
阅读次数：
277
消息队列及常见消息队列介绍 2017-10-10 09:35操作系统/客户端/人脸识别 消息队列及常见消息队列介绍 2017-10-10 09:35操作系统/客户端/人脸识别 一、消息队列(MQ)概述 消息队列（Message Queue），是分布式系统中重要的组件，其通用的使用场景可以简单地描述为 ...
分类：
Web程序 时间：
2018-05-16 15:14:34
阅读次数：
2413
写在前面 Rocketmq采用apache rockemq 4.2.0release版本。 源码路径（http://mirrors.shu.edu.cn/apache/rocketmq/4.2.0/rocketmq-all-4.2.0-source-release.zip） 场景 这里采用两台Ubu ...
分类：
其他好文 时间：
2018-05-15 22:32:21
阅读次数：
1361
生成者 DefaultMQProducer 发送消息失败，消息重试。 produce.send(msg,10) 可以指定重试的次数 消费者（先订阅服务，在发送消息） DefaultMQPushConsumer setConsumerMessageBatchMaxsize(10); 看情况，不会一次性 ...
分类：
Windows程序 时间：
2018-05-12 23:08:40
阅读次数：
1491
集群模式 多Master模式 优点：数据不会丢失，性能高 缺点：单台机器岩机期间，这台机器未被消费的消息在机器恢复之前不可订阅。消息的实时性会受到影响 多Master多Slave模式，异步复制 优点：即使Master岩机之后，消费者任然可以从slave中消费。 缺点：Master岩机，会丢失少量数据 ...
分类：
其他好文 时间：
2018-05-12 19:18:37
阅读次数：
162
1，机器ip 软件版本 jdk-8u131-linux-x64.tar.gz rocketmq-all-4.2.0-bin-release.zip rocketmq-console-ng-1.0.0.jar 10.15.10.238 HNVM015238 nameserver1 rocketmq-m ...
分类：
其他好文 时间：
2018-05-12 00:00:47
阅读次数：
200
为什么要响应式编程？ 传统的Servlet模型走到了尽头 传统的Java服务器编程遵循的是J2EE的Servlet规范，是一种基于线程的模型：每一次http请求都由一个线程来处理。 <! ?xml version="1.0" encoding="UTF 8" standalone="no"? 客户端 ...
分类：
编程语言 时间：
2018-05-11 23:56:43
阅读次数：
947
"上一节" 消息重试里面提到了重试的消息可以被延时消费，其实除此之外，用户发送的消息也可以指定延时时间（更准确的说是延时等级），然后在指定延时时间之后投递消息，然后被consumer消费。阿里云的ons还支持定时消息，而且延时消息是直接指定延时时间，其实阿里云的延时消息也是定时消息的另一种表述方式， ...
分类：
其他好文 时间：
2018-05-10 00:32:26
阅读次数：
1085
一、RocketMQ基础知识介绍Apache RocketMQ是阿里开源的一款高性能、高吞吐量、队列模型的消息中间件的分布式消息中间件。RocketMQ具有以下特点： 上图是一个典型的消息中间件收发消息的模型，RocketMQ也是这样的设计，简单说来RocketMQ具有以下特点：1）是一个队列模型的 ...
分类：
其他好文 时间：
2018-05-09 19:35:10
阅读次数：
176
