游客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用来校验用户权限。二者缺一不可。
展示更多
AI助理

你好,我是AI助理

可以解答问题、推荐解决方案等