文档章节

服务共享 vertx Server sharing

天舒
 天舒
发布于 2016/04/19 09:58
字数 497
阅读 52
收藏 1

Server sharing

服务共享

When several HTTP servers listen on the same port, vert.x orchestrates the request handling using a round-robin strategy.

当几个http服务监听同一个端口,vert.x安排循环处理这个请求。

Let’s take a verticle creating a HTTP server such as:

让我们创建一个http服务:

io.vertx.examples.http.sharing.HttpServerVerticle

vertx.createHttpServer().requestHandler(request -> {
  request.response().end("Hello from server " + this);
}).listen(8080);

This service is listening on the port 8080. So, when this verticle is instantiated multiple times as 

with:

vertx run io.vertx.examples.http.sharing.HttpServerVerticle -instances 2

这个服务监听着8080端口,所以当verticle被实例化为多个。

, what’s happening ? If both verticles would bind to the same port, you would receive a socket exception. Fortunately, 

将发生什么?2个实例绑定到同一个端口,你将获得一个socket异常。幸运的是

vert.x is handling this case for you. When you deploy another server on the same host and port as an existing server it 

vert.x已经帮你处理了这个场景。当你在已经存在的地址、端口上发布另外一个服务。

doesn’t actually try and create a new server listening on the same host/port. It binds only once to the socket. When 

它事实上不会创建一个新的服务监听这个地址/端口,它只是一次性绑定到这个socket上。

receiving a request it calls the server handlers following a round robin strategy.

当收到一个请求,它会循环调用服务处理者。

Let’s now imagine a client such as:

我们想象有个client这样的。每100毫秒执行一次访问服务8080。

vertx.setPeriodic(100, (l) -> {
  vertx.createHttpClient().getNow(8080, "localhost", "/", resp -> {
    resp.bodyHandler(body -> {
      System.out.println(body.toString("ISO-8859-1"));
    });
  });
});

Vert.x delegates the requests to one of the server sequentially:

vert.x将依次请求服务。

Hello from i.v.e.h.s.HttpServerVerticle@1
Hello from i.v.e.h.s.HttpServerVerticle@2
Hello from i.v.e.h.s.HttpServerVerticle@1
Hello from i.v.e.h.s.HttpServerVerticle@2
...

Consequently the servers can scale over available cores while each Vert.x verticle instance remains strictly single threaded, 

因此,这些服务可以扩展并在有效的内核上伸缩

and you don’t have to do any special tricks like writing load-balancers in order to scale your server on your multi-core 

所有你不用再用特意的写动态平衡的代码来平衡你的多核机器。

machine.


© 著作权归作者所有

共有 人打赏支持
天舒
粉丝 11
博文 17
码字总数 9012
作品 0
东城
架构师
使用Vert.x构建Web服务器和消息系统

Vert.x亮点 Vert.x应用程序是事件驱动,异步和单线程的。 Vert.x过程通过事件总线,这是Vert.x的事件驱动架构的内置一块通信。 结合异步处理,单线程组件和事件总线产生高度的可扩展性,并编...

力谱宿云
2016/06/20
1K
0
Vert.x Blueprint 系列教程(二) | Vert.x Kue 教程(Web部分)

上部分蓝图教程中我们一起探索了如何用Vert.x开发一个基于消息的应用。在这部分教程中,我们将粗略地探索一下模块的实现。 Vert.x Kue REST API kue-http模块中只有一个类KueHttpVerticle,作...

sczyh30
2016/07/26
190
0
Vert.x 3.1.0 发布,JVM 上的 Node.js 替代

Vert.x 3.1.0 发布,主要更新内容如下: Vertx-syncis a set of utilities that allow you to perform asynchronous operationsand receive events in a synchronous way, but without bloc......

oschina
2015/10/09
2.4K
12
vert.x core vert.x的核心是一个java api的集合

At the heart of Vert.x is a set of Java APIs that we call Vert.x Core vert.x的核心是一个java api的集合 Repository. Vert.x core provides functionality for things like: 核心提供了......

天舒
2016/04/19
223
0
AeroGear.js 1.1.0 发布,手机Web脚手架

AeroGear.js 1.1.0 发布了,该版本包含全新的 Notifier 插件,可支持基于 websocket 和 vert.x 的消息服务通讯,修复了很多 bug,包括: Changelog Bump version to 1.1.0 Update jQuery de...

红薯
2013/06/25
945
1

没有更多内容

加载失败,请刷新页面

加载更多

分布式框架spring-session实现session一致性使用问题

前言:项目中使用到spring-session来缓存用户信息,保证服务之间session一致性,但是获取session信息为什么不能再服务层获取? 一、spring-session实现session一致性方式 用户每一次请求都会...

WALK_MAN
29分钟前
2
0
C++ yield()与sleep_for()

C++11 标准库提供了yield()和sleep_for()两个方法。 (1)std::this_thread::yield(): 线程调用该方法时,主动让出CPU,并且不参与CPU的本次调度,从而让其他线程有机会运行。在后续的调度周...

yepanl
37分钟前
1
0
Java并发编程实战(chapter_3)(线程池ThreadPoolExecutor源码分析)

这个系列一直没再写,很多原因,中间经历了换工作,熟悉项目,熟悉新团队等等一系列的事情。并发课题对于Java来说是一个又重要又难的一大块,除非气定神闲、精力满满,否则我本身是不敢随便写...

心中的理想乡
47分钟前
17
0
shell学习之获取用户的输入命令read

在运行脚本的时候,命令行参数是可以传入参数,还有就是在脚本运行过程中需要用户输入参数,比如你想要在脚本运行时问个问题,并等待运行脚本的人来回答。bash shell为此提 供了read命令。 ...

woshixin
今天
1
0
区块链技术中的那些能商用的企业级应用

WEPOWER是一家立陶宛初创企业,旨在改变可再生电力项目的付费方式。WePower公司创始人Nick Martyniuk表示,政府统一收购价的存在推动了全球风能与太阳能市场的发展。因此,他的公司希望帮助那...

问题终结者
今天
2
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部