我从REST端点访问数据： "https://api-public.sandbox.pro.coinbase.com/products/BTC-EUR/ticker" 为了每秒访问一次数据，我使用一个无限循环while(true) {来调用每秒一次发送给执行元的消息，这将开始调用REST请求的过程： 访问数据的actor为： object ProductTickerRestActor {
case class: " +
浏览 15提问于2020-09-27得票数 0
回答已采纳
2回答
如果我是用Java编写代码的话，我可以在REST中使用JaxRS，在服务器到服务器之间进行通信时可以轻松地进行RPC设置。interface UsersApi { @GET}
创建了该接口的具体实现，将其作为路由添加到我的服务器代码中返回一个代理，我只需调用getUsers()方法即
浏览 7提问于2017-12-05得票数 5
1回答
我们在应用程序中使用了Akka actors。参与者调用服务，在某些情况下，这些服务调用由第三方公开的rest API。现在第三方API需要很长时间才能响应。由于这一点，在高峰时间，系统吞吐量受到影响，因为线程在等待客户端API响应时被阻塞。
有时在高峰期，因为线程正在等待，消息只会在akka邮箱中等待很长时间，一旦阻塞的线程可用，消息就会被提取。我正在考虑使用Future将rest</em
浏览 10提问于2020-05-22得票数 0
1回答
我熟悉在JVM (Java/nio，Scala/Akka)上根据两种范式(阻塞和非阻塞)进行编程。然而，我看到了一种灰色地带，这让我感到困惑。但在这两个极端之间是什么呢？读/写小文件、本地套接字，或者对嵌入式数据存
浏览 0提问于2017-08-06得票数 1
我试图从概念上理解为什么在Play Framework2.0中，为web服务调用调用WS.url().get()被认为是一种最佳实践，但是如果您将任何其他阻塞调用(如JDBC调用)包装在承诺中，那么建议您在默认执行上下文之外的执行上下文中这样做我知道，默认情况下，Play Framework的线程池被配置为每个内核都有一个线程，每个控制器都希望运行完全非阻塞的代码。出于这个原因，如
浏览 0提问于2014-08-30得票数 3
回答已采纳
使基于REST的web服务(POST)异步是一次处理数千个请求的最佳方式吗(请记住，我只有一个服务器实例为请求提供服务)？
编辑: Jersey被错误标记。例如:我有一个基于rest的web服务，它应该在很短的时间内(~60秒)被10万个客户端使用。我知道，如果允许我部署服务器的多个实例，那么我就可以使用负载均衡器来处理所有传入的请求，并相应地委托它们。但我被限制只能使用单个实例。在这种限制下，我可以选择什么设计？我
浏览 10提问于2017-01-08得票数 2
2回答
应该如何为使用参与者的REST服务创建应用程序体系结构？行为者应：
演员=微型服务这是一个高层次的层。应用程序中的每个微服务都应该作为单独的参与者工作吗？我不能这样理解--我应该如何正确地使用演员？如果我用层(控制器、服务、DAO和数据库)创建REST</
浏览 0提问于2018-12-09得票数 0
2回答
我正在使用spring mvc/boot学习rest。我理解基本的rest调用，但我在理解长时间运行/非阻塞rest调用时遇到了问题。我知道对于长时间运行的rest调用，我们会启动一个单独的线程，服务器会向客户端返回一个DeferredResult对象，但是当处理线程完成时，如何通知客户端呢？谁能给我一个如何在客户端处理这个问题的例子？
另外，非</em
浏览 1提问于2016-12-25得票数 2
当接收事件时，Akka Actors将一次处理一条消息，在进入下一条消息之前阻塞，直到请求完成。}
这感觉像是一种非常错误的方法--它在代码中人
浏览 1提问于2016-04-13得票数 19
1回答
阿克卡演员如何清理资源？
、、、、
在使用Akka HTTP构建的web服务器上，我们正在经历奇怪的内存行为。我们的架构是这样的：
responseactors web服务器路由调用各种参与者，获取未来的结果，并将其流到调用非阻塞操作(使用期货)，合并和处理从中获取的数据，并将结果输送到发送方。我们使用标准的Akka演员，实现它的接收方法(不是Akka类型的)在应用程序中没有阻塞<
浏览 1提问于2020-07-16得票数 1
1回答
我正在尝试一个简单的akka数据流示例，如下所示：}
我还在scala编译器设置的P字段中设置了continuations:enable。
浏览 0提问于2013-04-16得票数 1
回答已采纳
没有Promise<Result>，没有Akka之类的东西。
如果你使用普通的MySQL驱动程序进行数据库查询，你不会阻塞主服务器线程吗？我遗漏了什么？
浏览 3提问于2012-11-29得票数 4
回答已采纳
1回答
我试图使用Akka流同时处理一系列依赖的流。目前，代码需要11秒才能完成。我可以很容易地削减它使用原始演员，而没有适当处理背压的好处。有什么办法让这件事更并发吗？
浏览 4提问于2017-10-02得票数 0
回答已采纳
1回答
在Java 8中使用Play Framework 2.5.9，并尝试遵循异步、非阻塞模型的良好实践。通过异步和非阻塞地调用其他服务，我无法将来自该服务的响应
浏览 1提问于2017-04-14得票数 0
我使用的是scala的未来，而不是Akka，我认为从Play 2.1开始做的事情是正确的。如何在保持代码非阻塞的情况下将java.util.concurrent.Future封装到scala.concurrent.Future中？，但使用了get，因此它变成了阻塞 future {
// how to
浏览 5提问于2013-06-20得票数 21
2回答
我正在使用Play Framework2.2作为我即将使用的web应用程序之一。我用同步模式实现了我的控制器，使用了几个阻塞调用(主要是数据库)。return ok();因此，在优化代码的同时，决定使用对Play的异步编程支持。看了一下文档，但是这个想法对我来说仍然很模糊，因为我对如何正确地将上面的同步代码块转换为异步感到困惑。所以，我想出了下面的代码：public static Promise<Result
浏览 4提问于2014-03-15得票数 10
我使用Spring WebFlux (WebClient)编写REST服务。对于每个传入的请求，我向另一个REST服务发出数百个请求，因此为了使它们尽可能快，我想使用无阻塞线程。让我得到客户端的请求，我必须发出600个API调用：
List<String> urls = Arrays.asList("www.example-rest.com/url1", "www.example-<
浏览 2提问于2017-12-31得票数 1
1回答
我正在尝试确定在Spring MVC中实现处理长时间运行的批处理作业的最佳方式。在我的搜索中，我发现Akka是一个用于aync处理的非阻塞框架，这是首选的，因为我不希望批处理吞噬线程池中的所有线程。从本质上讲，我要做的是让一个作业按设定的时间表运行，它将调用各种web服务，处理数据，并将其持久化。
我见过一些与Spring一起使用它的代码示例，但我从未见过它与CRON类型的调度器一起使用。它似乎总是使用</e
浏览 0提问于2015-04-24得票数 0
我需要使用Spring批处理从SQL DB中读取一堆行(数千行)，并在写入Kafka主题之前调用REST服务来丰富内容。当使用Spring反应性webClient时，如何限制活动的非阻塞服务调用的数量？我是否应该在使用Spring批处理读取数据之后，在循环中引入一个Flux？(我理解delayElements的用法，它具有不同的用途，比如当单个Get服务调用带来大
浏览 2提问于2018-07-30得票数 4
回答已采纳
我的应用程序是一个HTTP服务，它公开了其他服务可以使用的几个API，在这种情况下，我不得不调用两个不同的外部服务，它们将是一个消息传递服务和另一个REST服务。我理解对于这些I/O绑定操作，使用单独的线程池或ExecutionContext是一个很好的实践。我正在使用以下方法为我的application.conf中的自定义application.conf创建一个配置：
execution
浏览 2提问于2016-04-17得票数 2
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
腾讯会议
云直播
对象存储活动推荐
腾讯云开发者
