腾讯云
开发者社区
文档
建议反馈
控制台
登录/注册
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
视频
沙龙
1
回答
分布式系统在哪里发送请求?
、
分布式系统中的不同组件如何知道在哪里发送消息来访问某些服务? 例如,假设我有一个处理身份验证的服务和一个处理搜索的服务。处理搜索的组件如何知道在哪里发送身份验证请求?子域是否更常用?如果是的话,复制在这个场景中是如何工作的?是否有处理所有这些路由的本地IP地址的注册表?
浏览 3
提问于2014-12-07
得票数 1
回答已采纳
1
回答
分布式系统中的消息传递与RPC (Openstack与K8s/Swarm)
、
、
、
、
OpenStack使用消息传递(我想是默认的RabbitMQ ?)用于节点之间的通信。另一方面,Kubernetes (继承了Google内部的Borg)使用RPC。Docker的swarm也使用RPC。两者都是基于gRPC/protofbuf的,这似乎在Google内部也被大量使用。 我知道像Kafka这样的消息平台被广泛用于流数据和日志聚合。但是像OpenStack,Kubernetes,Docker Swarm等系统需要在节点之间进行特定的交互,而远程过程调用似乎是一个自然而然的选择,因为它允许为特定的操作定义API。 OpenStack是在评估消息传递与远程过程调用的优缺点后选择消息传
浏览 72
提问于2017-12-02
得票数 23
1
回答
AKKA:将本地资源传递给参与者
、
让我们假设我想使用AKKA参与者模型来创建一个程序,处理来自文件的数据。据我所知,由于该模型正在获胜,如果参与者真的不知道他们在哪里运行,那么传递消息中的文件路径应该是错误的-some参与者,而应用程序可能无法访问该路径-。相反,由于资源问题,将整个文件作为字节传递将不是一个选项(如果文件越来越大怎么办?)处理这种情况的正确策略是什么?在同一个问题上:假设有一个分布式文件系统会成为接受路径作为消息的好借口吗?
浏览 4
提问于2022-02-21
得票数 1
回答已采纳
4
回答
了解数据库复制机制的最好来源是什么?
、
、
对不同复制方法和问题的最广泛的概述和最深入的分析在哪里?
浏览 11
提问于2008-09-19
得票数 1
回答已采纳
1
回答
如何实现并发原语?
、
我在哪里可以找到关于并发原语通常是如何实现的信息(书籍、论文、教程)?我最感兴趣的是进程间通信或消息传递(同步和异步)的实现:发送、接收、选择等。
浏览 0
提问于2010-10-25
得票数 1
回答已采纳
2
回答
如何通过卡夫卡传输大文件?
、
我正在将基于酸的monolith迁移到基于事件的微服务体系结构。在monolith中,潜在的大型文件存储在数据库中,我希望与微服务共享这些信息(包括文件内容)。 我的方法是将文件分割成有编号的块,并发送几条消息(例如,带有元数据和id的一个FileCreatedMessage,后面是包含该块及其序列号的n FileContentMessage )。在接收端,消息可能不会按顺序到达。因此,我会存储消息块,订购并加入它们,并存储结果。 有什么方法可以让我用一条消息或另一条信息通过Kafka传输数据,而不需要为几条消息实现分片、排序和连接逻辑的开销? 我注意到卡夫卡溪流。它似乎解决了与这个不同的问题
浏览 0
提问于2019-06-09
得票数 5
回答已采纳
1
回答
用于Eclipse的MapReduce或Hadoop插件
、
我正在寻找Eclipse中的一个插件,它可以在使用Java创建MapReduce作业时自动完成一些工作。 例如: 自动创建Mapper -还原类(实现接口)。 提供一些样品开始。
浏览 0
提问于2014-06-20
得票数 2
回答已采纳
1
回答
使用J测量仪进行性能负载测试,以及资产文件对结果的影响
、
、
、
、
各位,今天好, 我一直在和Jmeter一起玩一个负载测试项目。我在寻找一种模拟完全/真实用户行为的方法,从加载应用程序的主页开始,进行登录,然后向某个用户发送预定义的消息,并加载所有资产文件和图像,而不仅仅是直接的API调用。 使用简单的方法执行前面的步骤会有点复杂,而且需要更长的时间。 我已经找到了这个铬扩展(),它可以帮助记录一组操作,并以J抄格式导出它。 但, 它只记录直接API调用,不加载任何资产或套接字/WebSocket会话。 。 考虑到我们可以将与Jmeter结合使用,就可以解决这种状态。但是,如果您要使用10k或更多的用户进行测试(参考资料限制),这将不
浏览 1
提问于2019-08-12
得票数 3
回答已采纳
1
回答
RabbitMQ / AMQP:多个队列,单个使用者
、
、
我想要创建一个使用者,它处理来自多个变量数目的消息,这些消息是动态连接或断开连接的。 我需要的是每个消费者首先优先处理每个源的N条消息。然后运行多个消费者来提高速度。 我一直在阅读、和以及许多其他文档的文档,而没有确定如何实现这一点。而且我也做了一些没有运气的测试。 有人能指点我怎么做或者在哪里读到吗? -编辑-- QueueA-A3-A2-A1-┐ QueueB QueueC-┘ 所期望的效果是每个使用者获得每个队列的第一条消息。例如: A1、B1、C1、A2、B2、C2、A3、B3、C3等等。如果创建了一个新队列(QueueD),消费者将以同样的方式开始接收来自它的消息。 提前感谢
浏览 1
提问于2018-05-02
得票数 4
1
回答
在生产中使用PredictionIO
、
、
、
我已经在本地安装了PredictionIO,使用我根据需要修改的通用推荐模板对引擎进行了培训,一切看起来都很好。 既然我知道这可以满足我的需求,我希望将它部署到生产中,不幸的是,关于它的文档不多。 理想情况下,我希望在AWS上部署所有的东西,文档中有一部分描述了它,但是由于禁用了CloudFormation模板,所以没有用。 我正在考虑使用Docker来实现它,但是我对整个堆栈缺乏了解,我想了解以下几点: 数据应该存储在哪里? hbase似乎是“数据库”,将其与其他服务器(事件服务器、预测服务器)放在同一服务器上不是很危险吗? 是如何扩展的?,我需要在负载均衡器后面运行多个Predic
浏览 1
提问于2016-09-16
得票数 5
1
回答
与Jenkins的云测试集成
、
、
我已经安装了Jenkins和SOASTA Cloud Test,现在我想将云测试集成到Jenkins中。在播放Jenkins的作文时遇到错误,我附上了截图。请提供您宝贵的建议。
浏览 10
提问于2017-02-08
得票数 0
1
回答
安装最佳和持久的ubuntu
、
请给我一台hp膝上型电脑我想使用它;编程,图形设计,网页设计,软件工程,在线教育。它以9.5GB的空闲分区空间运行window专业版。
浏览 0
提问于2017-02-09
得票数 -1
回答已采纳
1
回答
如何测试消息传递服务?
我必须测试消息传递服务,并想知道是否有任何经过验证的技术专门用于测试消息传递服务。例如,我知道JMeter对JMS的支持。这将涵盖负载/性能测试。然而,我不是在寻找工具,而是寻找概念和技术。
浏览 0
提问于2016-04-25
得票数 2
1
回答
Bigtable如何处理Tablet Server故障?
、
我发现Bigtable集群由一个主服务器和多个tablet服务器组成。失败时master发送到tablet服务器的消息。将平板电脑的备份副本设为主要副本。GFS自动创建的tablet的额外副本。 这足够了吗?但我想知道如何解决它,或者程序是什么,或者实际上是遵循了哪些步骤来解决它?
浏览 0
提问于2015-11-04
得票数 2
1
回答
当与Couchbase-lite一起使用时,同步网关为每个更改创建一个文档。
、
、
据我所观察到: 对于您创建的每个文档,还会创建一个修订管理器文档。此修订管理器跟踪最新版本,并维护数组中所有修订的历史记录。 每次更新文档时,都会创建一个新文档(whyyyyy?)。修订管理器文档的最新指针指向此新文档,并将以前的文档添加到其修订历史记录列表中。 因此,在每次更新操作中,Sync都添加了一个新文档,同时也修改了修订管理器文档. 这是一种非常低效率的版本控制方法,在这种情况下,整个文档的副本被维护用于版本控制,而不仅仅是差异,因为这将占用大量的空间。(例如:它占用了8.03MB的磁盘空间,用于在“GrocerySync”示例应用程序中对单个待办项目执行500次
浏览 2
提问于2015-06-07
得票数 3
回答已采纳
2
回答
群集tomcat、数据库或文件系统中的图像上传
、
我需要用集群的tomcats上传图片Java项目。我面临的问题是天气如何将图像上传到文件系统或数据库中。由于文件系统存在完整性问题(集群节点之间的图像不一致),但是性能更快。 通过一种混合的方法得到了两个节点间文件同步的解决方案。通过将文件转换为基本的64字符串并将其作为XML发送到单独线程中的集群中的其他节点,实现了每个节点之间的瞬时同步。因此,当设计失败时,出现了许多场景。(其中之一是一个节点处于下降状态,而上传则发生在另一个节点上。)。然后提出了在服务器启动时保持数据库作为同步主副本的解决方案,并在其他时间使用二次存储。 尽管如此,解决方案似乎过于复杂,因此我们采用了共享挂载驱动,这是和
浏览 6
提问于2014-02-01
得票数 1
回答已采纳
1
回答
是否有一种方法来注册朱庇特笔记本进度条Widget而不是Dask/Distributed中的文本进度条?
、
我知道有一种方法可以在全球注册dask.diagnostics.ProgressBar,虽然它很不错,但它破坏了我的单元格输出。我还看到了一个很好的distributed.diagnostics.progress函数,它可以显示木星笔记本进度栏小部件的执行进度,但它期望收到未来的结果。 我在这里遇到的问题是,dask.diagnostics.ProgressBar使用stdout (所以我在使用进度栏时不能打印任何东西),需要使用Dask/Distributed期货显式地调用distributed.diagnostics.progress,但是我有自己的函数,它们计算一些东西并返回一个“结果”
浏览 4
提问于2016-08-15
得票数 2
3
回答
使用消息队列的应用程序的良好示例
我想学习更多关于编程消息传递应用程序和使用消息队列的知识。像qpid,亚马逊队列等的事情。你能告诉我一些应用程序(最好是C++,如果可能的话,开源),这样我可以了解更多。 另外,您能告诉我决定是否不使用消息队列的一般指导原则吗?我对leanring很感兴趣,只是因为“酷”的因素,但我认为这对我未来可能是有益的。
浏览 0
提问于2011-02-12
得票数 2
回答已采纳
1
回答
不可靠介质上的并行广播
、
、
我有成百上千个节点,每个节点都知道彼此的地址。 为了有效地在它们之间传播信息,我目前认为我需要将它们转换为一棵树,或者可能是多棵树。 我读过https://en.wikipedia.org/wiki/Broadcast_(parallel_pattern),但它似乎不能处理消息丢失。 如果消息有1%的失败机会,是否有办法将消息传送到99%的节点?速度在这里很重要,所以不需要重试和/或TCP。 当消息失败时,一个简单的树广播将丢失整个分支。也许多棵树就能解决这个问题?多少? 我很高兴节点能够接收少量冗余消息。我需要使用UDP。少量的绝对故障是可以的,因为它们可以在稍后的时间赶上自己,在此期间退
浏览 19
提问于2020-09-12
得票数 0
3
回答
Kafka的键/值对消息的目的是什么?
、
、
、
、
| 的所有都显示ProducerRecord的键/值对不仅具有相同的类型(所有示例都显示为<String,String>),而且具有相同的值。例如: producer.send(new ProducerRecord<String, String>("someTopic", Integer.toString(i), Integer.toString(i))); 但在Kafka文档中,我似乎找不到在哪里解释了键/值的概念(以及它的基本用途/工具)。在传统的消息传递(ActiveMQ、RabbitMQ等)中我总是在特定的主题/队列/交换上触发一条消息。但Ka
浏览 20
提问于2016-11-30
得票数 116
回答已采纳
1
回答
AWS Lambda:服务错误
、
这个错误意味着什么? 我使用Java部署了5个Lambda函数,这些函数工作得很好,但从今天下午开始,它们都开始在执行每个函数时显示相同的消息: Service error. 没有输出,没有日志,只有红色框中的消息。 在中,他们说: 下午6:05下午PDT我们正在调查增加的错误率和提高的AWS Lambda请求在美国-东部-1地区。新创建的函数和控制台编辑也会受到影响。 为什么会发生这种情况,是否有办法防止这种情况发生?
浏览 2
提问于2016-08-11
得票数 1
回答已采纳
1
回答
Oracle coherence和Hadoop HDFS之间的区别是什么
、
、
、
Oracle Coherence和Hadoop HDFS之间的区别是什么,读过HDFS和coherence (但没有什么是清楚的)听起来都是一样的。这些是不同的技术解决不同的问题,还是相同的技术但不同的产品?需要知道它们在技术方面的差异和相似之处,即从更广泛的角度来看,这两种技术在哪里适合? 注意:我不是要求产品比较(所以没有大猩猩和鲨鱼)。
浏览 0
提问于2012-09-30
得票数 4
2
回答
ZeroMQ中同步套接字的混淆
、
、
这似乎是一个愚蠢的问题,但我对ZeroMQ有关同步套接字(如 )的术语感到非常困惑。 根据我的理解,当客户端发送消息,然后它阻塞,直到响应到达时,就会发生同步通信。如果ZeroMQ实现了同步通信,那么对于同步套接字来说,只有一个.send()方法就足够了。 我认为ZeroMQ的同步套接字术语仅指在最后一条消息的响应到达之前不能发送更多的消息,但是“发件人”仍然可以异步地继续其处理(做更多的事情)。 这是真的吗? 在这种情况下,是否有任何使用ZeroMQ实现同步通信的简单方法? 编辑:当我想在远程进程(如RPC)中调用方法时,同步通信是有意义的。如果我想在远程进程中执行一系列命令,并且每个命令都
浏览 4
提问于2017-12-24
得票数 1
回答已采纳
1
回答
即使在MassTransit中的客户端请求超时后,仍会处理消息
、
我正在使用MT和RabbitMQ实现标准的请求/响应场景。客户端是Asp.net核心应用程序接口,消费者是windows服务。 作为测试异常用例的一部分,如果我停止使用者并使用请求客户端提交来自API的请求,由于没有使用者处理,API得到请求超时异常,这很酷。但是消息位于消费者队列中,当我启动消费者时,它会挑选消息并处理这些东西(将消息发送到外部端点),然后移到_skipped队列中,因为没有请求客户端监听此消息。 你认为这是正确的行为吗?首先当api得到请求超时异常时,他还是会重试,那么处理第一条消息还有什么意义呢? 如何忽略那些请求客户端已经完成处理但出现错误的消息? 谢谢
浏览 26
提问于2021-03-05
得票数 0
4
回答
了解有关分布式计算的更多信息
、
、
我对学习更多关于分布式计算以及如何实现分布式计算很感兴趣-主要是在C++中,但我也对C#感兴趣。 有没有人可以推荐一些资源?我对这个主题知之甚少甚至一无所知,所以我应该从哪里开始呢? 谢谢。
浏览 1
提问于2009-06-29
得票数 8
回答已采纳
1
回答
如何正确地在分布式系统中存储图像?
、
、
、
、
我正在尝试创建一个分布式系统,其中包含移动应用程序、web用户面板和与DB通信的API。我希望用户能够上传来自移动应用程序和web用户面板的个人资料图像,但是在分布式系统中存储图像的最佳和“正确”方法是什么?在这个主题上找不到任何描述最佳实践的东西。 我知道文件路径应该在数据库中,图像应该在文件系统中。但是,文件系统应该在API服务器上还是在哪里呢? 下面是我认为分布式系统应该是什么样子的图表。
浏览 4
提问于2022-08-03
得票数 1
1
回答
getStream.io (聊天)-所有的消息都存储在哪个数据库中?
、
我很乐意知道在中哪个数据库是存储在getStream.io中的所有消息?
浏览 1
提问于2021-12-12
得票数 0
1
回答
java.lang.OutOfMemoryError:超过WSO2 MB的GC开销限制
、
、
、
、
我最近一直在使用WSO2 Message Broker (Ver : 3.1.0 ),以便使用JMeter作为jms客户端来发布和使用消息。因此,我有了发布消息的publisher Java程序,我试图每秒发布4000条消息。必要的话我可以提供片段。 我通过在无头模式下运行JMeter命令jmeter -n -t C:\Users\ctsadmin\Downloads\wso2MB\apache-jmeter-2.13\bin\GamesSubscriber.jmx -l C:\Users\ctsadmin\Downloads\wso2MB\apache-jmeter-2.13\bin\myt
浏览 3
提问于2016-05-06
得票数 4
回答已采纳
1
回答
分布式系统指挥与控制
我有一个应用程序,它由运行在一个或多个系统上的一组Java和C++组成,并且需要能够监视和控制组件,就像它们是一个完整的系统一样。 我的要求: 运行时统计(每秒消息等) 事件日志 控制:“服务X设定为1000 mps”或“所有服务停止”。 环境配置,以便所有服务都可以启动并发现工作模式(等等) 由于数据平面消息传递是基于0MQ的,所以我目前正在使用基于0MQ的消息传递和消息分发器来扇出控制消息。 不过,我对其他人如何处理这个问题很感兴趣。 谢谢。
浏览 0
提问于2013-05-06
得票数 1
1
回答
什么分布式消息队列支持数百万队列?
、
、
我正在寻找一个分布式消息队列,它将支持数百万个队列,每个队列每秒处理数十条消息。 消息将很小(几十字节),我不认为队列会变得很长--根据每个队列最多几十条消息的顺序,但是当系统继续运行时,队列应该是相当空的。 我不确定集群中会有多少个节点--可能取决于具体的解决方案,但如果我不得不猜测,我可以说是10个节点。我更希望队列对集群内的单个节点故障具有相对的弹性,但是这里和那里丢失的一些消息不会使我失眠。 这样的消息队列是否存在?似乎大部分字段都是针对处理数百个高吞吐量队列而优化的。但是SQS是建立在什么基础上的呢?当然不是魔法。 更新: 根据请求,这可能确实有助于了解我的问题域。(为了不把水弄浑,
浏览 3
提问于2012-10-12
得票数 2
回答已采纳
2
回答
如何编写可测试性的动态自平衡系统?
、
我即将着手编写一个系统,该系统需要在涉及的一个或多个节点发生故障时重新平衡其在剩余节点之间的负载分布。有没有人对应该避免什么和什么是有效的有什么好的参考? 特别是,我很好奇如何开始构建这样的系统,以便能够对其进行单元测试。
浏览 0
提问于2009-09-21
得票数 2
回答已采纳
2
回答
MapR沙箱工作说明
在我的笔记本电脑上安装了MapR沙箱后,如何在MapR沙箱上练习示例练习?我在哪里可以找到说明书?谢谢。Venkat
浏览 5
提问于2016-05-14
得票数 0
4
回答
测试分布式系统的集成测试框架?
、
、
、
我有一个分布式系统,组件分布在多个机器上。它们使用tcp或组播相互通信。每个组件彼此交换消息-这些基本上是序列化的数据结构。 我们有什么集成测试框架来测试这样的系统呢?我熟悉ruby,所以基于ruby的东西肯定会有帮助。
浏览 2
提问于2012-08-12
得票数 13
1
回答
低开销网络复制文件
、
、
我们正在努力寻找一个系统来保持一对服务器的同步,我已经研究了上百万种解决方案。我偶然发现了文龙,这似乎是完美的。现在,我只需要一种低开销的方式来复制已更改到另一台服务器的文件。这是一个本地网络,所以加密是不必要的,它是一个千兆位连接,所以压缩也没有了。 Rsync可能有效,但对于这项任务来说似乎有点大。nc似乎很棒,但我不知道有什么方法可以向另一台服务器表示文件应该从第一台服务器转到哪里。 有什么建议吗?
浏览 0
提问于2012-06-02
得票数 1
1
回答
Kafka Consumer订阅topic但不消费消息,不出现在消费者组列表中
、
、
、
、
Kafka Consumer (org.apache.kafka:kafka-clients:2.3.0)应该使用一个分区消费来自topic的消息。 该服务记录消费者订阅,但它不使用消息,也不会使用Official Apache Tools kafka-consumer-groups.sh出现在消费者组列表中。 2020-06-15 11:50:50.308 [main] INFO o.a.k.clients.consumer.KafkaConsumer - [Consumer clientId=consumer-1, groupId=my-groupid] Subscribed to t
浏览 129
提问于2020-06-15
得票数 0
回答已采纳
1
回答
为什么DNS放大攻击被认为是DDoS攻击?
、
、
我的理解是,DNS放大攻击涉及到向DNS解析器发送一堆带有伪造发送者地址的请求,这是受害者的地址,DNS用大量的信息响应这个IP地址。使得这个DDoS而不是DoS的分布式特性在哪里?如果攻击者同时使用多个DNS解析器,我可以看到它是DDoS,但是链接的文章听起来并不是这样。
浏览 0
提问于2015-12-13
得票数 0
回答已采纳
1
回答
离子3哪里保存数据?
、
、
、
关于离子数据保存,我哪儿也找不到答案。例如: 如果我使用延迟加载(卸载模块停留在哪里(RAM或主存储)或使用服务工作人员),那么所有资产都保存在哪里? 对我来说很重要,因为如果有100张图片--它的重量大约是100 me,如果应用程序关闭了,100 me会去哪里?
浏览 0
提问于2019-01-16
得票数 0
1
回答
具有消息事件处理程序的多个CAPL文件
我已经在CAN中创建了一个CAN模拟系统。我已经添加了两个capl文件,其中包含一个ID为1的CAN消息处理程序。现在,如果我收到ID为1的CAN消息,这些处理程序将按什么顺序被调用? 谢谢
浏览 1
提问于2015-06-11
得票数 1
1
回答
安全程序-拆分文件
、
、
、
为了保护文件,您将如何描述将敏感文件拆分为不同服务器上的较小部分的“系统”的体系结构? 我们会将文件转换为字节,然后将这些字节分发到不同的服务器上吗?为了回调原始文件(如果您拥有正确的权限),您将如何将所有的片段重新组合在一起? 这是一个我不知道如何处理的理论问题。有什么建议我应该从哪里开始吗?
浏览 0
提问于2010-11-09
得票数 0
回答已采纳
1
回答
实时聊天,不想丢失消息-使用队列(redis,zeromq)?
、
、
、
、
我有一个实时聊天的应用程序。聊天是在客户端和服务器端(nodejs)使用Faye实现的。 现在,这个客户端聊天被用于rails应用程序,当我的页面重新加载/刷新时,我不想丢失在以下场景中可能发生的消息: 我重新加载页面 我从DB那里得到聊天记录 用户在聊天的另一边写5行 我呈现这一页 我丢失了5份最近的记录 我想听听你对解决这个问题的意见。我想到了一个类似于消息队列的消息队列,其中没有传递给客户端的消息将在那里等待,然后在页面通过javascript打开时被获取。 如果有人确认消息队列非常适合使用zeromq或在redis中实现简单队列,我还需要您的意见,因为我已经
浏览 2
提问于2012-10-02
得票数 1
回答已采纳
1
回答
Flink中的RocksDBStateBackend :它到底是如何工作的?
、
我读过Flink关于国家后端的官方文档,。特别是,我对RocksDBStateBackend感兴趣。 我不明白,如果启用了这种后端,RocksDB就可以通过Flink集群中的另一个节点从TaskManagers访问? 到目前为止,我对RocksDBStateBackend的理解是,任务管理器将在其内存中存储状态,即JVM进程的内存。在那之后,他们会把州派到RocksDB里面吗?如果是,Flink集群中的RocksDB在哪里?它在哪里?
浏览 3
提问于2019-10-31
得票数 4
回答已采纳
1
回答
负载平衡网络websocketserver
、
最近,我尝试了Netty服务器来开发一个聊天服务器。我已经重复使用了示例"io.netty.http.example.websocketx.server",并通过添加通道映射、消息处理器将新消息保存到数据库等方式稍微修改了它。 通道映射将包含所有已打开的频道和订阅的聊天室id。因此,当有人向聊天室123发送消息时,当收到messageReceived函数中的消息时,服务器将将消息发送到订阅到该聊天室的所有通道。 当只有一个WebSocketServer实例时,这个方法工作得很好,但是,如何将负载平衡到多个WebSocketServers呢?当WebSocketServer #1
浏览 5
提问于2014-07-09
得票数 1
回答已采纳
1
回答
websphere MQ使用什么样的db存储?
、
websphere MQ附带了什么样的数据库?DB2分号?或者基于db的本地文件系统。它需要某种形式的持久存储,因为如果它在队列上接收到消息,而侦听器处于下线状态,那么它需要持久化消息,直到侦听器备份。
浏览 2
提问于2013-10-10
得票数 1
回答已采纳
1
回答
hadoop数据挖掘库
、
、
我在hadoop中使用Mahout进行数据挖掘算法。但是它在一些cases.Is中有bug,还有其他使用hadoop的数据挖掘库吗?谢谢。
浏览 0
提问于2013-08-01
得票数 0
1
回答
用于集合通信的DDD和消息
、
、
我正在用java中的DDD原理编写一个练习应用程序,其中包含了spring和mongodb。根据DDD,Aggregates之间的通信只能通过消息传递。此时Im没有分发应用程序,所有聚合都驻留在同一个应用程序中,因此我只是使用Spring消息传递功能来交换消息。 每个聚合正好对应一个mongo文档。由事件触发的每个命令或操作都由@ transaction注释来保护,以确保原子地处理db事务和事件。我在想我应该把这些事件存放在哪里?我能把它们储存在蒙戈文件里吗?事实上,由于芒果交易跨越单个文档,这不是唯一的选择吗? 下一步是设置一个周期性任务,该任务将读取所有最近的事件,并发布它们以模拟非线程通
浏览 4
提问于2021-01-28
得票数 0
回答已采纳
3
回答
扩展vs. MPI vs zeromq?
、
、
、
、
在对的一个回答中,用户提到了消息传递应用编程接口。我还遇到过一个名为的程序。我对也有一定的了解。 所以,我的主要问题是:为什么我要选择一个而不是另一个?更具体地说,当有成熟的MPI实现时,我为什么要选择使用when或ÖMQ呢?
浏览 0
提问于2008-08-30
得票数 47
回答已采纳
2
回答
如何在多台服务器上托管单个MySQL数据库?
、
、
我是编程新手。但我将在一个拥有数百万记录和巨大流量的网站上工作,我想要负载平衡我的应用服务器数据库。 如何用PHP创建应用程序?如何将一个数据库分发到多个服务器上?
浏览 1
提问于2013-08-02
得票数 0
回答已采纳
1
回答
如何在消息处理系统中保持相关消息的顺序?
、
、
、
系统从MQ获取消息。由于系统具有多个VM,因此处理消息的实际顺序可能与MQ中的顺序不同(等等。可以在前一条消息之前处理后一条消息,并将其存储在数据库中)。 现在我希望具有相同Business-ID的消息可以在发送时作为订单进行处理。 我可以得到一个建议,我们可以使用一个VM并从MQ读取消息。并获取Business-Id并将消息分发到目标VM (具有相同Business-Id的消息将分发到相同的VM)。它可以解决这个问题,但是只有一个线程来做分发工作,性能可能不好。 有没有其他方法来解决这个问题?任何博客、论文、开源代码都可以。
浏览 0
提问于2019-06-13
得票数 0
2
回答
windows上的vb6图标位置
、
、
在哪里可以找到原始的vb6 (或windows )图标?(.ico文件) 我需要消息框上出现的错误、警告、问题和信息图标。 非常感谢。
浏览 0
提问于2011-07-27
得票数 0
1
回答
在JMS中使用事务(ActiveMQ)
、
、
、
在我们的后端,有几个服务通过带有Apache ActiveMQ的JMS发送和接收消息。每个服务都有一个到ActiveMQ代理的会话。我们现在想要执行以下操作(伪代码): 服务s1: Message m = createMessage("s2","Hello World") sendMessage(m) try { Message answer = commit() ... } catch (TransactionFailedException e){ ... } 服务s2: onMessageReceive: try { Message
浏览 2
提问于2012-02-20
得票数 5
回答已采纳
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
Linux哪里好?Linux系统好在哪里?
Kafka分布式消息系统剖析
分布式系统的消息&服务模式简单总结
分布式消息系统之Kafka入门
非常好、极好的视频体验哪里可以享受到
热门
标签
更多标签
云服务器
ICP备案
对象存储
实时音视频
云直播
活动推荐
运营活动
广告
关闭
领券