文档章节

使用vertx共享数据 Using Shared Data with Vert.x

天舒
 天舒
发布于 2016/04/19 11:16
字数 1323
阅读 195
收藏 0

Using Shared Data with Vert.x

使用vertx共享数据

Shared data contains functionality that allows you to safely share data between different parts of your application, or 

共享数据功能允许你安全的在不同的模块、

different applications in the same Vert.x instance or across a cluster of Vert.x instances.

或不同的应用、或不同的分布式实例之间共享数据。

Shared data includes local shared maps, distributed, cluster-wide maps, asynchronous cluster-wide locks and 

共享数据有多个方式:包括本地共享maps、分布式、宽集群的maps、异步的宽集群锁

asynchronous cluster-wide counters.

、异步的宽集群计数器。

Local shared maps

Local shared maps allow you to share data safely between different event loops (e.g. different verticles) in the same Vert.x instance.

本地共享maps允许你在不同的实例之间共享数据。


Local shared maps only allow certain data types to be used as keys and values. Those types must either be immutable, or certain other types that can be copied like Buffer. In the latter case the key/value will be copied before putting it in the map.

本地存储只允许某些数据类型被设置为keys和values,这个类型必须不可变的或某些可以被拷贝的类型例如Buffer,在最后keys/values被拷贝进map里。

This way we can ensure there is no shared access to mutable state between different threads in your Vert.x application so 

我们可以确定不会有不同线程之间有多个状态。所以

you don’t have to worry about protecting that state by synchronising access to it.

你不用担心异步访问的问题。

Here’s an example of using a shared local map:

这里有个本地共享的例子。

SharedData sd = vertx.sharedData();

LocalMap<String, String> map1 = sd.getLocalMap("mymap1");

map1.put("foo", "bar"); // Strings are immutable so no need to copyLocalMap<String, Buffer> map2 = sd.getLocalMap("mymap2");

map2.put("eek", Buffer.buffer().appendInt(123)); // This buffer will be copied before adding to map// Then... in another part of your application:map1 = sd.getLocalMap("mymap1");

String val = map1.get("foo");

map2 = sd.getLocalMap("mymap2");

Buffer buff = map2.get("eek");

Cluster-wide asynchronous maps

宽集群异步共享maps

Cluster-wide asynchronous maps allow data to be put in the map from any node of the cluster and retrieved from any other node.

宽集群共享map允许从任何集群点、和任何节点上获取共享数据。

This makes them really useful for things like storing session state in a farm of servers hosting a Vert.x web application.

You get an instance of AsyncMap with getClusterWideMap.

这个非常有用,例如存储session状态在一个web应用的集群里。你可以获得一个AsyncMap从getClusterWideMap里。

Getting the map is asynchronous and the result is returned to you in the handler that you specify. Here’s an example:

获取map是异步返回的,你可以单独处理返回结果。

SharedData sd = vertx.sharedData();

sd.<String, String>getClusterWideMap("mymap", res -> {
  if (res.succeeded()) {
    AsyncMap<String, String> map = res.result();
  } else {
    // Something went wrong!
  }
});

Putting data in a map

设置共享数据。

You put data in a map with put.

你可以用put方法设置数据。

The actual put is asynchronous and the handler is notified once it is complete:

事实上put是异步的,hander里会有通知一旦设置完成。

map.put("foo", "bar", resPut -> {
  if (resPut.succeeded()) {
    // Successfully put the value
  } else {
    // Something went wrong!
  }
});

Getting data from a map

获取数据从map里。

You get data from a map with get.

你可以获取数据用get。

The actual get is asynchronous and the handler is notified with the result some time later

实际上获取也是异步的,可以在hander里获取结果。

map.get("foo", resGet -> {
  if (resGet.succeeded()) {
    // Successfully got the value
    Object val = resGet.result();
  } else {
    // Something went wrong!
  }
});

Other map operations

map的其他操作。

You can also remove entries from an asynchronous map, clear them and get the size.

你也可以异步删除、清空map里的实例、和获取map的size。

See the API docs for more information.

查看更多。

Cluster-wide locks

宽集群的锁。

Cluster wide locks allow you to obtain exclusive locks across the cluster - this is useful when you want to do something or access a resource on only one node of a cluster at any one time.

宽集群锁。

Cluster wide locks have an asynchronous API unlike most lock APIs which block the calling thread until the lock is obtained.

宽集群锁有一个异步的方法不像大部分锁的api,它锁的时候会阻止访问线程直到锁成功。

To obtain a lock use getLock.

获取一个锁用getLock。

This won’t block, but when the lock is available, the handler will be called with an instance of Lock, signifying that you now own the lock.

这个不阻止,当锁有效,则handler会被执行,标示着你用了这个锁。

While you own the lock no other caller, anywhere on the cluster will be able to obtain the lock.

When you’ve finished with the lock, you call release to release it, so another caller can obtain it.

sd.getLock("mylock", res -> {
  if (res.succeeded()) {
    // Got the lock!
    Lock lock = res.result();

    // 5 seconds later we release the lock so someone else can get it

    vertx.setTimer(5000, tid -> lock.release());

  } else {
    // Something went wrong
  }
});

You can also get a lock with a timeout. If it fails to obtain the lock within the timeout the handler will be called with a failure:

你可以延时来获取某个锁,如果获取锁超时失败了,会返回一个失败failure。

sd.getLockWithTimeout("mylock", 10000, res -> {
  if (res.succeeded()) {
    // Got the lock!
    Lock lock = res.result();

  } else {
    // Failed to get lock
  }
});

Cluster-wide counters

集群计数器。

It’s often useful to maintain an atomic counter across the different nodes of your application.

如果你经常用一个原子的计数器在不同的节点之间。

You can do this with Counter.

你可以用Counter来做。

You obtain an instance with getCounter:

通过getCounter来获得。

sd.getCounter("mycounter", res -> {
  if (res.succeeded()) {
    Counter counter = res.result();
  } else {
    // Something went wrong!
  }
});

Once you have an instance you can retrieve the current count, atomically increment it, decrement and add a value to it using the various methods.

一旦你获取了一个实例你可以获取当前计数,原子的,可增长,可减少的,可设置的通过各种方法。

See the API docs for more information.


© 著作权归作者所有

共有 人打赏支持
天舒
粉丝 11
博文 17
码字总数 9012
作品 0
东城
架构师
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
Vert.X 入门手记 (一) 介绍

Vert.X 中文站:vertx.tk(临时域名) 目前中文化正在进行中,有人来帮忙否?? QQ交流群:219655467 介绍 Vert.X是一个异步网络应用开发框架,用来开发高并发、异步、可伸缩、多语言支持的Web...

Vity
2014/03/04
0
0
使用Vert.x构建Web服务器和消息系统

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

力谱宿云
2016/06/20
1K
0
Vert.x 3.2.0 发布,JVM 上的 Node.js 替代

Vert.x 3.2.0 发布,主要更新如下: mcehref="http://vertx.io/docs/vertx-core/ceylon">vertx-lang-ceylon: the support of the mcehref="http://ceylon-lang.org/">Ceylon language! mceh......

oschina
2015/12/16
3.2K
10
服务共享 vertx Server sharing

Server sharing 服务共享 When several HTTP servers listen on the same port, vert.x orchestrates the request handling using a round-robin strategy. 当几个http服务监听同一个端口,v......

天舒
2016/04/19
39
0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

angular 解决其他电脑不能访问的问题。

ng serve --host 0.0.0.0 --disable-host-check

miaojiangmin
今天
1
0
优酷视频文件怎么转换格式

  以前在优酷上下载视频都只是在手机上观看,但随着科技的发展,对于视频的要求也逐渐增多,不再只是观看视频那么简单,在精彩的部分还会将其单独分割出来,然后进行视频剪辑,可以做出我们...

萤火的萤火
今天
0
0
数据结构:散列

在一个数据结构中查找key元素,用顺序查找、二分查找都需要经过一系列关键之比较才能查找到结果,平均查找长度与数据量有关,元素越多比较次数就越多。 如果根据元素的关键字就能知道元素的存...

京一
今天
1
0
Apache RocketMQ 正式开源分布式事务消息

近日,Apache RocketMQ 社区正式发布4.3版本。此次发布不仅包括提升性能,减少内存使用等原有特性增强,还修复了部分社区提出的若干问题,更重要的是该版本开源了社区最为关心的分布式事务消...

阿里云云栖社区
今天
32
0
使用JavaScript和MQTT开发物联网应用

如果说Java和C#哪个是最好的开发语言,无疑会挑起程序员之间的相互怒怼,那如果说JavaScript是动态性最好的语言,相信大家都不会有太大的争议。随着越来越多的硬件平台和开发板开始支持JavaS...

少年不搬砖老大徒伤悲
今天
0
0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

返回顶部
顶部