p*****2
发帖数: 21240 | 1 这个链接的例子意义不大呀。自己都说了跟sync的call一样的。cassandra在java里怎
么做async query呢。有大牛做过吗？
http://www.datastax.com/documentation/developer/java-driver/1.0 |
z****e
发帖数: 54598 | 2 我用vertx包了一层
随便用scala/java写一个verticle就搞定了
很容易 |
p*****2
发帖数: 21240 | 3
底层的IO还是blocking的吧？
【在 z****e 的大作中提到】
: 我用vertx包了一层
: 随便用scala/java写一个verticle就搞定了
: 很容易
|
c******o
发帖数: 1277 | 4 据我所知，没有好的reactive(async) 的jvm C＊driver.
这也是为什么我们mongo的原因之一。 |
s********k
发帖数: 6180 | 5 Mongo有什么好的reactive(async)的driver？
【在 c******o 的大作中提到】
: 据我所知，没有好的reactive(async) 的jvm C＊driver.
: 这也是为什么我们mongo的原因之一。
|
c******o
发帖数: 1277 | |
z****e
发帖数: 54598 | 7 嗯，vert.x可以勉强做到aysn*
但是要做到reactive的话，需要rxjava
https://github.com/ReactiveX/RxJava
rxjava 4天前已经rc2了，等这个出来之后
就可以组合实现aysn* driver的效果了
而不用blocked等待
【在 c******o 的大作中提到】
: 据我所知，没有好的reactive(async) 的jvm C＊driver.
: 这也是为什么我们mongo的原因之一。
|
z****e
发帖数: 54598 | 8 你真的应该试试vert.x
最新版本也支持scala了
想怎么耍就怎么耍，随便搞
而不用拘泥于具体的单个framework
可以打组合拳，这个不足那个补
很爽
【在 c******o 的大作中提到】
: 据我所知，没有好的reactive(async) 的jvm C＊driver.
: 这也是为什么我们mongo的原因之一。
|
c******o
发帖数: 1277 | |
p*****2
发帖数: 21240 | 10
多谢大牛
【在 c******o 的大作中提到】
: 据我所知，没有好的reactive(async) 的jvm C＊driver.
: 这也是为什么我们mongo的原因之一。
|
z****e
发帖数: 54598 | 11 只是建议你try一下啦
不要拘泥于那么一两个框架
能用的东西很多，又不是不让你用scala
眼光要开阔一点嘛
【在 c******o 的大作中提到】
: 一个framework还没搞定呢。。。
|
p*****g
发帖数: 7 | 12
From http://stackoverflow.com/questions/22322510/is-there-a-good-way-to-check-whether-a-datastax-session-executeasync-has-throw
You could try something like this since the ResultSetFuture implements
ListenableFuture from the Guava library:
ResultSetFuture resultSetFuture = session.executeAsync("SELECT * FROM
test.t;");
Futures.addCallback(resultSetFuture, new FutureCallback() {
@Override
public void onSuccess(@Nullable com.datastax.driver.core.ResultSet
resultSet) {
// do nothing
}
@Override
public void onFailure(Throwable throwable) {
System.out.printf("Failed with: %sn", throwable);
}
});
This approach will not block your application.
【在 p*****2 的大作中提到】
: 这个链接的例子意义不大呀。自己都说了跟sync的call一样的。cassandra在java里怎
: 么做async query呢。有大牛做过吗？
: http://www.datastax.com/documentation/developer/java-driver/1.0
|
p*****2
发帖数: 21240 | 13 多谢了 今天试试
【在 p*****g 的大作中提到】
:
: From http://stackoverflow.com/questions/22322510/is-there-a-good-way-to-check-whether-a-datastax-session-executeasync-has-throw
: You could try something like this since the ResultSetFuture implements
: ListenableFuture from the Guava library:
: ResultSetFuture resultSetFuture = session.executeAsync("SELECT * FROM
: test.t;");
: Futures.addCallback(resultSetFuture, new FutureCallback() {
: @Override
: public void onSuccess(@Nullable com.datastax.driver.core.ResultSet
: resultSet) {
|
z****e
发帖数: 54598 | 14 这个呢？
http://github.com/datastax/java-driver
【在 c******o 的大作中提到】
: 据我所知，没有好的reactive(async) 的jvm C＊driver.
: 这也是为什么我们mongo的原因之一。
|
