腾讯云
开发者社区
文档
建议反馈
控制台
登录/注册
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
视频
沙龙
2
回答
在ubuntu服务器非gui模式下运行的gui没有显示任何结果。
我尝试运行命令./jmeter.sh -n -t -t,并得到了日志消息: Starting the test @ Mon Jul 09 17:44:48 ICT 2018 (1531133088159) Waiting for possible Shutdown/StopTestNow/Heapdump message on port 4445 summary = 0 in 00:00:00 = ******/s Avg: 0 Min: 9223372036854775807 Max: -9223372036854775808 Err: 0 (0.00%) Tidy
浏览 5
提问于2018-07-09
得票数 1
回答已采纳
1
回答
Spring集成-在集群中有一个消息驱动的通道适配器活动。
发行: 将1个活动MDP (以下为jmsIn)附加到单个队列,并将第二个集群MDP保持在服务器2上的被动状态。我只需要一个活动的进程,因为我希望执行聚合而不丢失消息。 我一直在阅读关于控制总线的文章,但是由于它是一个集群环境,通道id和jms:消息驱动的通道适配器id将在两个服务器上都有保存名称。控制总线是否可以使用JMX在另一台服务器上停用,即使它们有id?或者可能先由消息驱动的通道适配器进行检查,以确定队列本身上是否已经有活动的连接。 Message-driven-channel-adapter示例代码: <jms:message-driven-channel-adapter id=
浏览 2
提问于2015-09-29
得票数 1
2
回答
用于事件发布的Kafka vs JMS
、
、
、
在我们的场景中,我们有一组微服务,它们通过发送事件消息与其他服务交互。在高峰时刻,我们预计每天会收到数百万条信息。每条消息都针对一个或多个侦听器类型。我们的要求如下: 零条信息丢失。 能够动态注册特定类型的多个侦听器,以提高吞吐量。 在发送消息时,不能保证侦听器是活动的。 我们考虑了两种选择: 将每条消息发送到JMS主队列,然后该队列的侦听器将消息根据消息内容路由到特定队列,然后目标服务将侦听这些特定队列。 通过消息类型将消息发送到Kafka主题,然后目标服务将订阅相关主题并使用这些消息。 为此目的使用JMS或Kafka的缺点和优点是什么?
浏览 1
提问于2018-12-31
得票数 0
回答已采纳
1
回答
如何使用AWS每分钟执行一次方法(多个进程/实例)
、
、
、
、
我有一个每分钟发送SQS消息的进程。重要的是,消息每分钟发出一次,所以我计划在多个实例上运行流程,这样它才能更好地容错。 即使它在多个实例上运行,我也只希望SQS消息每分钟运行一次。因此,如果机器A发送消息,我不希望机器B发送它们,反之亦然。 我希望避免主/从设置。 我想使用一个单独的SQS队列发送一个可以由其中一个进程接收的完成消息,以开始发送消息,并在完成/一分钟后发送一个完成消息,但是如果由于故障或其他问题而无法发送完成的消息,它们的循环就会结束,这是不可接受的。 我还想让发出消息的进程在simpleDB或可能的另一个DB中放置时间戳,并让进程在间隔上检查时间戳。第一个检查它并发现它已经
浏览 1
提问于2015-02-27
得票数 0
回答已采纳
1
回答
如果我想创建分布式互斥体库,我应该创建一个线程吗?
、
、
、
我正在尝试用C++编写一个简单的锁定/解锁算法,它的行为就像分布式系统中的互斥锁一样。 它将被实现为一个库,用户将能够通过接口文件使用它。 假设有3个进程{A,B,C}。 每个处理器都知道其他进程的地址和端口等。 如果A想要锁定某个对象,它需要从其他进程获得权限,在本例中是B和C。 我相信发送和等待来自B和C的回复不是问题,因为用户肯定会调用这个函数。 但是,B和C应该如何接收消息呢? 可以保证所有进程都是活动的。 是否应该为每个运行监听(轮询)套接字的处理器分配一个单独的线程? 这是否意味着如果我在构造函数中创建一个线程,并在进程运行时使用它,然后在析构函数中销毁它就可以了?
浏览 0
提问于2011-07-21
得票数 0
回答已采纳
1
回答
如何测试消息传递服务?
我必须测试消息传递服务,并想知道是否有任何经过验证的技术专门用于测试消息传递服务。例如,我知道JMeter对JMS的支持。这将涵盖负载/性能测试。然而,我不是在寻找工具,而是寻找概念和技术。
浏览 0
提问于2016-04-25
得票数 2
1
回答
Bigtable如何处理Tablet Server故障?
、
我发现Bigtable集群由一个主服务器和多个tablet服务器组成。失败时master发送到tablet服务器的消息。将平板电脑的备份副本设为主要副本。GFS自动创建的tablet的额外副本。 这足够了吗?但我想知道如何解决它,或者程序是什么,或者实际上是遵循了哪些步骤来解决它?
浏览 0
提问于2015-11-04
得票数 2
2
回答
如何使用依赖项更新模型
、
、
、
我有点想不通了。我有一个模型(您可以在下面的图像中看到),这个模型可以更改(它不会经常发生,但它可以)。当它发生变化时,我没有得到整个数据集的更改,我按照以下顺序得到这个集合(不知道它是否相关):首先我得到所有的标签,然后得到所有的位置,然后是过滤器,然后是类型,最后是消息。 更新这些类的属性不是问题,当我需要更新层次结构时,我会陷入困境,因为它们都是相互连接的。 我为所有的模型做了一个过于复杂的更新方法网,他们会通知那些有他们的记录的人他们被删除了,但是我用得越远,我就越迷失在我所写的代码中。所以我决定后退一步,想出一种更简单的方法。不幸的是,我不知道有一种简单易懂的方式来更新这个模型。 困
浏览 0
提问于2016-11-18
得票数 1
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
1
回答
AWS Lambda:服务错误
、
这个错误意味着什么? 我使用Java部署了5个Lambda函数,这些函数工作得很好,但从今天下午开始,它们都开始在执行每个函数时显示相同的消息: Service error. 没有输出,没有日志,只有红色框中的消息。 在中,他们说: 下午6:05下午PDT我们正在调查增加的错误率和提高的AWS Lambda请求在美国-东部-1地区。新创建的函数和控制台编辑也会受到影响。 为什么会发生这种情况,是否有办法防止这种情况发生?
浏览 2
提问于2016-08-11
得票数 1
回答已采纳
1
回答
用Snowflake SQL查询多元素半结构化数据(json)
、
、
、
我不能用Snowflake SQL正确地查询多层(json)数据的半结构化数据。你能帮我指出什么是不正确的吗?是我正在解析的数据还是我的扁平化语法?如何写出正确的语法?非常感谢!我的问题是: WITH a AS ( SELECT PARSE_JSON('[ { "name": "conversion_event", "created_at" : "2020-01-01 00:00:00", "uuid" : 12314512441312312, "campaign_na
浏览 4
提问于2020-07-23
得票数 0
1
回答
即使在MassTransit中的客户端请求超时后,仍会处理消息
、
我正在使用MT和RabbitMQ实现标准的请求/响应场景。客户端是Asp.net核心应用程序接口,消费者是windows服务。 作为测试异常用例的一部分,如果我停止使用者并使用请求客户端提交来自API的请求,由于没有使用者处理,API得到请求超时异常,这很酷。但是消息位于消费者队列中,当我启动消费者时,它会挑选消息并处理这些东西(将消息发送到外部端点),然后移到_skipped队列中,因为没有请求客户端监听此消息。 你认为这是正确的行为吗?首先当api得到请求超时异常时,他还是会重试,那么处理第一条消息还有什么意义呢? 如何忽略那些请求客户端已经完成处理但出现错误的消息? 谢谢
浏览 26
提问于2021-03-05
得票数 0
2
回答
使用异步请求而不是与互斥同步的多线程设计模式的名称是什么?
、
、
我想知道设计模式的“正式”名称是什么,在这种设计模式中,只有一个线程实际处理某些资源(数据库、文件、通信接口、网络连接、日志等)。而希望使用该资源执行某些操作的其他线程必须向该线程传递一条消息,并可选地等待有关完成的通知? 我找到了一些文章将这种方法称为“中央控制器”,但谷歌搜索并没有给出太多关于这个特定短语的信息。 另一方面,这并不完全是“消息泵”或“事件队列”,因为它与GUI或操作系统向应用程序传递某些消息无关。 它也不是“工作队列”或“线程池”,因为这个单独的线程只专用于这个单一的活动(管理单个资源),而不是用来做任何抛给它的事情。 例如,假设有一个由一个线程管理的特殊通信接口(例如,设
浏览 0
提问于2017-03-03
得票数 0
2
回答
在队列中跨码头集装箱同步工作
、
我有一个相当简单的(我想)的设置,它给我带来了一些悲伤。 我使用的是一个排队系统(AWS )和一些用.net核心编写代码的工人码头容器,这些容器从队列中提取并处理消息。多个工作人员可以同时从队列中提取。 某些操作属于单个作业。例如,我们要处理100个单元,因此我们可以在SQL中创建一个job,然后将100个消息发送给SQS进行处理。当所有的工作人员都完成了,而且只有一次,我们想要删除任务,并给一些外部服务的消息,我们已经完成了。至关重要的是,我们只向外部服务发送一次消息,因为该服务将导致某些用户可见的活动。 正在发生的情况是,最后几个单元通常同时完成几乎毫秒的处理,所以我们要么发出重复的消息(
浏览 0
提问于2018-06-18
得票数 2
1
回答
getStream.io (聊天)-所有的消息都存储在哪个数据库中?
、
我很乐意知道在中哪个数据库是存储在getStream.io中的所有消息?
浏览 1
提问于2021-12-12
得票数 0
2
回答
如果只有尾随0,则使用printf格式化不带小数位的浮点数
、
有没有可能在C中格式化一个浮点数,如果与使用printf的0不同,它只显示两个小数位? 例如: 12 => 12 12.1 => 12.1 12.12 => 12.12 我尝试使用: float f = 12; printf("%.2f", f) 但我得到了 12 => 12.00 12.1 => 12.10 12.12 => 12.12
浏览 3
提问于2012-03-09
得票数 42
回答已采纳
1
回答
分布式系统指挥与控制
我有一个应用程序,它由运行在一个或多个系统上的一组Java和C++组成,并且需要能够监视和控制组件,就像它们是一个完整的系统一样。 我的要求: 运行时统计(每秒消息等) 事件日志 控制:“服务X设定为1000 mps”或“所有服务停止”。 环境配置,以便所有服务都可以启动并发现工作模式(等等) 由于数据平面消息传递是基于0MQ的,所以我目前正在使用基于0MQ的消息传递和消息分发器来扇出控制消息。 不过,我对其他人如何处理这个问题很感兴趣。 谢谢。
浏览 0
提问于2013-05-06
得票数 1
2
回答
我需要一个十进制数的正则表达式
、
我需要一个正则表达式来验证一个十进制数,但在数字之前不需要任何符号。即。 .2 (精细) .12 (精细) 12 (罚款) 12.0 (罚款) 12.12 (罚款) 但 12.123 (不允许) -12.12(不允许) +12.12 (不允许)
浏览 4
提问于2013-09-19
得票数 0
回答已采纳
1
回答
无法加载通过引用远程服务器的链接服务器连接获取的数据。
、
当我试图从引用远程计算机的链接服务器连接加载数据时,我会收到以下错误: 无法执行此操作,因为用于链接服务器"DATABASENAME“的OLE提供程序"DBDRIVER”无法开始分布式事务。 OLE提供程序"DBDRIVER“用于链接服务器"DATABASENAME”返回消息"No是活动的“。 我检查了两个事务伙伴上的分布式事务协调器服务是否正在运行,并允许网络连接正常。
浏览 3
提问于2013-10-14
得票数 0
回答已采纳
2
回答
网络模式下的互斥?
、
我想做以下几点: 我有很多电脑。在每台计算机上都会运行一个程序。没有集中式服务器。 该程序可以根据定义的标准选择提供另一台计算机指定的数据。在这样做时,另一台计算机不应该这样做。(一种双向同步) 我们来举个例子吧。(C1 ..Cn是在不同计算机上运行的程序) C1发送C2更新的数据。当处理处于活动状态时,C2不应该要求C1更新其他内容。 他们的想法是: C1向C2发送消息: PauseExecution() C1发送给要处理的C2项(更新C2上的一些数据) C1向C2: ResumeExecution()发送一条消息。C2向C1发送消息: PauseExecution() C2发送给要处理的C
浏览 0
提问于2013-02-13
得票数 1
1
回答
将两个数组值分别等于或不等于index index
、
、
我有一个场景,我想比较array1和array2的值 echo "${array1[@]}" 给我output1:12.12 10.1 echo "${array2[@]}" 给我output2:12.12 10.1 how将array1值与下面的array2进行比较 array1[0]=array2[0] array1[1]=array2[1] 12.12 12.12 10.1 10.1 然后if匹配显示 回显“成功”或“失败” 成功-当array1中的所有数据与aray2匹配时 失败-当索引到索引值不匹配时,则失败
浏览 0
提问于2020-01-03
得票数 0
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
2
回答
在具有ID的多个列中查找具有相同值的行
我有一个相对较大的表,有很多列和行。其中我有ID,经度和纬度。我想有一个ID的列表,其中具有相同的坐标(纬度和经度),类似这样 ID¦latitude¦longitude¦number 1 ¦ 12.12¦ 34.54¦1 12¦ 12.12¦ 34.54¦1 52¦ 12.12¦ 34.54¦1 3 ¦ 56.08¦ -45.87¦1 67¦ 56.08¦ -45.87¦1 谢谢
浏览 17
提问于2017-01-29
得票数 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
回答
具有消息事件处理程序的多个CAPL文件
我已经在CAN中创建了一个CAN模拟系统。我已经添加了两个capl文件,其中包含一个ID为1的CAN消息处理程序。现在,如果我收到ID为1的CAN消息,这些处理程序将按什么顺序被调用? 谢谢
浏览 1
提问于2015-06-11
得票数 1
1
回答
用特定时间的消息触发某些事件
、
、
、
、
我如何在特定的时间用某种消息触发某个事件? 例句:有人把“生日快乐”的消息安排在他朋友的生日当天上午12点。因此,这个生日活动应该在他的生日当天早上12:00发出“生日快乐”的信息。 我能想出的唯一解决方案是,这个工作是一个cron作业,每分钟运行一次,检查过期的时间并触发该事件。 但是,如果我们有很多事件,那么查询每分钟都不是一个好主意,它也会产生1分钟的错误。 那么,我们可以使用像apache这样的服务(但它不会在特定的时间安排事件)来触发事件吗?
浏览 5
提问于2022-02-05
得票数 0
1
回答
如何处理大规模并发事件?
、
、
、
、
我有以下面试问题: 假设公司有这样的活动,我们将在网站上创建一个按钮,只有前十次点击将被接受并获奖。假设全世界有数以百万计的人参与这一活动。你将如何实现它? 我的答案是: 只需保存数据库中的每一次单击,按创建时间ASC对它们进行排序,然后得到前十次。 我的回答受到了另一个问题的质疑: 如果有多个服务器节点处理此过程,该怎么办?如何确保数据的完整性?数据库会产生的是最初的十次点击吗? 那就是我迷路的地方。我刚才回答说,让这些节点在一个数据库上操作,或者检查跨节点的日志,比较它们,诸如此类。但似乎并不是人们想要的答案。 为什么我的答案不能解决这个问题,以及如何解决这个问题。 PS:我申请的是一个团
浏览 0
提问于2021-03-27
得票数 0
回答已采纳
1
回答
如何使用链接服务器插入远程表?
、
、
、
我的链接服务器设置正确,我可以执行下面的查询。 插入RemoteServer.Table SELECT *从LocalServer.Table 但是,当我在事务中执行相同的操作时, 开始在RemoteServer.Table中插入SELECT *从LocalServer.Table提交 我会犯这样的错误 OLE DB提供程序"SQLNCLI“用于链接服务器"66.70.123.202”返回消息"No是活动的“。无法执行操作,因为OLE DB提供程序"SQLNCLI“用于链接服务器"66.70.123.202”无法开始分布式事务。
浏览 3
提问于2010-06-13
得票数 4
回答已采纳
2
回答
如何通过卡夫卡传输大文件?
、
我正在将基于酸的monolith迁移到基于事件的微服务体系结构。在monolith中,潜在的大型文件存储在数据库中,我希望与微服务共享这些信息(包括文件内容)。 我的方法是将文件分割成有编号的块,并发送几条消息(例如,带有元数据和id的一个FileCreatedMessage,后面是包含该块及其序列号的n FileContentMessage )。在接收端,消息可能不会按顺序到达。因此,我会存储消息块,订购并加入它们,并存储结果。 有什么方法可以让我用一条消息或另一条信息通过Kafka传输数据,而不需要为几条消息实现分片、排序和连接逻辑的开销? 我注意到卡夫卡溪流。它似乎解决了与这个不同的问题
浏览 0
提问于2019-06-09
得票数 5
回答已采纳
1
回答
实时聊天,不想丢失消息-使用队列(redis,zeromq)?
、
、
、
、
我有一个实时聊天的应用程序。聊天是在客户端和服务器端(nodejs)使用Faye实现的。 现在,这个客户端聊天被用于rails应用程序,当我的页面重新加载/刷新时,我不想丢失在以下场景中可能发生的消息: 我重新加载页面 我从DB那里得到聊天记录 用户在聊天的另一边写5行 我呈现这一页 我丢失了5份最近的记录 我想听听你对解决这个问题的意见。我想到了一个类似于消息队列的消息队列,其中没有传递给客户端的消息将在那里等待,然后在页面通过javascript打开时被获取。 如果有人确认消息队列非常适合使用zeromq或在redis中实现简单队列,我还需要您的意见,因为我已经
浏览 2
提问于2012-10-02
得票数 1
回答已采纳
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
回答
跨java应用程序的多个实例共享数据
、
我的java应用程序的两个实例部署在服务器中。其中一个实例将在任何一个点处于活动状态,另一个实例将处于备用状态。活动实例将从一些接收者接收一些数据,并进行一些处理。现在,如果我的活动实例由于某些错误而被关闭,备用将变成实时的。 在第一个实例中维护/收集的数据(map/list)是否可以以某种方式共享给第二个实例?
浏览 6
提问于2017-06-28
得票数 0
回答已采纳
3
回答
扩展vs. MPI vs zeromq?
、
、
、
、
在对的一个回答中,用户提到了消息传递应用编程接口。我还遇到过一个名为的程序。我对也有一定的了解。 所以,我的主要问题是:为什么我要选择一个而不是另一个?更具体地说,当有成熟的MPI实现时,我为什么要选择使用when或ÖMQ呢?
浏览 0
提问于2008-08-30
得票数 47
回答已采纳
1
回答
如何在消息处理系统中保持相关消息的顺序?
、
、
、
系统从MQ获取消息。由于系统具有多个VM,因此处理消息的实际顺序可能与MQ中的顺序不同(等等。可以在前一条消息之前处理后一条消息,并将其存储在数据库中)。 现在我希望具有相同Business-ID的消息可以在发送时作为订单进行处理。 我可以得到一个建议,我们可以使用一个VM并从MQ读取消息。并获取Business-Id并将消息分发到目标VM (具有相同Business-Id的消息将分发到相同的VM)。它可以解决这个问题,但是只有一个线程来做分发工作,性能可能不好。 有没有其他方法来解决这个问题?任何博客、论文、开源代码都可以。
浏览 0
提问于2019-06-13
得票数 0
1
回答
故障转移nservicebus和石英
、
上下文 在我们当前的Nservicebus设置中,我们将所有的项目配置为在2台机器上运行,作为故障转移。 在一个项目中,我们配置了一个Quartz调度程序来调度一些任务。 其中一项任务是向Nservicebus发送消息。 但是因为这个项目现在运行在2台机器上,所以消息被发送了2次到总线上,并被处理了两次。 问题 是否有一种方法可以在Nservicebus中配置该项目的一个实例可以同时处于活动状态。如果1倒了,另一个就开始工作了?
浏览 2
提问于2015-12-09
得票数 0
2
回答
Kafka vs ActiveMQ中的完整性保证?
、
我在比较Apache Kafka和ActiveMQ (以及类似的消息队列产品)时发现的信息从来都不清楚每个解决方案的完整性属性(特别是一致性)。 使用Kafka,您可以获得即使在出现故障时也不会丢失消息的保证。使用"LazyPersistence“选项会失去这种保证吗? 所谓“无损失”,我的意思是消息将对客户端可用,即使在重启后出现故障-理想情况下,所有到达客户端的消息都以正确的顺序。 ActiveMQ ( "classic“或Artemis)是否保证失败时不会丢失消息?有没有什么配置选项可以保证这一点?如果"classic“和Artemis的答案不同,那就太好了。
浏览 3
提问于2020-08-23
得票数 0
3
回答
Message broker与MOM (面向消息的中间件)
、
、
、
、
我对消息代理(例如RabbitMQ )和面向消息的中间件之间的区别感到有点困惑。除了维基百科上的内容,我找不到太多的信息。在搜索MOM时,我找到了AMQP上的信息,其中说明了MOM的协议。这是什么意思?那妈妈是什么呢?我还了解到RabbitMQ实现了AMPQ协议。那么为什么这会使RabbitMQ成为消息代理呢?消息代理和MOM是一回事吗? 希望一些人能解开我的困惑。谢谢
浏览 18
提问于2012-11-03
得票数 29
4
回答
链接服务器相关
、
我有两个Server实例: Server1 ( Server 2008) Server2 ( Server 2005) 我正在从Server1执行一个存储过程,它引用Server2上的表。 它在我的测试环境中运行得很好: Server1运行Vista SP2,Server 2008; Server2运行Windows SP2,Server 2005。 但是,它不能在生产环境中工作: Server1运行Vista SP1,Server 2008; Server2运行Windows SP2,Server 2005。 我收到的错误消息是: OLE D
浏览 2
提问于2010-02-04
得票数 0
回答已采纳
4
回答
连接到ActiveMQ Artemis队列的单个使用者中的消息顺序问题
在接收单个队列使用者和多个生产者时,是否可能出现消息顺序问题?producer1在2021-06-27 02:57:44.513上发布消息m1,在同一队列worker_consumer_queue上在2021-06-27 02:57:44.514上发布消息m2。连接到配置为单个使用者的队列的客户端代码应该首先按照m1的顺序接收消息,然后按照m2的顺序接收消息,对吗?有时接收消息的顺序不对。版本为ActiveMQ Artemis 2.17.0。尽管我提到了多个生产者,但使用属性blockOnDurableSend=false从同一个线程逐个发布消息。 我创建并关闭每个消息发布的生产者。在同一个J
浏览 3
提问于2021-06-27
得票数 0
回答已采纳
1
回答
分布式计算、微服务和并行计算的区别是什么?
、
、
我对以下内容的基本理解: 分布式计算是一种连接节点的模型,从-from硬件的角度来看,它们只共享网络连接-并通过消息进行通信。每个节点代码负责一部分业务逻辑,因为在ERP系统中有一个节点负责hr,一个节点负责记账。通信可以是HTML、SOA、RCP 微服务是一种服务,它负责业务逻辑的一部分,并通常通过http进行相互通信。微服务可以共享硬件资源,并通过它们的api访问。 并行系统是优化资源使用的系统。例如,多线程应用程序运行在共享内存资源的多个线程上。 我有点困惑,因为微服务是分布式系统,但当在单个硬件资源上运行多个微服务时,它们也是并行系统。我是不是已经明白了:
浏览 0
提问于2016-12-10
得票数 18
1
回答
如何转换尾随的减号
CSV文件中的数据在末尾包含负号。如何将其转换为常规数字。 CSV中的数据 Amount 10 12.12- 41 42- 14.14- 期望的 10 -12.12 41 -42 -14.14
浏览 0
提问于2017-08-06
得票数 1
回答已采纳
1
回答
为什么SQS消息写入和删除会给出错误的计数?
、
、
我编写了以下代码,以便将一些消息写入SQS队列并立即删除它们。但是,我在输出中看到,每条消息都会被即时删除。然而,我看到消息计数非常随机地出现。我的意思是,它最初显示1,然后再次显示2,尽管又删除了一个。我已经将可见性超时设置为50秒,就像在这个中提到的那样。作为程序的一部分,我尝试了相同的方法。 所以我的疑问是删除消息是否会立即发生。如果是这样,这将如何影响线程计数。请看下面的代码和输出。 __author__ = 'Dhanapathi.Marepalli' import boto.sqs conn = boto.sqs.connect_to_region("u
浏览 0
提问于2015-11-02
得票数 0
1
回答
参与者模型是否适合处理经过时间的应用程序?
、
、
、
、
我需要创建一个具有计时器/定期检查两个时间戳的分布式应用程序。是否有可能通过行为者模式实现以下行为: 产卵儿童演员 向子参与者发送消息,启动检查时间戳的例程 在计时器过期时不接收任何可用作触发器的消息时执行一些操作 传入的消息可以更改将定期检查的时间戳。 如果失败,主管需要用最后两个收到的时间戳恢复失败的参与者。在执行由计时器触发的事件时稍微延迟(重新启动参与者和重新应用状态)是可以接受的。 任务的关键目标是不丢失任何应该发生在两个时间戳之间一定时间内的事件,并不惜一切代价消除单个故障点。 演员模型(用Erlang或AKKA实现)是否适合解决这个问题?如果不是,其他更适合这种情况的模型/系统是
浏览 0
提问于2018-09-23
得票数 5
3
回答
管理JVM外代理池和通信
、
、
我需要从我的应用程序中管理一个代理池。所有代理都是用Java编写的,但是这些代理需要在它们自己的JVM中运行。我编写了一个概念证明,它启动子进程并使用stdout/stdin发送命令和保持活动状态的信息。我还打开了一个套接字连接用于数据传输。 我猜一些连接池的库应该能够帮助管理代理。 代理和主进程之间的通信是怎样的?使用带有XML消息的TCP (JAXB)并不像我希望的那样可靠或方便。有什么建议可以提供更好的库来帮助你吗? 我可以自己写我需要的东西,但我相信其他人已经做得更好了。
浏览 0
提问于2010-07-22
得票数 3
回答已采纳
1
回答
“企业集成模式”这本书是DDD的补充吗?
、
、
对于那些熟悉的人来说。这些模式是DDD的良好补充吗?最初,我认为它们更适合分布式企业应用程序,但我注意到,一些仅将数据库作为外部服务的复杂项目确实受益于消息传递模式。 我一直回避这本书,因为我对高度分布式的服务器端软件不感兴趣。然而,考虑到我越来越多地使用领域事件和事件采购,我有一种感觉,那本书中的模式很可能会在任何DDD项目中重用。 EIP是DDD从业者的必读之书吗?
浏览 2
提问于2013-06-25
得票数 3
回答已采纳
2
回答
Kademlia能否安全地用于具有足够隐私的聊天/讨论应用程序?
、
、
我花了很长时间来考虑去中心化应用程序及其优势,特别是当涉及到大量流量时,它们往往更可靠、更便宜的事实,而集中式应用程序则不是这样(最好的例子是facebook或google,这些服务器消耗大量能源)。 我的问题是: Kademlia可以用于聊天协议吗?它的安全性如何?如果我启用了数据包加密,是否可以保证隐私?如果我调整协议,其他类型的消息传递应用程序是否可以与kademlia (论坛/usenet、电子邮件、IRC)一起使用? 我确信我需要添加很多代码来保护隐私,这样任何人都可以窃听或利用Sybil攻击(在维基百科上有描述)。 你觉得呢?你认为这个项目值得吗? (为我糟糕的英语道歉)
浏览 2
提问于2011-06-17
得票数 3
回答已采纳
1
回答
其他信息系统如何处理卡夫卡动物园管理员解决的问题?
、
、
、
、
动物园管理员是一个协调服务机构,负责处理以下问题- 如果集群中的一个节点发生故障,动物园管理员将查找另一个节点。 处理对共享资源的序列化访问 种族状况死锁。 其他流行的消息传递系统没有动物园管理员。他们当然应该面对动物园管理员声称要解决的问题。 Q1)他们有其他方法来解决这些问题吗?对那些方式放点光。 Q2)他们找到了一种与这些问题共存的方法吗?
浏览 0
提问于2019-07-28
得票数 0
2
回答
在scalabale应用程序中点到点消息传递?
、
、
、
在谷歌搜索了whatsapp这样的聊天信使如何发送/接收消息后,我偶然发现他们使用了基于队列的消息传递系统。我只是想弄清楚这个特性的高级设计是什么? HLD对地雷的理解:-说朋友1和朋友2在线。朋友1已经建立到web服务器1的HTTP连接,朋友2已经建立到web服务器2的HTTP连接,朋友1将消息发送给朋友2。 现在,一旦消息到达web服务器1,我需要将消息传送到web服务器2,以便通过已经建立的web连接将消息推送回朋友2。 我相信,这里可以使用分布式自定义java队列将消息从一个服务器传播到另一个服务器。一旦消息到达一台服务器,它就会将其推送到具有消息内容、fromUserId、toUse
浏览 10
提问于2017-01-28
得票数 7
回答已采纳
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
Kafka分布式消息系统剖析
分布式消息系统之Kafka入门
分布式系统的消息&服务模式简单总结
Apache Kafka 2.0.0 正式发布,分布式消息发布订阅系统
Kafka开发分布发布订阅消息系统学习路线
热门
标签
更多标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM
活动推荐
运营活动
广告
关闭
领券