腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(1264)
视频
沙龙
1
回答
如
何在
应用程序
重启
时
维护
Alpakka
/
Akka
流
的
源
状态
?
scala
、
akka
、
akka-stream
、
alpakka
我是
Alpakka
的
新手,正在考虑将其用于系统集成。在
应用程序
重新启动
时
维护
Akka
Streams
源
的
状态
的
理想方式是什么? 例如:假设我使用如下代码连续读取一些输入数据并将其转储到某个位置。如果它运行4小
时
,然后整个JVM崩溃并重新启动(例如,k8s重新启动我
的
pod或更多): someSource .via(s
浏览 20
提问于2019-12-28
得票数 1
2
回答
在父供应商执行元重新启动
时
不重新启动处理执行元
java
、
scala
、
akka
、
actor
首先,我对
Akka
和演员模型非常陌生,所以也许我做
的
每件事都是错
的
。 我有一个输入actor,它从
流
源
获取数据,并将它们传递给子处理器actor,子处理器actor具有一些内部
状态
。如果Input actor
的
连接中断,可能会崩溃,从而触发其
重启
。问题是,除此之外,这还会触发其子进程
的
重启
,从而使其丢失
状态
。我不希望发生这种情况,因为输入流可能会恢复,它们
的
状态
将
浏览 4
提问于2016-08-05
得票数 0
回答已采纳
2
回答
是否可以使用AkkaHttp、AkkaStreams、
Alpakka
和数据库构建OLTP/AkkaHttp服务器?
akka
、
akka-stream
、
akka-http
、
alpakka
在我看来,使用actors当然是可能
的
:例如,使用AkkaHttp和类型化
的
参与者。但是,我不清楚是否只使用AkkaStreams及其
Alpakka
连接器库(其中包括数据库),是否可以执行常规CRUD / OLTP服务,或者仅仅从一个数据库复制数据到另一个数据库,或者其他OLAP /批处理/
流
处理场景。如果您知道如何做到这一点,请指出一些细节,如果您可以提供一个例子
的
github,例如,这将是很好
的
。 我认为服务器可能涉及两个会话/有
状态<
浏览 1
提问于2020-02-10
得票数 1
回答已采纳
1
回答
使用
akka
流
和喷雾将csv文件传输到浏览器
scala
、
akka
、
spray
、
akka-stream
我认为来自
的
修改版
的
将运行良好,但我在连接这些部分时遇到了困难。考虑到source: Source[String, Unit]和ctx: RequestContext,我认为修改后
的
StreamingActor应该与actorRefFactory.actorOf(fromSource为供参考,以上要点:import
akka
.util.ByteStringimport
浏览 1
提问于2015-11-05
得票数 0
1
回答
Akka
流在阶段失败
时
重新创建
流
scala
、
akka
、
akka-stream
我有非常简单
的
Akka
流
,它使用
alpakka
从Kafka读取msg,对msg执行一些操作,并将其索引到Elasticsearch。我使用
的
是CommitableSource,因此我
的
策略至少是一次。只有当索引到ES成功
时
,我才提交偏移量,如果它失败,我将再次读取消息,因为表单最新
的
已知偏移量。是重新启动整个
流
源
->
流
-> Sink.如果出于任何原因,我无法在弹性索引消息。我尝试了以下几
浏览 0
提问于2018-07-08
得票数 2
3
回答
Akka
流
-将ByteString
流
拆分为多个文件
scala
、
stream
、
akka
、
akka-stream
我试图将传入
的
Akka
字节流(从http请求
的
主体中分离出来,但也可以从文件中分离出来)分成多个定义大小
的
文件。 例如,如果我上传一个10 1Gb文件,它会创建大约10个1GB
的
文件。我
的
问题是,我真的不知道从哪里开始,因为我读过
的
所有响应和示例要么将整个块存储到内存中,要么使用基于字符串
的
分隔符。除了我不能真的有1Gb
的
“块”,然后把它们写到磁盘上。有什么简单
的
方法来做这样
的
手术吗?我唯一
浏览 2
提问于2016-12-30
得票数 4
回答已采纳
1
回答
Akka
流
的
多个Kafka分区
java
、
apache-kafka
、
akka
、
akka-stream
嗨,我和Kafka和
Akka
Streams一起工作。在Kafka中,对于主题MyTestTopic,我有3个分区,数据在高度并发
的
情况下被推入主题,大致上是1000 QPS,它只会比这个更高。下面是我为
Akka
Stream Kafka使用者编写
的
代码: ConsumerSettings.createDuration.ofSeconds(timeout)))) .
浏览 5
提问于2019-12-09
得票数 0
2
回答
如何对参与者集合执行查询
akka
、
akka.net
这些参与者
的
状态
是持久化
的
Akka
.Persistance。现在我们要为这个参与者系统构建查询系统。基本上,我们
的
问题是,我们希望有一种方法来获得这些特定参与者
的
所有
状态
的
汇总/列表。虽然我没有严格地订阅CQRS模式,但我认为这可能是一种很好
的
方式。 我最初
的
想法是有一个参与者来查询,作为其
状态
的
一部分,它包含正在执行“数据写入”
的
其他参与者
的<
浏览 2
提问于2017-01-26
得票数 4
回答已采纳
2
回答
Akka
streams vs Apache Flink
apache-flink
、
akka-stream
在探索
Akka
流
时
,我还遇到了Apache哪个
流
处理引擎。
Akka
流
实现反应
流
并支持背压。 那么,如果我要在两者之间做出决定,我应该选择哪一个呢?它们有何不同之处,相似之处
何在
?这里
的
标准应该是什么?
浏览 3
提问于2020-04-23
得票数 4
回答已采纳
4
回答
阿帕奇星火对阿克卡
apache-spark
、
parallel-processing
、
akka
、
distributed-computing
你能告诉我Apache和
AKKA
之间
的
区别吗?我知道这两个框架都是用来编写分布式计算和并行计算
的
程序,但我看不出它们之间
的
联系或区别。 此外,我想得到适合其中每一个
的
用例。
浏览 13
提问于2015-03-16
得票数 67
回答已采纳
5
回答
卡夫卡对卡夫卡
流
scala
、
akka-stream
、
apache-kafka-streams
、
typesafe
、
stream-processing
我知道,基于
Akka
的
方法实现了反作用规范,并处理了kafka
流
似乎缺乏
的
背压和功能。 卡夫卡
流
比卡夫卡
流
有什么优势?
浏览 6
提问于2017-08-11
得票数 49
回答已采纳
1
回答
在
Akka
中,PersistentView
的
典型用例是什么?
akka
、
system.reactive
、
akka-stream
、
event-sourcing
、
akka-persistence
这里写
的
是: 它与 / RX有何不同? 看上去和我很像。
浏览 4
提问于2017-03-29
得票数 1
回答已采纳
1
回答
将WebSocket从Play迁移到
Akka
HTTP
websocket
、
akka-stream
、
akka-http
我在Play
应用程序
中有一个WebSocket服务器,我想将其移动到
akka
-http服务。我目前使用
的
是ActorFlow.actorRef,它是在
Akka
中不存在
的
Play
的
一部分。当WebSocket被接受
时
,我订阅一个RabbitMQ队列,并将每条消息转发给WebSocket。当我收到来自WebSocket
的
消息
时
,我会在本地处理一些消息,并将其他消息转发到RabbitMQ交换。 我如何使用
akka
-http
浏览 1
提问于2016-09-20
得票数 0
2
回答
阿克卡
流
中任意阶段失效
的
重试
流
java
、
akka
、
akka-stream
、
retry-logic
我使用
akka
流来处理我
的
数据。其中我有一个源代码,它由元素UUID组成。 最后,我用
流
中所有元素
的
状态
更新DB。现在,我想在这个
流
中添加重试机制,这样如果
流
中
的
任
浏览 0
提问于2018-06-21
得票数 5
2
回答
如何使用Kafka实现事件
源
?
apache-kafka
、
event-sourcing
我想用kafka作为事件商店来实现事件
源
模式。我想让它尽可能简单。我
的
应用程序
包含一个客户列表。客户将被创建并删除。非常简单。当出现创建客户
的
请求
时
,我将创建事件CUSTOMER_CREATED (包括客户数据),并使用KafkaProducer将其存储在卡夫卡主题中。在使用事件CUSTOMER_DELETED删除客户
时
也是如此。 现在,当我想列出所有客户
时
,我必须重播到目前为止发生
的
所有事件,然后得到当前
状态
,即所有
浏览 0
提问于2019-01-19
得票数 0
1
回答
弹簧云断路器
spring-cloud
、
hystrix
、
circuit-breaker
Hystrix主要用于使用spring云构建
的
应用程序
。话虽如此,一个
应用程序
可能有多个服务层。例如Amazon (Amazon站点必须有多种服务,
如
登录、产品、手推车、订单、支付等)在这种
浏览 1
提问于2018-01-30
得票数 2
回答已采纳
4
回答
用于实现CQRS、事件
源
和Saga以实现数据一致性和分布式事务
的
流行框架是什么?
asynchronous
、
frameworks
、
cqrs
、
event-sourcing
、
data-consistency
我想知道一些流行
的
框架,可用于在
应用程序
中实现CQRS、ES、Saga。 作为我研究
的
一部分,我必须比较这些框架,并根据各种-ilities对它们进行评估。
浏览 7
提问于2021-05-27
得票数 1
2
回答
卡夫卡
流
如何用于事件
源
?
apache-kafka
、
microservices
、
apache-kafka-streams
、
cqrs
、
event-sourcing
我读到了如何通过使用Apache作为事件代理来实现事件
源
。() 如果我们看一下这张图片,它会显示事件是如何被写入Kafka
的
,然后Kafka
流
被用来在数据库中创建视图。我在这里
的
问题是,我们如何才能使用卡夫卡
流
实现这一目标?如果我正确的话,它是一个客户端库,所以我们需要使用它
的
东西,比如一个名为“聚合服务”
的
微服务。这是实现这种设计
的
正确方法吗?它
的
规模会很好吗?
浏览 8
提问于2022-08-01
得票数 0
1
回答
在非浏览器客户端使用cookies,例如Php - Android
php
、
android
、
web-services
、
cookies
、
session-cookies
如
何在
非浏览器客户端(
如
Php - Android)中使用cookies来
维护
会话和其他信息。我
的
网站是基于cookies来
维护
状态
的
,现在当我为移动
应用程序
编写web服务
时
,发现网站将每个API调用视为来自唯一用户,因为cookies不存在。如
何在
PHP(Web服务)和android
应用程序
之间使用cookies?
浏览 0
提问于2014-04-22
得票数 0
1
回答
Alpakka
Kafka Java测试
java
、
apache-kafka
、
playframework
、
testcontainers
、
alpakka
我试图为一个
应用程序
编写Junit测试,该
应用程序
使用kafka
流
将数据从kafka发送到websocket连接。我已经能够在本地运行
应用程序
,发布到主题并看到套接字连接上返回
的
数据。.map(consumerRecord -> objectMapper.convertValue(consumerRecord, JsonNode.class));然后,我在这里
的
流
中使用这个
源
import
akka
.actor.Ac
浏览 3
提问于2022-02-09
得票数 0
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
如何在生产中为机器学习模型提供服务?
GrowingIO 响应式编程探索和实践
关于Spark Streaming 技术要点的一些汇总
Akka Actor及其在商业智能数据服务中的应用
58一站式数据分析平台云窗的实践之路
热门
标签
更多标签
活动推荐
运营活动
广告
关闭
领券