Initial commit

.gitignore

@@ -0,0 +1 @@
+data

cfg/nsqadmin.toml

@@ -0,0 +1,3 @@
+http_address = "0.0.0.0:4171"
+nsqlookupd_http_addresses = ["nsqlookupd:4161"]
+broadcast_address = "nsqadmin"

cfg/nsqd.toml

@@ -0,0 +1,7 @@
+http_address = "0.0.0.0:4151"
+tcp_address = "0.0.0.0:4150"
+data_path = "/data"
+mem_queue_size = 10000
+max_bytes_per_file = 104857600
+nsqlookupd_http_addresses = ["nsqlookupd:4161"]
+broadcast_address = "nsqd"

cfg/nsqlookupd.toml

@@ -0,0 +1,3 @@
+http_address = "0.0.0.0:4161"
+tcp_address = "0.0.0.0:4160"
+broadcast_address = "nsqlookupd"

docker-compose.yml

@@ -0,0 +1,29 @@
+services:
+  nsqlookupd:
+    image: nsqio/nsq
+    command: /nsqlookupd --config=/etc/nsq/cfg/nsqlookupd.toml
+    ports:
+      - "4160:4160"
+      - "4161:4161"
+    volumes:
+      - ./cfg:/etc/nsq/cfg
+  nsqd:
+    image: nsqio/nsq
+    command: /nsqd --config=/etc/nsq/cfg/nsqd.toml
+    depends_on:
+      - nsqlookupd
+    ports:
+      - "4150:4150"
+      - "4151:4151"
+    volumes:
+      - ./data:/data
+      - ./cfg:/etc/nsq/cfg
+  nsqadmin:
+    image: nsqio/nsq
+    command: /nsqadmin --config=/etc/nsq/cfg/nsqadmin.toml
+    volumes:
+      - ./cfg:/etc/nsq/cfg
+    depends_on:
+      - nsqlookupd
+    ports:
+      - "4171:4171"

test.sh

@@ -0,0 +1,13 @@
+# http://shitbox:4171
+
+# while true
+# do
+#     NOW=$(date +%T)
+#     PAYLOAD="{\"time\":${NOW}}"
+#     printf "\n${PAYLOAD}"
+#     curl -s -d ${PAYLOAD} "http://shitbox:4151/pub?topic=queue"
+#     sleep 0.0001
+# done
+
+# bombardier -b '{}' -m 'POST' -c 100 http://shitbox:4151/pub?topic=queue
+bombardier -b '{\"_id\":\"67085247feb0abc89e3cc896\",\"index\":0,\"guid\":\"01129a9e-8c82-488d-aab1-9da50224a26c\",\"isActive\":true,\"balance\":\"$3,427.97\",\"picture\":\"http://placehold.it/32x32\",\"age\":37,\"eyeColor\":\"blue\",\"name\":\"Jimmie Golden\",\"gender\":\"female\",\"company\":\"ZIZZLE\",\"email\":\"jimmiegolden@zizzle.com\",\"phone\":\"+1 (994) 539-3181\",\"address\":\"964 Metrotech Courtr, Sisquoc, Northern Mariana Islands, 8482\",\"about\":\"Pariatur dolore sit ex ut qui consectetur ea veniam sunt irure. Esse laboris culpa eiusmod est elit et do culpa consectetur. Enim commodo cillum velit deserunt irure. Eiusmod reprehenderit velit ipsum voluptate elit dolor aute magna. Occaecat laboris est ex nulla est occaecat anim et esse consectetur officia. Sit ipsum ipsum esse dolor cillum cupidatat aliqua.\r\n\",\"registered\":\"2024-02-24T06:51:44 -01:00\",\"latitude\":72.202774,\"longitude\":-84.133177,\"tags\":[\"occaecat\",\"irure\",\"in\",\"irure\",\"in\",\"sit\",\"dolor\"],\"friends\":[{\"id\":0,\"name\":\"Reyes Hester\"},{\"id\":1,\"name\":\"Church Marks\"},{\"id\":2,\"name\":\"Woodard Osborn\"}],\"greeting\":\"Hello, Jimmie Golden! You have 7 unread messages.\",\"favoriteFruit\":\"banana\"}' -m 'POST' -c 100 http://shitbox:4151/pub?topic=queue