diff --git a/pom.xml b/pom.xml
index 2f8fa236..509dc384 100644
--- a/pom.xml
+++ b/pom.xml
@@ -492,11 +492,12 @@
junit
test
-
-
-
-
-
+
+
+ com.sproutsocial
+ nsq-j
+ 1.4.9
+
diff --git a/src/main/java/com/sqx/nsq/PubExample.java b/src/main/java/com/sqx/nsq/PubExample.java
new file mode 100644
index 00000000..9ce6aca9
--- /dev/null
+++ b/src/main/java/com/sqx/nsq/PubExample.java
@@ -0,0 +1,20 @@
+package com.sqx.nsq;
+
+import com.sproutsocial.nsq.Subscriber;
+
+/**
+ * @author GYJoker
+ */
+public class PubExample {
+
+ public static void handleData(byte[] data) {
+ System.out.println("Received:" + new String(data));
+ }
+
+ public static void main(String[] args) {
+ Subscriber subscriber = new Subscriber("47.122.26.160");
+ subscriber.subscribe("test", "channel1", PubExample::handleData);
+
+
+ }
+}
diff --git a/src/main/resources/application.yml b/src/main/resources/application.yml
index a3c91423..671c93c2 100644
--- a/src/main/resources/application.yml
+++ b/src/main/resources/application.yml
@@ -9,6 +9,11 @@ server:
servlet:
context-path: /czg
+nsq:
+ lookup-addresses: 127.0.0.1:4161 # 这里填写你的NSQ lookupd服务地址和端口,示例用本地地址
+ topic: test_topic # 定义要使用的NSQ主题
+ channel: test_channel # 定义NSQ通道
+
spring:
main:
allow-circular-references: true