我正在使用一家提供实时流的数据供应商的Java API。我想使用Akka streams来处理这个流。Java API有一个pub sub设计，其工作原理大致如下： Subscription sub = createSubscription(); buffer.enqueue(e)}); 我曾尝试在自
浏览 32提问于2021-09-28得票数 1
回答已采纳
1回答
我仍然在分析线程转储，以找出服务器宕机的实际原因，但让我感到困惑的是为什么这两台服务器同时宕机。 at java.lang.Thread.run(java.base@11/Thread.java:834) at play
浏览 17提问于2019-10-22得票数 0
1回答
Java反应式框架的比较
、、、、
我看到许多框架/库声称它们可以帮助在Java语言中构建响应式应用程序，例如: Akka、Vert.x、RxJava、Reactor、QBit等。可以驱动选择Java反应式框架的应用程序需求是什么？
谢谢您抽时间见我。
浏览 6提问于2015-11-12得票数 35
回答已采纳
1回答
在访问/swagger.json端点时，我从swagger库抛出了以下错误。:44)at akka.dispatch.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
at akka.dispatch.forkjoin.ForkJoinPool.runWorker
浏览 16提问于2019-06-14得票数 0
回答已采纳
1回答
即使在我导入证书之后
、、、、
当我在windows系统上运行此程序时，错误将得到解决。但是，当我在一分OS系统中遵循相同的解决方案时，错误仍然存在。 at play.api.libs.streams.StrictAccumulator$$anonfun$mapFuture$
浏览 7提问于2019-11-29得票数 0
在迁移到Play 2.5时，我试图实现新的WebSocket功能，如描述的(用参与者处理WebSockets )。在Play 2.5.4中没有play.libs.streams.ActorFlow (如示例所示)，而只有play.api.libs.streams.ActorFlow。>转换
有谁能解释一下如何在2.5中实现这种方法？我为什么会犯这个错误？
浏览 9提问于2016-08-01得票数 1
我想使用IAsyncEnumerable作为akka streams的源码。但是我没有找到，怎么做呢。using System.Threading.Tasks;
namespace ConsoleApp1
浏览 5提问于2021-09-22得票数 0
我发现了大量使用Akka角色在Scala中处理套接字的示例，但Java API中没有IO。我应该如何在一个Akka参与者中使用Java中的套接字？套接字周围有没有任何包装器，可以使用消息与套接字通信？
浏览 0提问于2012-07-08得票数 0
)
我在Main.scala中的代码片段import akka.stream.ActorMaterializer: akka.actor.ActorCell.addFunctionRef(Lscala/Function2;)Lakka/actor/FunctionRef;
at akka.stream.
浏览 4提问于2016-02-23得票数 3
回答已采纳
我试图通过使用akka流参考文件将音频流从服务A发送到服务B (akka-streams库版本: 2.6.3)。一切都运行得很好，除了每月一次在akka流引用中抛出异常(每天使用该服务的次数约为50k )外，我找不到问题的原因。$anonfun$callback$1(GraphStage.scala:202)
at akka.stream.stage.GraphStageLogic$StageActor(ActorGraphIn
浏览 1提问于2020-03-30得票数 0
回答已采纳
正如您所看到的，我已经将我的pojos放在名为hibernate.cfg.xml和models的包中conf中。<?$anonfun$apply$2(Action.scala:96) at play.api.libs.streams.StrictAcc
浏览 2提问于2017-12-25得票数 0
回答已采纳
1回答
我使用作为一个Akka-Http，Akka-Streams项目的连接器。我创建的MongoConnection如下所示，但是数据库中的数据是使用Snappy压缩的。无论我往哪里看，在ReactiveMongo文档中都找不到任何关于压缩支持的内容。当我尝试使用带有compressors=snappy标志的URL连接到Mongo数据库时，它返回一个异常。To change default exception handling behavior, provide a custom Except
浏览 3提问于2021-03-04得票数 0
我正在尝试使用Java11中的HttpClient从Java API调用Scala服务。在Java API上，代码如下所示： var client = HttpClient.newHttpClient(); .build();
var response = client.send(request, HttpResponse.BodyHandlers.ofSt
浏览 39提问于2021-10-06得票数 0
$anonfun$apply$2(Action.scala:98) at scala.util.Try$.apply(Try.scala:213) at pla
浏览 0提问于2020-06-01得票数 1
1回答
现在我正在阅读Play Java的文档。我不明白这些句子解释了apply(RequestHeader header)到底在起什么作用。
方法的返回类型是累加器。一个累加器异步地将元素流累加到一个结果中，它可以通过传入一个Akka流源来运行，这将返回一个CompletionStage，当累加器完成时将被赎回。它与Sink>本质上是一样的，实际上它只不过是这种类型的包装器，但最大的区别是，累加器提供了方便的方法，如map、mapFuture、recover等，用于处理结果，就好像它是一个承诺，Sink
浏览 0提问于2017-01-27得票数 1
1回答
我试图在浏览器中使用ng-file-upload上传一个ng-file-upload文件，并在后端播放Scala2.5.x。如果我在播放中使用moveTo，则会上载该文件，但该文件是由头文件和拖车生成的，而不是普通文件： }
Ok("file uploaded
浏览 10提问于2016-10-18得票数 0
回答已采纳
所以我在Akka Streams中使用了这个小小的自定义阶段来进行分区。object CustomPartitioner {
* Creates a Partition stage that, given a type A, makes a decision* */
def apply[A, B, C](partitionF: A => Either[B, C]然后将它
浏览 4提问于2019-04-24得票数 0
回答已采纳
Java8中引入的CompletableFutures为scala.concurrent.Future中可用的语言特性带来了一些特性，比如一元转换。是否仍然有很好的理由通过scala.concurrent.Future桥在Java中使用akka.dispatch？
浏览 0提问于2015-02-18得票数 17
回答已采纳
我从REST端点访问数据： "https://api-public.sandbox.pro.coinbase.com/products/BTC-EUR/ticker" 为了每秒访问一次数据，我使用一个无限循环{ val rData = scala.io.Source.fromURL("https://api-public.sandbox
浏览 15提问于2020-09-27得票数 0
回答已采纳
当我在电脑上安装插件时，一切都很好。但是当插件构建在GitLab的管道中时，构建失败了，因为没有找到依赖项。未找到的依赖项托管在包注册表中。我试图删除所有的gradle缓存，然后在我的计算机上重新构建。依赖性是按预期下载的。因此，这使我说，艺术品可以在包注册表中获得。我安装的gradle版本与包装器相同(gradle 6.5.1)。我还试着在我的电脑上运行包装器，以防万一，它也能正常工作。test
- publi
浏览 10提问于2020-08-09得票数 2
云服务器
ICP备案
对象存储
云点播
智聆口语评测
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号