We may get to a point whereby we have multiple Vert.x applications running and we want one Verticle to communicate with another – this is easy enough if the IP address and port are fixed but not so easy in more scalable\/real-world scenarios where we cannot guarantee these are fixed.<\/p>\n
In such situations we can use service discovery<\/em> to locate other services.<\/p>\n Before we get started with the code, we need to add the following to the pom.xml<\/p>\n I’m using vertx.version 3.5.0 in my examples.<\/em><\/p>\n Publishing\/Registering our Verticle with ServiceDiscovery<\/strong><\/p>\n To register our Verticle with ServiceDisovery we create a Record object which tells the ServiceDiscovery how to access a Verticle, this includes it’s host\/IP, port and service root along with a name for other code to use to locate the service. For example<\/p>\n So this basically says, create a Record named “hello-service” (the key or name of the service) and it’s IP\/host is localhost, obviously this is just for my testing. Next we supply the exposed port and finally the root of the service. <\/p>\n We then publish this record to the ServiceDiscovery object like this<\/p>\n Upon success we store the Record (in this case we only do this if the call succeeded) so that we can unpublish the service if it’s shutdown.<\/p>\n Let’s look at the full code for a simplified HelloVerticle<\/p>\n Locating a service via ServiceDiscovery<\/strong><\/p>\n Let’s take a look at some “consumer” code which will use service discovery to locate our “HelloVerticle”. As expected we need to create access to the ServiceDiscovery object and then we try to locate the Record for a previously added Record. <\/p>\n In the example, below, we search for the “name”, “hello-service”, this is wrapped into a JsonObject and the result (if successful will contain a Record which matches the search criteria. Using HttpClient we can now simply get the reference to this service and interact with it without ever knowing it’s IP address or port.<\/p>\n We may get to a point whereby we have multiple Vert.x applications running and we want one Verticle to communicate with another – this is easy enough if the IP address and port are fixed but not so easy in more scalable\/real-world scenarios where we cannot guarantee these are fixed. In such situations we can […]<\/p>\n","protected":false},"author":1,"featured_media":0,"comment_status":"closed","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"_jetpack_memberships_contains_paid_content":false,"footnotes":""},"categories":[161,210],"tags":[],"class_list":["post-6079","post","type-post","status-publish","format-standard","hentry","category-java","category-vert-x"],"jetpack_sharing_enabled":true,"jetpack_featured_media_url":"","_links":{"self":[{"href":"https:\/\/putridparrot.com\/blog\/wp-json\/wp\/v2\/posts\/6079","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/putridparrot.com\/blog\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/putridparrot.com\/blog\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/putridparrot.com\/blog\/wp-json\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/putridparrot.com\/blog\/wp-json\/wp\/v2\/comments?post=6079"}],"version-history":[{"count":9,"href":"https:\/\/putridparrot.com\/blog\/wp-json\/wp\/v2\/posts\/6079\/revisions"}],"predecessor-version":[{"id":6109,"href":"https:\/\/putridparrot.com\/blog\/wp-json\/wp\/v2\/posts\/6079\/revisions\/6109"}],"wp:attachment":[{"href":"https:\/\/putridparrot.com\/blog\/wp-json\/wp\/v2\/media?parent=6079"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/putridparrot.com\/blog\/wp-json\/wp\/v2\/categories?post=6079"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/putridparrot.com\/blog\/wp-json\/wp\/v2\/tags?post=6079"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}\r\n<dependency>\r\n <groupId>io.vertx<\/groupId>\r\n <artifactId>vertx-service-discovery<\/artifactId>\r\n <version>${vertx.version}<\/version>\r\n<\/dependency>\r\n<\/pre>\n\r\nRecord record = HttpEndpoint.createRecord(\r\n "hello-service",\r\n "localhost",\r\n 8080,\r\n "\/hello");\r\n<\/pre>\n
\r\ndiscovery.publish(record, ar ->\r\n{\r\n if (ar.succeeded()) {\r\n \/\/ publication succeeded\r\n publishedRecord = ar.result();\r\n } else {\r\n \/\/ publication failed\r\n }\r\n});\r\n<\/pre>\n\r\npublic class HelloVerticle extends AbstractVerticle {\r\n\r\n private ServiceDiscovery discovery;\r\n private Record publishedRecord;\r\n\r\n @Override\r\n public void start() {\r\n discovery = new DiscoveryImpl(vertx, \r\n new ServiceDiscoveryOptions());\r\n\r\n Router router = Router.router(vertx);\r\n router.get("\/hello").handler(ctx -> {\r\n ctx.response()\r\n .putHeader("content-type", "text\/plain")\r\n .end("hello");\r\n });\r\n\r\n Record record = HttpEndpoint.createRecord(\r\n "hello-service",\r\n "localhost",\r\n 8080,\r\n "\/hello");\r\n\r\n discovery.publish(record, ar ->\r\n {\r\n if (ar.succeeded()) {\r\n \/\/ publication success\r\n publishedRecord = ar.result();\r\n } else {\r\n \/\/ publication failure\r\n }\r\n });\r\n\r\n vertx\r\n .createHttpServer()\r\n .requestHandler(router::accept)\r\n .listen(8080, ar -> {\r\n \/\/ handle success\/failure \r\n });\r\n }\r\n\r\n @Override\r\n public void stop() {\r\n if(discovery != null) {\r\n discovery.unpublish(publishedRecord.getRegistration(), ar ->\r\n {\r\n if (ar.succeeded()) {\r\n \/\/ Success\r\n } else {\r\n \/\/ cannot unpublish the service, \r\n \/\/ may have already been removed, \r\n \/\/ or the record is not published\r\n }\r\n });\r\n\r\n discovery.close();\r\n }\r\n }\r\n}\r\n<\/pre>\n\r\nServiceDiscovery discovery = ServiceDiscovery.create(v);\r\ndiscovery.getRecord(\r\n new JsonObject().put("name", "hello-service"), found -> {\r\n if(found.succeeded()) {\r\n Record match = found.result();\r\n ServiceReference reference = discovery.getReference(match);\r\n HttpClient client = reference.get();\r\n\r\n client.getNow("\/hello", response ->\r\n response.bodyHandler(\r\n body -> \r\n System.out.println(body.toString())));\r\n }\r\n});\r\n<\/pre>\n","protected":false},"excerpt":{"rendered":"