topic是一种信息传递模式,这里先看下service topic是一种单项传输信息的模式,在下面的场景:右node会连续不断发送数据给左node 也可以写一个服务,让右边node接收到信息才开始发送,但是这样写起来很麻烦 此时应该用service node a发送请求,node b才会发送信息回来 ...
分类:
其他好文 时间:
2019-05-03 11:25:11
阅读次数:
148
在上一章中,我们完善了我们的日志系统,用direct交换器替换了fanout交换器,使得我们可以有选择性地接收消息。尽管如此,仍然还有限制:不能基于多个标准进行路由。在我们的日志系统中,我们可能不仅希望根据日志等级订阅日志,还希望根据日志来源订阅日志。这个概念来自于unix工具syslog,它不仅可 ...
分类:
其他好文 时间:
2019-05-02 18:55:48
阅读次数:
133
https://edu.cnblogs.com/campus/zswxy/software-engineering-class2-2018/homework/3162 思考 巩固 通过阅读导师博客,了解自己现阶段还存在哪些不足之处,在之后需要作出哪些改进与规划 http://mindhacks.cn ...
分类:
其他好文 时间:
2019-05-01 23:51:53
阅读次数:
183
最近在使用rocketmq 发送消息,出现了No route info of this topic 异常,但奇怪的是我的其它的服务都可以成功发送,唯有crs服务不能成功发送,在网上搜索的解决方式基本上都是: ocketmq运行时提示 No route info of this topic 异常产生的 ...
分类:
其他好文 时间:
2019-04-29 15:54:12
阅读次数:
199
RabbitMQ的5种模式与实例 1.1 简单模式Hello World 功能:一个生产者P发送消息到队列Q,一个消费者C接收 生产者实现思路: 创建连接工厂ConnectionFactory,设置服务地址127.0.0.1,端口号5672,设置用户名、密码、virtual host,从连接工厂中获 ...
分类:
其他好文 时间:
2019-04-28 15:49:39
阅读次数:
156
1、查看topic信息 kafka-topics --zookeeper 10.79.2.92:2181/chroot --describe --topic ogg_fab_u 2、创建topic kafka-topics --create --topic dwr_pnl --zookeeper 1 ...
分类:
其他好文 时间:
2019-04-28 15:26:51
阅读次数:
84
Money is an awkward topic of conversation for many professionals—even more so when you’re busy trying to make a positive impression on a prospective e ...
分类:
其他好文 时间:
2019-04-27 09:52:24
阅读次数:
134
kafka 操作: source /etc/profile 查看消费: /usr/local/platform/kafka_2.11-1.1.0/bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic all.log_impb ...
分类:
其他好文 时间:
2019-04-23 22:30:24
阅读次数:
149
1. 问题 比如说我们建了一个 topic,有三个 partition。生产者在写的时候,其实可以指定一个 key,比如说我们指定了某个订单 id 作为 key,那么这个订单相关的数据,一定会被分发到同一个 partition 中去,而且这个 partition 中的数据一定是有顺序的。消费者从 p ...
分类:
其他好文 时间:
2019-04-22 00:41:18
阅读次数:
544
1. 查看所有topic 2. 创建tooic及topic的partitioner 说明:在集群模式中,partitioner可以根据集群节点的磁盘空间大小和kafka server这个配置`log dir=/data/kafka log,/data01/kafka log,/data02/kafk ...
分类:
其他好文 时间:
2019-04-21 20:25:27
阅读次数:
294