RocketMQ整理 概念 broker MQ服务节点 topic 主题 message queue 消息队列，类似于kafka中的partition producer 生产者，先去连接name server，查询到对应的broker信息，再去连接broker consumer 消费者，先去连接na ...
分类：
其他好文 时间：
2020-02-17 20:08:08
阅读次数：
85
1.RocketMQ概述 RocketMQ产品支持集群，效率高，同时支持上万队列，支持消息持久化，重试机制等等 2.RocketMQ原理 有别于其他消息中间件由broker做负载均衡并主动向consumer投递消息，RocketMq是基于拉模式拉取消息，consumer做负载均衡并通过长轮询向bro ...
分类：
其他好文 时间：
2020-02-17 19:43:12
阅读次数：
94
RocketMQ: 支持集群，效率高，同时支持上万队列，支持消息持久化，重试机制等等; RocketMQ包含的组件 NameServer：单点，供Producer和Consumer获取Broker地址 Producer：产生并发送消息 Consumer：接受并消费消息 Broker：消息暂存，消息转 ...
分类：
其他好文 时间：
2020-02-17 17:49:19
阅读次数：
77
创建工程（Producer和Consumer） 导入依赖 <dependency> <groupId>com.alibaba.rocketmq</groupId> <artifactId>rocketmq-client</artifactId> <version>3.0.10</version> < ...
分类：
编程语言 时间：
2020-02-17 16:11:14
阅读次数：
110
RocketMQ是什么 是一个队列模型的消息中间件，具有高性能，高可靠，高实时，分布式特点； Producer，Consumer，队列都可以分布式； Producer向一些队列轮流发送消息，队列集合称为Topic，Consumer如果做广播消费，则一个consumer实例消费这个Topic对应的素有 ...
分类：
其他好文 时间：
2020-02-17 14:09:58
阅读次数：
67
这个框架的目标是作为一个通用的框架，我希望它大而全，在日后可以直接作为我其他项目的基础模板，所以我还想继续给他添加一些功能，就当写一些demo进去吧。这篇文章，我将会添加一个队列的功能。nsq队列有很多种，我选择nsq。使用nsq需要知道以下几个概念：nsqd：负责维护队列的组件，接受消息排队和投递；nsqlookupd：管理nsq集群的组件；nsqadmin：nsq的web管理组件；topic：
分类：
其他好文 时间：
2020-02-17 09:29:26
阅读次数：
79
https://developer.huawei.com/consumer/cn/doc/development/HMS-2-Library/hmssdk_huaweiid_sdkdownload ...
分类：
其他好文 时间：
2020-02-16 16:34:17
阅读次数：
151
背景介绍 我们在工作中难免会写一些重复性的代码，所以需要我们具备一定的抽象能力，比如把共同的逻辑抽取到抽象类中，也可以通过一些工具类来避免冗余代码 今天这篇文章就是把一个调用服务的重试功能抽取出一个工具类，以备复用。这里为了方便介绍，把调用服务简化成方法的调用，被调用的 foo 方法如下： ~~~ ...
分类：
其他好文 时间：
2020-02-14 11:25:19
阅读次数：
68
/** * RabbitMQ消息确认机制 * 关于rabbit的生产和消费方的一些实用的操作； * producer的confirm和consumer的ack，这两者使用的模式都是用来保证数据完整性，防止数据丢失 */ /** * producer的confirm模式 * 业务场景描述： * 促销系 ...
分类：
其他好文 时间：
2020-02-14 11:14:24
阅读次数：
98
函数式接口就是只定义一个抽象方法的接口。在java8中，接口还可以拥有默认方法（即在类没有对方法进行实现时，其主体为方法提供默认实现的方法）。哪怕有很多默认方法，只要接口只定义了一个抽象方法，它就依然是一个函数式接口。 函数式接口带有@FunctionalInterface的标注，但它不是必须的。如 ...
分类：
其他好文 时间：
2020-02-11 15:59:35
阅读次数：
64
