https:\/\/www.nats.io\/download\/nats-io\/gnatsd\/<\/a>
2.\u4e0b\u8f7dwindows\u7248\u672c\uff0c\u4e5f\u53ef\u4ee5\u7528docker-image\u7248\uff0c\u90fd\u5f88\u65b9\u4fbf\u3002
3.windows\u7248\u672c\uff0c\u4e0b\u8f7d\u4e4b\u540e\uff0c\u89e3\u538b\uff0c\u53cc\u51fbgnatsd.exe\u5373\u53ef\u8fd0\u884c
4.\u83b7\u5f97\u670d\u52a1\u5668\u5730\u5740\uff1anats:\/\/localhost:4222<\/p>\nnats\u4ee3\u7801<\/h1>\n
1.\u5148maven\u5b89\u88c5\u76f8\u5173\u4f9d\u8d56\uff0c\u4e3b\u8981\u662fnats\u7684\u548cjson\u7684\uff0c\u56e0\u4e3a\u6211\u4eec\u8981pub\u4e00\u4e2ajson\u8fc7\u53bb<\/p>\n
<dependency>\n<groupId>io.nats<\/groupId>\n<artifactId>jnats<\/artifactId>\n<version>2.2.0<\/version>\n<\/dependency>\n<dependency>\n<groupId>com.google.code.gson<\/groupId>\n<artifactId>gson<\/artifactId>\n<version>2.8.5<\/version>\n<\/dependency><\/code><\/pre>\n\u00a0<\/p>\n
nats\u5ba2\u6237\u7aef(sub\u8ba2\u9605)<\/h1>\npackage nats.lzwtest;\nimport java.nio.charset.StandardCharsets;\nimport java.util.concurrent.CountDownLatch;\nimport io.nats.client.Connection;\nimport io.nats.client.Dispatcher;\nimport io.nats.client.Nats;\npublic class SubscribeAsync {\n public static void main(String[] args) {\n try {\n \/\/ [begin subscribe_async]\n \tConnection nc = Nats.connect(\"nats:\/\/localhost:4222\");\n \/\/ Use a latch to wait for a message to arrive\n CountDownLatch latch = new CountDownLatch(10);\n \/\/ Create a dispatcher and inline message handler\n Dispatcher d = nc.createDispatcher((msg) -> {\n String str = new String(msg.getData(), StandardCharsets.UTF_8);\n System.out.println(str);\n latch.countDown();\n });\n \/\/ Subscribe\n d.subscribe(\"lizhenwei\");\n \/\/ Wait for a message to come in\n latch.await();\n \/\/ Close the connection\n nc.close();\n \/\/ [end subscribe_async]\n } catch (Exception e) {\n e.printStackTrace();\n }\n }\n}<\/code><\/pre>\n\u00a0<\/p>\n
nats\u5ba2\u6237\u7aef(pub\u53d1\u5e03)<\/h1>\npackage nats.lzwtest;\nimport java.nio.charset.StandardCharsets;\nimport java.time.Duration;\nimport com.google.gson.Gson;\nimport com.google.gson.GsonBuilder;\nimport io.nats.client.Connection;\nimport io.nats.client.Nats;\n\/\/ [begin publish_json]\nclass StockForJsonPub {\n public String symbol;\n public float price;\n}\npublic class PublishJSON {\n public static void main(String[] args) {\n try {\n \tConnection nc = Nats.connect(\"nats:\/\/localhost:4222\");\n \/\/ Create the data object\n StockForJsonPub stk = new StockForJsonPub();\n stk.symbol=\"GOOG\";\n stk.price=1200;\n \/\/ use Gson to encode the object to JSON\n GsonBuilder builder = new GsonBuilder();\n Gson gson = builder.create();\n String json = gson.toJson(stk);\n \/\/ Publish the message\n nc.publish(\"lizhenwei\", json.getBytes(StandardCharsets.UTF_8));\n \/\/ Make sure the message goes through before we close\n nc.flush(Duration.ZERO);\n nc.close();\n System.out.println(\"pub success\");\n } catch (Exception e) {\n e.printStackTrace();\n }\n }\n}\n\/\/ [end publish_json]<\/code><\/pre>\n\u8fd0\u884c\u7ed3\u679c<\/h1>\n
sub\u7aef\u6536\u5230\u5982\u4e0b\uff1a<\/p>\n
{\"symbol\":\"GOOG\",\"price\":1200.0}<\/code><\/pre>\n\u00a0<\/p>\n\n\n
<\/p>\n","protected":false},"excerpt":{"rendered":"
\u9700\u6c42\u4ecb\u7ecd\uff1a NATS\u662f\u4e00\u4e2a\u5f00\u6e90\u4e14\u9ad8\u6027\u80fd\u7684\u6d88\u606f\u7cfb\u7edf,\u5b83\u5e38\u5e38\u88ab\u8ba4\u4e3a\u662f”\u4e00\u4e2a\u4e3a\u4e91\u670d\u52a1\u7684\u4e2d\u592e\u795e\u7ecf\u7cfb\u7edf […]<\/p>\n","protected":false},"author":1,"featured_media":0,"comment_status":"closed","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[10],"tags":[],"class_list":["post-381","post","type-post","status-publish","format-standard","hentry","category-10"],"_links":{"self":[{"href":"https:\/\/www.yinyubo.com\/index.php?rest_route=\/wp\/v2\/posts\/381","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/www.yinyubo.com\/index.php?rest_route=\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/www.yinyubo.com\/index.php?rest_route=\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/www.yinyubo.com\/index.php?rest_route=\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/www.yinyubo.com\/index.php?rest_route=%2Fwp%2Fv2%2Fcomments&post=381"}],"version-history":[{"count":2,"href":"https:\/\/www.yinyubo.com\/index.php?rest_route=\/wp\/v2\/posts\/381\/revisions"}],"predecessor-version":[{"id":929,"href":"https:\/\/www.yinyubo.com\/index.php?rest_route=\/wp\/v2\/posts\/381\/revisions\/929"}],"wp:attachment":[{"href":"https:\/\/www.yinyubo.com\/index.php?rest_route=%2Fwp%2Fv2%2Fmedia&parent=381"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.yinyubo.com\/index.php?rest_route=%2Fwp%2Fv2%2Fcategories&post=381"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.yinyubo.com\/index.php?rest_route=%2Fwp%2Fv2%2Ftags&post=381"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}