上一个章中没有密码设置怎么就能接发消息了？？ 首先activemq中常见的有两种密码：控制台 和 broker 控制台的密码在conf/jetty.xml文件中： <bean id="securityConstraint" class="org.eclipse.jetty.http.security ...
分类：
其他好文 时间：
2018-09-23 11:53:27
阅读次数：
236
顺序、广播、定时任务 前插 ? 在进行常用的三种消息类型例子展示的时候，我们先来说一说RocketMQ的几个重要概念： PullConsumer与PushConsumer ：主要区别在于Pull与Push的区别。对于PullConsumer，消费者会主动从broker中拉取消息进行消费。而对于Pus ...
分类：
其他好文 时间：
2018-09-20 11:13:29
阅读次数：
171
修改rocketmq官方代码测试： 启动&参数修改 查看当前系统状态 查看当前所有topicList 查看broker状态 查看某个topic的状态 查看连接的procedure/consumer 查看某个key对应的msg 根据ID查看对应的MSG 根据位置偏移查询上面的那条数据 查看消费详情 重 ...
分类：
其他好文 时间：
2018-09-13 20:15:00
阅读次数：
250
这个坑对小白来讲可能要趟很久才能过，我就是这样~~明明很简单的配置，搞了半天 我用的是rocketmq4.1.0，配置了jvm参数，都能正常启动，且能在线上运行demo，但是线下就是连不上 1. 在conf目录下有个broker.conf，我以为他默认会读取这个文件，拼命在改这个文件。。实际上都不起 ...
分类：
其他好文 时间：
2018-09-13 18:34:46
阅读次数：
130
前言 开源社区有好多优秀的队列中间件，比如RabbitMQ和Kafka，每个队列都貌似有其特性，在进行工程选择时，往往眼花缭乱，不知所措。对于RabbitMQ和Kafka，到底应该选哪个？ RabbitMQ架构 RabbitMQ是一个分布式系统，这里面有几个抽象概念。 broker：每个节点运行的服 ...
分类：
其他好文 时间：
2018-09-12 11:13:11
阅读次数：
108
首先编写一个打印函数KafkaPrintFunction 然后编写trident整合kafka的topology 另一个Java项目发送kafka数据 最后运行storm项目以及java项目（需要先运行java项目往kafka发数据，建立此topic，storm才能消费这个topic） 观察结果，s ...
分类：
其他好文 时间：
2018-09-10 13:30:09
阅读次数：
320
1.消息发送 1.异步发送 消息生产者使用持久（persistent）传递模式发送消息的时候，Producer.send() 方法会被阻塞，直到 broker 发送一个确认消息给生产者，这个确认消息暗示生产者 broker已经成功地将它发送的消息路由到目标目的并把消息保存到二级存储中。这个过程通常称 ...
分类：
其他好文 时间：
2018-09-08 16:52:10
阅读次数：
167
“数据”是一个公司的核心资产，数据丢失或不可用则将是一个严重事故。如何做到高可用，其实三个核心点： 冗余，可用，扩容 冗余一般都是复制机制将数据分发在不同的机器上，保证数据非单点存储 可用保证服务不中断，当master挂了，能自动切到salve 上 扩容一般当数据存储容量不足，可通过分片或分区来往外 ...
分类：
其他好文 时间：
2018-09-08 13:10:43
阅读次数：
216
问题导读1.Kafka独特设计在什么地方？2.Kafka如何搭建及创建topic、发送消息、消费消息？3.如何书写Kafka程序？4.数据传输的事务定义有哪三种？5.Kafka判断一个节点是否活着有哪两个条件？6.producer是否直接将数据发送到broker的leader(主节点)？7.Kafa ...
分类：
其他好文 时间：
2018-09-06 20:35:16
阅读次数：
170
tar -zxvf /root/soft/kafka_2.11-1.1.1.tgz -C /app/ #broker.id=0 每台服务器的broker.id都不能相同 #hostnamehost.name=1.2.3.251 #在log.retention.hours=168 下面新增下面三项me ...
分类：
其他好文 时间：
2018-09-05 11:13:01
阅读次数：
162
