前面的章节，我们已经把RocketMQ的环境搭建起来了，是一个两主两从的异步集群。接下来，我们就看看怎么去使用RocketMQ，在使用之前，先要在NameServer中创建Topic，我们知道RocketMQ是基于Topic的消息队列，在生产者发送消息的时候，要指定消息的Topic，这个Topic的 ...
分类：
其他好文 时间：
2020-06-09 11:21:24
阅读次数：
75
RocketMQ事务消息（Transactional Message）是指应用本地事务和发送消息操作可以被定义到全局事务中，要么同时成功，要么同时失败。RocketMQ的事务消息提供类似 X/Open XA 的分布事务功能，通过事务消息能达到分布式事务的最终一致。 Half Message(半消息) ...
分类：
其他好文 时间：
2020-06-08 12:31:10
阅读次数：
59
1.MQ介绍 1.1 什么是MQ MQ是消息队列，也叫做消息中间件，通过生产者与消费者模型，生产者不断的向消息队列发送消息，消费者不断的从消息队列获取消息，因为发送消息和获取消息都是异步的，而且只关心消息的发送和接收，没有业务逻辑的侵入，可以轻松实现解耦。 1.2 MQ有哪些 MQ的实现有很多种，比 ...
分类：
其他好文 时间：
2020-06-07 11:09:15
阅读次数：
53
1。RabbitMQ MQ全称为Message Queue，即消息队列， RabbitMQ是由erlang语言开发，基于AMQP（Advanced Message Queue 高级消息队列协议）协议实现的消息队列，它是一种应用程序之间的通信方法，消息队列在分布式系统开 发中应用非常广泛。 开发中消息 ...
分类：
其他好文 时间：
2020-06-07 09:26:42
阅读次数：
71
介绍 Redis发布订阅（pub/sub）是一种消息通信模式：发布者（pub）发送消息，订阅者（sub）接收消息。 应用的领域：微信公众号、微博的关注、还有一些关注系统等！ Redis客户端可以订阅任意数量的频道。 订阅/发布消息图： 总共有三个对象：消息的发送者、频道、消息的订阅者！ 下图展示了频 ...
分类：
其他好文 时间：
2020-06-06 15:38:30
阅读次数：
66
使用webview 控件的时候 不免涉及到CTRL 与JS互相调用,这主要用到两个函数 oaJsApi.toctrl()及webview.execJsFunction(), 其中oaJsApi.toctrl()为js 向ctrl 发送消息; webview.execJsFunction()执行js中... ...
1.常见的我们是进入它的消费者模式 , 在里面输入 , 但是如何封装到shell中 kafka-console-producer.sh --broker-list node1:9092 --topic sky 比如我只想把 hello 这条消息发送到Topic sky里面 echo "hello" ...
分类：
系统相关 时间：
2020-06-03 23:08:22
阅读次数：
153
保证消息的安全 持久化 交换器持久化：声明交换器时指定持久化 队列持久化：声明队列时指定持久化 消息持久化：发送消息时指定持久化 一般队列和消息持久化要同时声明，此外消息假如进了交换器却找不到队列，也会丢失，必要时添加mandatory参数。 持久化会降低吞吐量。 消费者确认 订阅队列时设置auto ...
分类：
其他好文 时间：
2020-06-02 11:39:33
阅读次数：
58
发送端的可选配置 acks acks 配置表示 producer 发送消息到 broker 上以后的确认值。有三个可选项 Ø 0：表示 producer 不需要等待 broker 的消息确认。这个选项时延最小但同时风险最大（因为当 server 宕机时，数据将会丢失）。 Ø 1：表示 produce ...
分类：
其他好文 时间：
2020-05-31 21:27:40
阅读次数：
48
前言 要了解生产者ISR，需要提前了解下生产者重试机制和应答机制 生产者重试机制 创建生产者时，可以指定retries参数，如果向broker发送消息时抛出异常，并且异常是可重试异常RetriableException，那么此时就会按照指定的次数进行重试 1、哪些情况下可以重试 （1）没有到deli ...
分类：
其他好文 时间：
2020-05-31 18:19:32
阅读次数：
105
