
游客mfe7gxjfjhxrc
访问dashboard时,利用弹性IP无法访问成功

imath60
实验项目:RocketMQ中使用Java客户端发送消息和消费的应用
涉及资源:ECS
耗时:15分钟
实验结论:成功
实验步骤:
1、选择实验资源-公共资源体验
2、启动RocketMQ集群
3、如何发送和消费并发消息
4、如何发送和消费延迟消息
5、如何发送和消费事务消息
6、生产者消费者如何同步发送、消费消息(Request-Reply)
7、如何有选择性的消费消息
8、如何使用ACL客户端生产消费消息
实验笔记:
通过上述实验,了解并掌握全场景的发送、消费消息。相关实践课程详见5小时轻松搞定RocketMQ

游客7khsivgmpkuxw
%1. 执行如下命令,进入namesrv目录,并启动namesrv。
cd /usr/local/services/5-rocketmq/namesrv-01
./restart.sh
返回结果如下,当观察到启动成功的日志后, 按Ctrl+C键,终止日志输出。
%1. 启动broker。
2.1执行如下命令,进入broker目录。
cd /usr/local/services/5-rocketmq/broker-01
2.2执行如下命令,修改broker配置项。
vim ./conf/broker.conf
2.3按i键,进入编辑模式,将brokerIP1参数改为实验室云服务器ECS的弹性IP。修改完成后,按ECS键输入退出编辑模式,输入:wq,按回车键保存。
说明:可在云产品资源列表中查看到实验室云服务器ECS的弹性IP。
2.4执行如下命令,启动broker。
./restart.sh
返回结果如下,当观察到启动成功的日志后,按Ctrl+C键,终止日志输出。
%1. 执行如下命令,进入dashboard目录,并启动dashboard。
cd /usr/local/services/7-rocketmq-datashboard
./restart.sh
返回结果如下,当观察到启动成功的日志后,按Ctrl+C键,终止日志输出。
%1. 验证集群启动情况。
在本机浏览器中,打开新页签,访问http://实验室云服务器ECS的弹性IP:30904#/cluster。
返回如下页面,可以查看到集群节点信息,表示集群已正常启动。

aliyun0968518276-23334
按照指示完成第一步。
第二步
第三步:
启动成功
demo启动成功

cheney524
1.启动RocketMQ集群
实验环境中已包含编译好的RocketMQ
1.1 启动namesrv
1.2 启动broker,需要首先修改配置文件中的IP地址为本机IP
其中有个特别有意思的dashboard可以通过可视化的方式,展示集群中生产、发送、消费消息的记录
2. 发送和消费普通消息(并发消息)
普通消息的效率最高,不区分消息顺序
3.发送和消费顺序消息
包括分区有序和全局有序
分区有序:topic中被设置同一个key的消息会送至同一个queue中
4. 发送和消费延迟消息
RocketMQ支持3个level的延迟级别
5. 发送和消费事务消息
事务消息是RocketMQ解决分布式事务的一种实现
6.生产者和消费者同步的发送和消费消息
即Request-Reply模式,可满足类似RPC同步调用的场景。但是建议需要同步调用就用RPC, 不要走RocketMQ,毕竟两者是完全不同的目标的产品,专业的事情交给专业的产品。
7. 选择性消费消息
可以通过tag,sql92表达式来实现
7.1 修改broker配置,支持消息和属性过滤
注意重启broker
8.使用ACL客户端生产消费消息
8.1 修改broker配置

游客avra4s3tgd2lm
这部分写的特别详细,就是自己有些地方不理解,还需要加强相关学习。

游客4jiqr76cvoikq
总结
1. 简单的发送和消费消息
2. 顺序消息
3. 延迟消息
4. 事物消息
5. 同步发送和消费消息
6. 有选择性的消费消息
7. 使用ACL客户端生产消费消息

孤独风
事物消息,顺序消息,延时消息,基本上支持了普通业务中大多数的场景。只是延时消息能支持自定义时间就好了。

游客khmcwsb46w76a
./restart.sh
这个命令没有找到

游客uq5wfhnejxx3m
本次实验,总结
生产者如何发送消息,消费者如何接收消息
顺序消息:
全局有序:要求queue个数为1
分区有序:要求queue个数为任意有效值,在同一个queue中是有序,相同key会被发送到同一个queue中
延迟消息:
处理指定延时时间的业务要求,如订票,20分钟内未支付的进行关闭订单
事务消息:
需要同本地事务一起判断是否提交与回滚
先发送half消息,获取本地消息的事务状态,进行half消息的commit或者rollback
同步消息:
request-reply可以满足同步调用的模板,我觉得可以不用如此费事,直接走rpc就搞定了
过滤消息:
设置tag或者其它属性,在消费端进行设置过滤条件,拉取指定消息
配置ACL:
需要指定安全信息
在broker端secret key用来校验信息的完整性, access key用来校验用户权限。二者缺一不可。
展示更多