Skip to content
  1. 先决条件:
  1. 快速开始

    build镜像,可以打开 network.sh 文件,修改 _IMAGE_NAMEIMAGE_VERSION 来更改镜tag

    shell
    
        cd example/test-network-k8s
        ./network.sh build-images

    拉取一些必要的镜像

    shell
        docker pull k8s.gcr.io/ingress-nginx/controller:v1.1.2
        docker pull quay.io/jetstack/cert-manager-webhook:v1.6.1
        docker pull quay.io/jetstack/cert-manager-controller:v1.6.1
        docker pull quay.io/jetstack/cert-manager-cainjector:v1.6.1
        docker pull k8s.gcr.io/ingress-nginx/kube-webhook-certgen:v1.1.1

    初始化kind集群

    shell
        ./network.sh kind

    加载镜像到kind集群

    shell
        ./network.sh kind-load-images

    启动 kind k8s 集群

    shell
        ./network.sh cluster-init

    启动 RobustMQ 集群

    shell
        ./network.sh up
  2. 清理工作

    shell
        ./network.sh unkind
  3. 回顾历程

    • 安装 kind
    • 拉取一些必要的镜像
    • 初始化kind集群
    • 加载镜像到kind集群
    • 启动 kind k8s 集群
    • 启动 RobustMQ 集群
  4. 简单使用

    更多命令请参考 cli-command

    这个 kind-k8s 集群会启动一个 cli-command 的 pod,可以在集群中执行 cli-command 命令。

    先获取到cli-command的 pod 的名字

    console
    % kubectl get pods -n robustmq
    NAME                                READY   STATUS    RESTARTS   AGE
    cli-command-6fbf8b6cc-7ldqp          1/1     Running   0          16m

    进入 cli-command 的 pod,执行命令

    发布消息

    console
    % kubectl exec -it cli-command-6fbf8b6cc-7ldqp -n robustmq -- /bin/sh
    # ./cli-command mqtt --server=mqtt-server-cs.robustmq.svc.cluster.local:1883 publish --username=admin --password=pwd123 --topic=test/topic1 --qos=0
    able to connect: "mqtt-server-cs.robustmq.svc.cluster.local:1883"
    you can post a message on the terminal:
    1
    > You typed: 1
    2
    > You typed: 2
    3
    > You typed: 3
    ^C>  Ctrl+C detected,  Please press ENTER to end the program.

    订阅消息

    console
    kubectl exec -it cli-command-6fbf8b6cc-7ldqp -n robustmq -- /bin/sh
    # cd libs
    # ./cli-command mqtt --server=mqtt-server-cs.robustmq.svc.cluster.local:1883  subscribe --username=admin --password=pwd123 --topic=test/topic1 --qos=0
    able to connect: "mqtt-server-cs.robustmq.svc.cluster.local:1883"
    subscribe success
    payload: 1
    payload: 2
    payload: 3
    ^C Ctrl+C detected,  Please press ENTER to end the program.
    End of input stream.