1111

src/main/java/com/fdkankan/contro/httpclient/address/MjAddressSource.java

@@ -12,7 +12,7 @@ public class MjAddressSource implements AddressSource {
     @Value("${bd.api.scheme:http}")
     private String scheme;
 
-    @Value("${bd.api.scheme:http}")
+    @Value("${bd.api.host}")
     private String host;
 
     @Value("${bd.api.port}")

src/main/java/com/fdkankan/contro/mq/nsq/NsqConsume.java

@@ -30,7 +30,7 @@ public class NsqConsume implements ApplicationRunner {
     @Override
     public void run(ApplicationArguments args) throws Exception {
         NSQLookup lookup = new DefaultNSQLookup();
-        lookup.addLookupAddress(nsqHost, 4161);
+        lookup.addLookupAddress(nsqHost, port);
         NSQConsumer consumer = new NSQConsumer(lookup, nsqTopic, channel, nsqMesgDeal);
         consumer.start();