使用nginx代理rocketmq多主多从集群

我在k8s里部署好了rocketmq多主多从集群，并且在我的kubernetes集群中已经使用了，但是突然有要求在kubernetes集群外部也要用，这个就尴尬了。因为我的是线上环境如果外部访问就需要放在公网上，我这里在测试环境测试。刚开始我用的是一个代理，代理多个broker就会发现客户端生产和消费都是两条同样的消息，但是只是发了一条会产生聊天，弄了两天。一直郁闷。。。。。 后来我把一个代理换成两个代理，每个代理代理一个broker即可。我的nginx已经安装好了，看一下我的nginx配置。

 nginx73
 stream {
     upstream prod-wulaoer-link-mq10909 {
         least_conn;
         server 192.168.6.236:32727;
     }
     upstream prod-wulaoer-link-mq10911 {
         least_conn;
         server 192.168.6.237:32742;
     }
     upstream prod-wulaoer-link-mq9876 {
         least_conn;
         server 192.168.6.236:30740;
     }
     server {
         listen 9876;#9876
         proxy_pass prod-wulaoer-link-mq9876;
     }
    server {
         listen 10909;#10909
         proxy_pass prod-wulaoer-link-mq10909;
     }
    server {
         listen 10911; #10911
         proxy_pass prod-wulaoer-link-mq10911;
     }
 }
 nginx93
 stream {
     upstream prod-wulaoer-link-mq10909 {
         least_conn;
         server 192.168.6.236:30532;
     }
     upstream prod-wulaoer-link-mq10911 {
         least_conn;
         server 192.168.6.236:31213;
     }
     upstream prod-wulaoer-link-mq9876 {
         least_conn;
         server 192.168.6.236:30740;
     }
     server {
         listen 9876;#9876
         proxy_pass prod-wulaoer-link-mq9876;
     }
    server {
         listen 10909;#10909
         proxy_pass prod-wulaoer-link-mq10909;
     }
    server {
         listen 10911; #10911
         proxy_pass prod-wulaoer-link-mq10911;
     }
 }

stream是需要配置到nginx的http里的，所以安装的nginx要支持stream。另外需要配置一下broker主的配置，把两个主里增加brokerIP1 = 192.168.6.93和`brokerIP1 = 192.168.6.73`然后重启broker即可，下面看一下我的控制台变化

增加了两个代理的ip，这时我们需要在主题里创建一个topic然后发个消息，在消息里查看一下，是不是一条消息就可以了，另外在连接rocketmq时需要把93和73的9876端口都加上才可以，避免brocker之间不均衡。