d******e 发帖数: 2265 | 1 同步异步?
需要做一个source (data gather with restful api) -> extraction -> query (http
)-> cmp->summary的pipeline.
应该选同步http client还是异步的? |
l**********n 发帖数: 8443 | 2 akka stream和http什么关系?akka stream是一种programming style, 类似于rxjava.
和http没啥必然联系
http
【在 d******e 的大作中提到】 : 同步异步? : 需要做一个source (data gather with restful api) -> extraction -> query (http : )-> cmp->summary的pipeline. : 应该选同步http client还是异步的?
|
p*****2 发帖数: 21240 | 3 akka不应该用同步吧
http
【在 d******e 的大作中提到】 : 同步异步? : 需要做一个source (data gather with restful api) -> extraction -> query (http : )-> cmp->summary的pipeline. : 应该选同步http client还是异步的?
|
z*******3 发帖数: 13709 | 4
rxjava.
不像rxjava吧,只要connection没有关闭就都可以做成streaming用
http, tcp都可以,udp也可以,http1不行
【在 l**********n 的大作中提到】 : akka stream和http什么关系?akka stream是一种programming style, 类似于rxjava. : 和http没啥必然联系 : : http
|
z*******3 发帖数: 13709 | 5 我知道为什么会说像rxjava了
因为有一个reactive stream
这个rxjava和akka stream都有impl
rxjava的例子在这里有
https://github.com/ReactiveX/RxJavaReactiveStreams/blob/0.x/examples/ratpack
/src/test/java/rx/reactivestreams/example/ratpack/RatpackExamples.java |
z*******3 发帖数: 13709 | |
d******e 发帖数: 2265 | 7 http是在akka stream上实现的。
akka给出了一些高级别的组件。
看上去可以用同步http,因为无法用queue传future.但是我不是很肯定。而且scala的
http client默认都是异步的。
rxjava.
【在 l**********n 的大作中提到】 : akka stream和http什么关系?akka stream是一种programming style, 类似于rxjava. : 和http没啥必然联系 : : http
|
d******e 发帖数: 2265 | 8 现在没有例子。网上搜了一个twitterclient例子貌似是同步的。
【在 p*****2 的大作中提到】 : akka不应该用同步吧 : : http
|
l**********n 发帖数: 8443 | 9 there is no difference. you can use Await to block and use Promise to do
async
【在 d******e 的大作中提到】 : 现在没有例子。网上搜了一个twitterclient例子貌似是同步的。
|
p*****2 发帖数: 21240 | 10
感觉同步against actor model呀。thread会被block,影响其他actors。话说回来还是
go方便。
【在 d******e 的大作中提到】 : 现在没有例子。网上搜了一个twitterclient例子貌似是同步的。
|
l**********n 发帖数: 8443 | 11 二爷转go了
【在 p*****2 的大作中提到】 : : 感觉同步against actor model呀。thread会被block,影响其他actors。话说回来还是 : go方便。
|
p*****2 发帖数: 21240 | 12
准备
【在 l**********n 的大作中提到】 : 二爷转go了
|