Add Address Resolver (#61)

* Add AddressResolver to handle load-balancers configuration
* add AddressResolver TLS example

Author: Gsantomaggio

.github/workflows/test_and_publish_image.yml

@@ -13,6 +13,7 @@ jobs:
           RABBITMQ_SERVER_ADDITIONAL_ERL_ARGS: "-rabbitmq_stream  advertised_host localhost"
         ports:
           - 5552:5552
+          - 15672:15672
     steps:
       - name: Set up Go
         uses: actions/setup-go@v2

.gitignore

@@ -22,3 +22,4 @@ vet
 perfTest/
 .vagrant/
 local/
+tls-gen/

Makefile

@@ -59,3 +59,10 @@ rabbitmq-server:
 		-e RABBITMQ_SERVER_ADDITIONAL_ERL_ARGS="-rabbitmq_stream advertised_host localhost" \
 		--pull always \
 		pivotalrabbitmq/rabbitmq-stream
+
+rabbitmq-ha-proxy:
+	cd compose; rm -rf tls-gen;
+	cd compose; git clone https://github.com/michaelklishin/tls-gen tls-gen; cd tls-gen/basic; make
+	cd compose; docker build -t haproxy-rabbitmq-cluster  .
+	cd compose; docker-compose down
+	cd compose; docker-compose up

comopose/conf/rabbitmq.conf

@@ -0,0 +1,2 @@
+tls-gen/
+.DS_Store

compose/.gitignore

@@ -0,0 +1,3 @@
+FROM haproxy
+
+COPY haproxy.cfg /usr/local/etc/haproxy/haproxy.cfg

compose/Dockerfile

@@ -0,0 +1,16 @@
+RabbitMQ cluster with HA proxy 
+===
+
+how to run:
+
+```bash
+git clone git@github.com:rabbitmq/rabbitmq-stream-go-client.git .
+make rabbitmq-ha-proxy 
+```
+
+ports:
+```
+ - localhost:5553 #standard stream port
+ - localhost:5554 #TLS stream port
+ - http://localhost:15673 #management port
+```

compose/README.md

@@ -0,0 +1,14 @@
+cluster_formation.peer_discovery_backend  = rabbit_peer_discovery_classic_config
+
+cluster_formation.classic_config.nodes.1 = rabbit@node0
+cluster_formation.classic_config.nodes.2 = rabbit@node1
+cluster_formation.classic_config.nodes.3 = rabbit@node2
+loopback_users.guest = false
+
+ssl_options.cacertfile = /certs/ca_certificate.pem
+ssl_options.certfile = /certs/server_certificate.pem
+ssl_options.keyfile = /certs/server_key.pem
+listeners.ssl.default = 5671
+stream.listeners.ssl.default = 5551
+ssl_options.verify               = verify_peer
+ssl_options.fail_if_no_peer_cert = false

comopose/conf/enabled_plugins renamed to compose/conf/enabled_plugins

@@ -3,49 +3,57 @@ services:
   rabbit_node0:
     environment:
       - RABBITMQ_ERLANG_COOKIE='secret_cookie'
-      - RABBITMQ_SERVER_ADDITIONAL_ERL_ARGS=-rabbitmq_stream advertised_host localhost advertised_port 5552
+      - RABBITMQ_SERVER_ADDITIONAL_ERL_ARGS=-rabbitmq_stream advertised_host node0
     networks:
       - back
     hostname: node0
     image: pivotalrabbitmq/rabbitmq-stream
     ports:
-      - "15672:15672"
-      - "5552:5552"
+      - "5561:5551"
+      - "5562:5552"
     tty: true
     volumes:
      - ./conf/:/etc/rabbitmq/
+     - "./tls-gen/basic/result/:/certs"
   rabbit_node1:
     environment:
       - RABBITMQ_ERLANG_COOKIE='secret_cookie'
-      - RABBITMQ_SERVER_ADDITIONAL_ERL_ARGS=-rabbitmq_stream advertised_host localhost advertised_port 5553
+      - RABBITMQ_SERVER_ADDITIONAL_ERL_ARGS=-rabbitmq_stream advertised_host node1
     networks:
       - back
     hostname: node1
-    depends_on:
-      - rabbit_node_0
     image: pivotalrabbitmq/rabbitmq-stream
     ports:
-      - "15673:15672"
-      - "5553:5552"
+      - "5571:5551"
+      - "5572:5552"
     tty: true
     volumes:
       - ./conf/:/etc/rabbitmq/
+      - "./tls-gen/basic/result/:/certs"
   rabbit_node2:
     environment:
       - RABBITMQ_ERLANG_COOKIE='secret_cookie'
-      - RABBITMQ_SERVER_ADDITIONAL_ERL_ARGS=-rabbitmq_stream advertised_host localhost advertised_port 5554
+      - RABBITMQ_SERVER_ADDITIONAL_ERL_ARGS=-rabbitmq_stream advertised_host node2
     networks:
       - back
     hostname: node2
-    depends_on:
-      - rabbit_node_1
     image: pivotalrabbitmq/rabbitmq-stream
     ports:
-      - "15674:15672"
-      - "5554:5552"
+      - "5581:5551"
+      - "5582:5552"
     tty: true
     volumes:
       - ./conf/:/etc/rabbitmq/
-
+      - "./tls-gen/basic/result/:/certs"
+  haproxy:
+    image: haproxy-rabbitmq-cluster
+#    container_name: haproxy
+    hostname: haproxy
+    ports:
+      - "5553:5552"
+      - "5554:5551"
+      - "15673:15672"
+    networks:
+      - back
 networks:
   back: