网络推广文案策划,兰州网站优化,wordpress改代码,the_post wordpress最近#xff0c;似乎我们正在听到有关Java的最新和最好的框架的消息。 忍者 #xff0c; SparkJava和Play等工具; 但是每个人都固执己见#xff0c;使您感到您需要重新设计整个应用程序以利用它们的出色功能。 这就是为什么当我发现Vert.x时令我感到宽慰的原因。 Vert.x不是… 最近似乎我们正在听到有关Java的最新和最好的框架的消息。 忍者 SparkJava和Play等工具; 但是每个人都固执己见使您感到您需要重新设计整个应用程序以利用它们的出色功能。 这就是为什么当我发现Vert.x时令我感到宽慰的原因。 Vert.x不是一个框架它是一个工具包它不受质疑而且正在解放。 Vert.x不想让您重新设计整个应用程序以使用它它只是想让您的生活更轻松。 您可以在Vert.x中编写整个应用程序吗 当然 您可以在现有的Spring / Guice / CDI应用程序中添加Vert.x功能吗 是的 您可以在现有JavaEE应用程序中使用Vert.x吗 绝对 这就是让它变得惊人的原因。 背景 Vert.x诞生于Tim Fox决定他喜欢NodeJS生态系统中正在开发的许多东西但他不喜欢在V8中进行权衡取舍单线程有限的库支持以及JavaScript本身。 Tim着手编写一个工具包该工具包在使用方式和位置方面不受质疑因此他决定在JVM上实现它的最佳位置。 因此Tim和社区开始着手创建一个事件驱动的非阻塞的反应性的工具箱该工具箱在许多方面都反映了NodeJS可以完成的工作而且还利用了JVM内部的强大功能。 Node.x诞生了后来发展成为Vert.x。 总览 Vert.x旨在实现事件总线该事件总线使应用程序的不同部分可以以非阻塞/线程安全的方式进行通信。 它的一部分是根据Eralng和Akka展示的Actor方法建模的。 它还旨在充分利用当今的多核处理器和高度并发的编程需求。 因此默认情况下所有Vert.x VERTICLES默认都实现为单线程。 与NodeJS不同Vert.x可以在许多线程中运行许多顶点。 此外您可以指定某些顶点为“工作”顶点并且可以是多线程的。 为了给蛋糕锦上添花Vert.x通过使用Hazelcast对事件总线的多节点群集提供了底层支持。 它继续包含许多其他令人惊奇的功能这些功能在这里没有列出太多但是您可以在Vert.x官方文档中内容。 关于Vert.x您需要了解的第一件事是与NodeJS相似永远不要阻塞当前线程。 默认情况下Vert.x中的所有内容均已设置为使用回调/未来/承诺。 Vert.x提供了异步方法来执行大多数I / O和处理器密集型操作这些操作可能会阻塞当前线程而不是执行同步操作。 现在使用回调可能很丑陋且很痛苦因此Vert.x可以选择提供基于RxJava的API该API使用Observer模式实现相同的功能。 最后Vert.x通过在许多异步API上提供executeBlockingFunction f方法可以轻松使用现有的类和方法。 这意味着您可以选择喜欢使用Vert.x的方式而不是由工具包指示必须如何使用它。 了解Vert.x的第二件事是它由顶点模块和节点组成。 顶点是Vert.x中最小的逻辑单元通常由单个类表示。 遵循UNIX Philosophy的原则顶点应该是简单且具有单一用途的。 一组顶点可以放到一个模块中该模块通常打包为单个JAR文件。 一个模块代表了一组相关的功能当一起使用时它们可以代表一个完整的应用程序或一个较大的分布式应用程序的一部分。 最后节点是运行一个或多个模块/垂直模块的JVM的单个实例。 由于Vert.x具有从头开始内置的群集功能因此Vert.x应用程序可以跨越一台计算机或跨多个地理位置的多台计算机跨越节点尽管延迟可能会掩盖性能。 示例项目 现在我最近去过一些聚会和会议在谈论反应式编程时它们向您展示的第一件事就是构建一个聊天室应用程序。 一切都很好但这并不能真正帮助您完全理解响应式开发的力量。 聊天室应用程序既简单又简单。 我们可以做得更好。 在本教程中我们将使用旧版Spring应用程序并将其转换为利用Vert.x的优势。 这具有多个目的表明该工具包易于与现有Java项目集成它使我们能够利用可能是生态系统中根深蒂固的现有工具的优势并且使我们遵循DRY原则 因为我们不不必重写大量代码即可获得Vert.x的好处。 我们的旧版Spring应用程序是使用Spring BootSpring Data JPA和Spring REST的REST API的简单示例。 源代码可以在“主”分支中找到该处 。 我们还将使用其他分支来演示进行中的进度因此只要对git和Java 8有一点经验的人都可以遵循。 让我们从检查常规Spring应用程序的Spring Configuration类开始。 SpringBootApplication
EnableJpaRepositories
EnableTransactionManagement
Slf4j
public class Application {public static void main(String[] args) {ApplicationContext ctx SpringApplication.run(Application.class, args);System.out.println(Lets inspect the beans provided by Spring Boot:);String[] beanNames ctx.getBeanDefinitionNames();Arrays.sort(beanNames);for (String beanName : beanNames) {System.out.println(beanName);}}Beanpublic DataSource dataSource() {EmbeddedDatabaseBuilder builder new EmbeddedDatabaseBuilder();return builder.setType(EmbeddedDatabaseType.HSQL).build();}Beanpublic EntityManagerFactory entityManagerFactory() {HibernateJpaVendorAdapter vendorAdapter new HibernateJpaVendorAdapter();vendorAdapter.setGenerateDdl(true);LocalContainerEntityManagerFactoryBean factory new LocalContainerEntityManagerFactoryBean();factory.setJpaVendorAdapter(vendorAdapter);factory.setPackagesToScan(com.zanclus.data.entities);factory.setDataSource(dataSource());factory.afterPropertiesSet();return factory.getObject();}Beanpublic PlatformTransactionManager transactionManager(final EntityManagerFactory emf) {final JpaTransactionManager txManager new JpaTransactionManager();txManager.setEntityManagerFactory(emf);return txManager;}
} 正如您在课程顶部看到的那样我们有一些非常标准的Spring Boot注释。 你还会看到 SLF4J批注这是一部分Lombok库旨在帮助降低锅炉板代码。 我们还有Bean批注的方法用于提供对JPA EntityManagerTransactionManager和DataSource的访问。 这些项目中的每一个都提供可注入的对象供其他类使用。 项目中的其余类也非常简单。 有一个客户 POJO它是服务中使用的实体类型。 通过Spring Data创建了一个CustomerDAO 。 最后有一个CustomerEndpoints类它是JAX-RS注释的REST控制器。 如前所述这是Spring Boot应用程序中的所有标准票价。 该应用程序的问题在于在大多数情况下它的可伸缩性有限。 您可以在Servlet容器中运行此应用程序也可以在Jetty或Undertow之类的嵌入式服务器中运行该应用程序。 无论哪种方式每个请求都占用一个线程因此在等待I / O操作时浪费了资源。 切换到Convert-To-Vert.x-Web分支我们可以看到Application类发生了一些变化。 现在我们有了一些新的Bean批注方法来注入Vertx实例本身以及ObjectMapper实例Jackson JSON库的一部分。 我们还用新的CustomerVerticle替换了CustomerEnpoints类。 几乎所有其他内容都是相同的。 CustomerVerticle类带有Component注释这意味着Spring将在启动时实例化该类。 它还具有用PostConstruct注释的start方法以便在启动时启动Verticle。 查看代码的实际内容我们看到Vert.x代码的第一部分 Router 。 Router类是vertx-web库的一部分它使我们能够使用流畅的API来定义HTTP URL方法和标头过滤器以进行请求处理。 将BodyHandler实例添加到默认路由可以处理POST / PUT正文并将其转换为JSON对象然后Vert.x可以将其作为RoutingContext的一部分进行处理。 Vert.x中的路由顺序可能很重要。 如果您定义的路由具有某种形式的全局匹配*或regex则除非实现chaining 否则它会吞下对其后定义的路由的请求。 我们的示例最初显示了3条路线。 PostConstructpublic void start() throws Exception {Router router Router.router(vertx);router.route().handler(BodyHandler.create());router.get(/v1/customer/:id).produces(application/json).blockingHandler(this::getCustomerById);router.put(/v1/customer).consumes(application/json).produces(application/json).blockingHandler(this::addCustomer);router.get(/v1/customer).produces(application/json).blockingHandler(this::getAllCustomers);vertx.createHttpServer().requestHandler(router::accept).listen(8080);} 请注意定义了HTTP方法定义了“ Accept”标头通过消耗定义了“ Content-Type”标头通过生产。 我们还看到我们正在通过对blockingHandler方法的调用传递对请求的处理。 Vert.x路由的阻塞处理程序接受RoutingContext对象因为它是唯一的参数。 RoutingContext包含Vert.x请求对象响应对象以及任何参数/ POST主体数据例如“id”。 您还将看到我使用了方法引用而不是lambda来将逻辑插入blockingHandler我发现它更具可读性。 这3条请求路由的每个处理程序都在该类中一个单独的方法中定义。 这些方法基本上只是调用DAO上的方法根据需要进行序列化或反序列化设置一些响应头并通过发送响应来结束请求。 总体而言非常简单明了。 private void addCustomer(RoutingContext rc) {try {String body rc.getBodyAsString();Customer customer mapper.readValue(body, Customer.class);Customer saved dao.save(customer);if (saved!null) {rc.response().setStatusMessage(Accepted).setStatusCode(202).end(mapper.writeValueAsString(saved));} else {rc.response().setStatusMessage(Bad Request).setStatusCode(400).end(Bad Request);}} catch (IOException e) {rc.response().setStatusMessage(Server Error).setStatusCode(500).end(Server Error);log.error(Server error, e);}}private void getCustomerById(RoutingContext rc) {log.info(Request for single customer);Long id Long.parseLong(rc.request().getParam(id));try {Customer customer dao.findOne(id);if (customernull) {rc.response().setStatusMessage(Not Found).setStatusCode(404).end(Not Found);} else {rc.response().setStatusMessage(OK).setStatusCode(200).end(mapper.writeValueAsString(dao.findOne(id)));}} catch (JsonProcessingException jpe) {rc.response().setStatusMessage(Server Error).setStatusCode(500).end(Server Error);log.error(Server error, jpe);}}private void getAllCustomers(RoutingContext rc) {log.info(Request for all customers);List customers StreamSupport.stream(dao.findAll().spliterator(), false).collect(Collectors.toList());try {rc.response().setStatusMessage(OK).setStatusCode(200).end(mapper.writeValueAsString(customers));} catch (JsonProcessingException jpe) {rc.response().setStatusMessage(Server Error).setStatusCode(500).end(Server Error);log.error(Server error, jpe);}} 您可能会说“但是这比我的Spring注释和类还要更多的代码和混乱”。 这可能是正确的但实际上取决于您如何实现代码。 这只是一个介绍性的示例因此我使代码非常简单易懂。 我可以使用Vert.x的注释库以类似于JAX-RS的方式实现端点。 此外我们还获得了可扩展性的巨大改进。 在幕后Vert.x Web使用Netty进行低级异步I / O操作从而使我们能够处理更多并发请求受数据库连接池的大小限制。 通过使用Vert.x Web库我们已经对该应用程序的可伸缩性和并发性进行了一些改进但是我们可以通过实现Vert.x EventBus来进行一些改进。 通过将数据库操作分为Worker Verticles而不是使用blockingHandler我们可以更有效地处理请求处理。 这显示在“ 转换为工作人员垂直”分支中。 应用程序类保持不变但是我们更改了CustomerEndpoints类并添加了一个名为CustomerWorker的新类。 此外我们添加了一个名为Spring Vert.x Extension的新库该库为Vert.x Verticles提供了Spring Dependency Injections支持。 首先查看新的CustomerEndpoints类。 PostConstructpublic void start() throws Exception {log.info(Successfully create CustomerVerticle);DeploymentOptions deployOpts new DeploymentOptions().setWorker(true).setMultiThreaded(true).setInstances(4);vertx.deployVerticle(java-spring:com.zanclus.verticles.CustomerWorker, deployOpts, res - {if (res.succeeded()) {Router router Router.router(vertx);router.route().handler(BodyHandler.create());final DeliveryOptions opts new DeliveryOptions().setSendTimeout(2000);router.get(/v1/customer/:id).produces(application/json).handler(rc - {opts.addHeader(method, getCustomer).addHeader(id, rc.request().getParam(id));vertx.eventBus().send(com.zanclus.customer, null, opts, reply - handleReply(reply, rc));});router.put(/v1/customer).consumes(application/json).produces(application/json).handler(rc - {opts.addHeader(method, addCustomer);vertx.eventBus().send(com.zanclus.customer, rc.getBodyAsJson(), opts, reply - handleReply(reply, rc));});router.get(/v1/customer).produces(application/json).handler(rc - {opts.addHeader(method, getAllCustomers);vertx.eventBus().send(com.zanclus.customer, null, opts, reply - handleReply(reply, rc));});vertx.createHttpServer().requestHandler(router::accept).listen(8080);} else {log.error(Failed to deploy worker verticles., res.cause());}});} 路由相同但实现代码不同。 现在我们不再使用对blockingHandler的调用而是实现了适当的异步处理程序该处理程序在事件总线上发送事件。 此Verticle中不再进行任何数据库处理。 我们已将数据库处理移至一个工作线程该线程具有多个实例以线程安全的方式并行处理多个请求。 我们还为这些事件的回复时间注册了一个回调以便我们可以向发出请求的客户端发送适当的响应。 现在在CustomerWorker Verticle中我们已经实现了数据库逻辑和错误处理。 Override
public void start() throws Exception {vertx.eventBus().consumer(com.zanclus.customer).handler(this::handleDatabaseRequest);
}public void handleDatabaseRequest(MessageObject msg) {String method msg.headers().get(method);DeliveryOptions opts new DeliveryOptions();try {String retVal;switch (method) {case getAllCustomers:retVal mapper.writeValueAsString(dao.findAll());msg.reply(retVal, opts);break;case getCustomer:Long id Long.parseLong(msg.headers().get(id));retVal mapper.writeValueAsString(dao.findOne(id));msg.reply(retVal);break;case addCustomer:retVal mapper.writeValueAsString(dao.save(mapper.readValue(((JsonObject)msg.body()).encode(), Customer.class)));msg.reply(retVal);break;default:log.error(Invalid method method );opts.addHeader(error, Invalid method method );msg.fail(1, Invalid method);}} catch (IOException | NullPointerException e) {log.error(Problem parsing JSON data., e);msg.fail(2, e.getLocalizedMessage());}
} CustomerWorker工人垂直服务器在事件总线上注册消费者以获取消息。 代表事件总线上地址的字符串是任意的但建议使用反向tld样式的命名结构以确保地址唯一com.zanclus.customer很简单。 每当有新消息发送到该地址时它将被发送到一个只有一个工作层。 然后工作层将调用handleDatabaseRequest来完成数据库工作JSON序列化和错误处理。 你有它。 您已经看到可以将Vert.x集成到旧版应用程序中以提高并发性和效率而不必重写整个应用程序。 我们可以使用现有的Google Guice或JavaEE CDI应用程序完成类似的操作。 当我们在Vert.x中尝试添加响应功能时所有业务逻辑都可能保持相对不变。 下一步由您决定。 接下来的一些想法包括Clustering WebSockets和ReactiveX sugar的VertxRx 。 翻译自: https://www.javacodegeeks.com/2015/12/reactive-development-using-vert-x.html
