k8s 安装rocketmq
时间: 2023-11-15 16:00:16 浏览: 98
在k8s上安装RocketMQ,可以通过以下步骤实现:
1. 部署RocketMQ的namesrv和broker,可以使用官方提供的Docker镜像,也可以自己构建镜像。
2. 部署RocketMQ的控制台dashboard,同样可以使用官方提供的Docker镜像,也可以自己构建镜像。
3. 部署RocketMQ的消费者和生产者应用程序,可以使用RocketMQ提供的示例程序,也可以自己编写应用程序。
4. 配置RocketMQ的参数,包括namesrv地址、broker地址等。
5. 验证RocketMQ是否正常工作。
具体的安装步骤可以参考以下引用:
引用:其中id需要进入控制台通过命令 id 查看,如下 [rocketmq@rocketmqnamesrv-0 bin]$ id uid=3000(rocketmq) gid=3000(rocketmq) groups=3000(rocketmq) 。
引用:消费消息: ./tools.sh org.apache.rocketmq.example.quickstart.Consumer。
引用:脚本如下 apiVersion: v1 kind: Service metadata: labels: app: rocketmq-dashboard name: rocketmq-dashboard spec: type: NodePort ports: - port: 8080 targetPort: 8080 name: port nodePort: 30809 selector: app: rocketmq-dashboard --- apiVersion: apps/v1 kind: Deployment metadata: name: rocketmq-dashboard spec: replicas: 1 selector: matchLabels: app: rocketmq-dashboard template: metadata: labels: app: rocketmq-dashboard spec: containers: - name: rocketmq-dashboard image: apacherocketmq/rocketmq-dashboard imagePullPolicy: IfNotPresent env: - name: TZ value: Asia/Shanghai - name: JAVA_OPTS value: "-Drocketmq.namesrv.addr=rocketmqnamesrv:9876 -Dcom.rocketmq.sendMessageWithVIPChannel=false" readinessProbe: tcpSocket: port: 8080 initialDelaySeconds: 15
阅读全文