# 产品概览
注意: EMQX Operator 控制器需要 Kubernetes v1.20.0 或者以上。
# 背景
此教程采用 minikube v1.20.0 安装部署
# 部署Operator控制器
# 准备
我们使用 cert manager (opens new window)来给 webhook 服务提供证书。你可以通过 cert manager 文档 (opens new window)来安装。
# 默认静态安装
安装默认静态配置文件
$ kubectl apply -f https://raw.githubusercontent.com/emqx/emqx-operator/1.1.2/config/samples/operator/controller.yaml
1
# 通过 Helm 安装
- 添加 EMQX Helm 仓库
$ helm repo add emqx https://repos.emqx.io/charts
$ helm repo update
1
2
2
- 用 Helm 安装 EMQX Operator 控制器
$ helm install emqx-operator emqx/emqx-operator \
--set installCRDs=true \
--namespace emqx-operator-system \
--create-namespace
1
2
3
4
2
3
4
# 检查 EMQX Operator 控制器状态
$ kubectl get pods -l "control-plane=controller-manager" -n emqx-operator-system
NAME READY STATUS RESTARTS AGE
emqx-operator-controller-manager-68b866c8bf-kd4g6 1/1 Running 0 15s
1
2
3
2
3
# 部署 EMQX Broker
- 创建 EMQX Custom Resource
$ cat https://raw.githubusercontent.com/emqx/emqx-operator/1.1.2/config/samples/emqx/v1beta2/emqx.yaml
1
apiVersion: apps.emqx.io/v1beta2
kind: EmqxBroker
metadata:
name: emqx
spec:
serviceAccountName: "emqx"
image: emqx/emqx:4.3.11
replicas: 3
labels:
cluster: emqx
storage:
storageClassName: standard
resources:
requests:
storage: 20Mi
accessModes:
- ReadWriteOnce
emqxTemplate:
listener:
type: ClusterIP
ports:
mqtt: 1883
mqtts: 8883
ws: 8083
wss: 8084
dashboard: 18083
api: 8081
acl:
- permission: allow
username: "dashboard"
action: subscribe
topics:
filter:
- "$SYS/#"
- "#"
- permission: allow
ipaddress: "127.0.0.1"
topics:
filter:
- "$SYS/#"
equal:
- "#"
- permission: deny
action: subscribe
topics:
filter:
- "$SYS/#"
equal:
- "#"
- permission: allow
plugins:
- name: emqx_management
enable: true
- name: emqx_recon
enable: true
- name: emqx_retainer
enable: true
- name: emqx_dashboard
enable: true
- name: emqx_telemetry
enable: true
- name: emqx_rule_engine
enable: true
- name: emqx_bridge_mqtt
enable: false
modules:
- name: emqx_mod_acl_internal
enable: true
- name: emqx_mod_presence
enable: true
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
Note:
Details for cluster config (opens new window) Details for env config (opens new window)
- 部署 EMQX Custom Resource 并且检查 EMQX 状态
$ kubectl apply https://raw.githubusercontent.com/emqx/emqx-operator/1.1.2/config/samples/emqx/v1beta2/emqx.yaml
emqx.apps.emqx.io/emqx created
$ kubectl get pods
NAME READY STATUS RESTARTS AGE
emqx-0 1/1 Running 0 22m
emqx-1 1/1 Running 0 22m
emqx-2 1/1 Running 0 22m
$ kubectl exec -it emqx-0 -- emqx_ctl status
Node 'emqx@emqx-0.emqx.default.svc.cluster.local' 4.3.11 is started
$ kubectl exec -it emqx-0 -- emqx_ctl cluster status
Cluster status: #{running_nodes =>
['emqx@emqx-0.emqx.default.svc.cluster.local',
'emqx@emqx-1.emqx.default.svc.cluster.local',
'emqx@emqx-2.emqx.default.svc.cluster.local'],
stopped_nodes => []}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
Note:
EMQX Operator 给 EMQX 集群提供默认的监听器。默认的服务类型是 ClusterIP，用户也可以选择 LoadBalancer 和 NodePort。
ws、wss、mqtt、mqtts、dashboard、api的端口需要提前配置，否则在集群允许时无法修改。