腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(7514)
视频
沙龙
1
回答
基于SQS的具有不同积压SLO的自动缩放处理器
amazon-web-services
、
amazon-sqs
我打算使用Amazon来排队处理需要处理的
消息
,然后使用自动缩放来增加资源,以便在分配的SLO中进行处理。例如,如果一台机器每10秒可以处理一个请求,那么在5分钟内我就可以处理30条
消息
。如果在
队列
中检测到
消息
数量大于30,则应该生成另一台机器以满足5分钟的SLO需求。accordingly.Have 为每个SLO提供一个SQS
浏览 3
提问于2022-08-31
得票数 1
1
回答
NServiceBus: saga如何与SQL持久化程序
并发
?
c#
、
sql-server
、
.net-core
、
concurrency
、
nservicebus
我希望确保在
高
并发
情况下不会在数据库中获得无效数据。另外,是否可以将
并发
配置为使用乐观
并发
而不是SQL持久化程序的悲观
并发
?
浏览 2
提问于2021-05-27
得票数 0
回答已采纳
1
回答
找到将多个数据
消息
交织到一个网络流中的解决方案(在QT框架中)
data
、
networking
、
stream-processing
我需要在基于QT框架的windows应用程序中找到
高
吞吐量网络数据交织的解决方案。必须考虑以下限制:一种天真的方法是将所有
消息
一排排地发送出去。然而,这将在一定的时间内阻止较小的
高
优先级
消息
,因为例
浏览 0
提问于2015-01-08
得票数 2
3
回答
php如何解决
并发
?
php
并发
我是这样理解的: 那么我的问题来了, 加个 if 判断就能解决
并发
?
浏览 668
提问于2017-11-21
4
回答
如何在不保留
并发
的情况下设置lambda最大
并发
?
amazon-web-services
、
aws-lambda
我想限制我的lambda最大执行
并发
性,我来跨reserved concurrency,它可以用来实现这个目标。但是,一旦保留了其他lambda,就无法使用不想影响其他lambda的
并发
性。如何在不使用reserved one的情况下在lambda上设置最大
并发
性?我很乐意放置一个
队列
,例如SQS、Dynamodb流、EventBridge等等,但我无法从它们那里找到解决方案。
浏览 8
提问于2021-04-09
得票数 6
回答已采纳
2
回答
RabbitMQ作为在负载下使用的
消息
代理
rabbitmq
、
spring-websocket
我开发了一个应用程序,我们需要处理160 k
并发
用户,这些
并发
用户通过websocket连接连接到后端。当运行
浏览 3
提问于2018-05-28
得票数 0
回答已采纳
1
回答
使用ConcurrentSkipListMap的
并发
测试
队列
java
、
testing
、
concurrency
、
queue
基本上,它需要实现一个
消息
队列
类: 最后,我所做的是实现一个MessageQueue类,在内部使用ConcurrentSkipListMap (一个
并发
和有序的映射)来保存
消息
,现在,由于它是一个
消息
队列
,因此
浏览 1
提问于2013-01-31
得票数 3
回答已采纳
4
回答
如何控制每个
队列
的
并发
性?
sidekiq
sidekiq文档显示我只能控制Sidekiq的全局
并发
,而不是每个
队列
。我在这里提出一个问题,希望每个
队列
的
并发
设置都有解决方案。一些第三方服务就是不接受
高
并发
性,并且仅仅为了这些限制整个侧边站是痛苦的。 我在sidekiq 3.3上
浏览 0
提问于2015-03-01
得票数 15
1
回答
Spring中的异步事件花费大量时间执行(轮到它)
java
、
spring
、
spring-mvc
、
asynchronous
我有一个应用程序,每当对端点进行REST调用时,我都需要触发电子邮件。设计是,每当调用REST调用时,我将数据保存在db中,发出异步事件并返回。情景 public class DataController { ApplicationEventPublisher eventPubli
浏览 3
提问于2017-07-24
得票数 4
回答已采纳
2
回答
为自定义创建的串行异步
队列
设置优先级
ios
、
objective-c
、
multithreading
、
grand-central-dispatch
、
thread-priority
如何为使用GCD创建的自定义串行异步
队列
设置
高
优先级?我看了一下,其中建议使用dispatch_set_target_queue() & Pass优先级
队列
(DISPATCH_QUEUE_PRIORITY_HIGH),它是自定义串行异步
队列
的
并发
队列
。我的理解是,这将使串行
队列
上的所有任务同时执行。我的理解正确吗?如果是,什么是替代解决方案?
浏览 7
提问于2014-10-03
得票数 6
回答已采纳
3
回答
了解dispatch_async
objective-c
、
asynchronous
、
dispatch-async
waitUntilDone:YES];这段代码的第一个参数是我们是否要求此代码在全局
队列
上执行串行任务,全局
队列
的定义本身就是返回给定优先级的全局
并发
队列
?与主
队列
相比,使用dispatch_get_global_queue有什么优势? 我很困惑。你能帮我更好地理解这一点吗?
浏览 2
提问于2013-04-30
得票数 241
2
回答
POSIX
消息
队列
通过内核空间?
linux
、
posix
、
message-queue
我希望在单进程多线程应用程序上使用POSIX
消息
队列
。mqueues将用于在线程之间共享数据。 我对它们在
Linux
内核中的工作原理有点困惑。是否所有的
消息
都通过内核空间,然后在接收时返回到用户空间?在用户空间线程中,我执行一个mq_send,
消息
最终到达内核空间,然后在接收到它时,是另一个从内核空间获取
消息
的系统调用。如果是这样的话,对于
高
使用率的
消息
队列
来说,这不是非常低效吗?
浏览 0
提问于2011-03-30
得票数 6
回答已采纳
1
回答
Websphere MQ在.NET应用程序中使用100%CPU
c#
、
.net
、
websphere
、
ibm-mq
我有一个.NET应用程序,它使用WebSphere MQ作为可靠的发布/订阅中间件,并且在从服务器向客户端发送后续
消息
队列
时遇到问题。服务器使用来自的XMSClient对象,发布一条
消息
,在确认传递后,检查是否有新的
消息
并发
布,直到没有要发布的
消息
,此时它将等待30秒,并将轮询更多要发送的
消息
。但是,我发现经常发生的情况是,当我有一个
消息
队列
(少于25个)时,WebSphere会突然将CPU使用率推
高
到10
浏览 0
提问于2013-01-30
得票数 0
1
回答
如何为sidekiq
队列
指定
并发
性?
ruby-on-rails
、
concurrency
、
sidekiq
例如,在sidekiq配置中,我有值为4的
并发
性,并有3个
队列
:
高
、默认、低。我在低
队列
中启动了10个ffmpeg活动工作人员,其中4个在运行,在接下来的4个等等之后,所以所有东西都是fine.But,同时我想运行另一个轻量级的作业,比如在另一个
队列
中截图(High)。因此,
高
队列
没有运行,它等待直到运行4-x作业完成,但我不想等待,我想要运行轻量级
队列
完美,如何做到这一点?(在
队列
中的‘课程背景)
浏览 6
提问于2016-01-13
得票数 1
回答已采纳
1
回答
RabbitMQ,是否可以在保持FIFO的同时从信道中消耗1条
消息
?
rabbitmq
、
message-queue
、
messagebroker
我使用RabbitMQ和C#作为
消息
代理框架。在我的场景中,有许多消费者可以从不同的
队列
中消费。从使用者的角度来看,几个
队列
形成了一个逻辑组。下面是一个可能的设置,每个消费者都关心
队列
的子集。Consumer2对所有
队列
感兴趣,在优先级为1,2,因此消费者维护优先级逻辑。请注意,这是一个与这里提
浏览 4
提问于2016-03-31
得票数 0
1
回答
使用Camel RoutePolicy设置
高
优先级/低优先级的SQS路由消费者的优雅方法?
apache-camel
、
amazon-sqs
我有两个SQS
队列
:一个用于低优先级
消息
,另一个用于
高
优先级
消息
。逻辑是不要接触低优先级
队列
上的
消息
,除非
高
优先级
队列
为空。现在,我已经设置了这两个路由,以便同时使用
队列
中的
消息
。我想要的是,进入
高
优先级路由的
消息
会触发低优先级路由的终止。为了尝试获得此功能,我尝试使用一个路由策略,该策略在
高
优先级路由上启动新的交换时停止低优先级
队列
: (摘自S
浏览 0
提问于2020-01-15
得票数 0
3
回答
GCD与自定义
队列
ios
、
objective-c
、
multithreading
、
cocoa-touch
、
grand-central-dispatch
并且创建的自定义
队列
与GCD是分开的,它们可以运行不同的任务,并且一旦释放,它们将被添加回池中。因此,我的假设是,对于复杂的操作,我的customQueue比GCD表现得更好。 你的想法是什么?
浏览 3
提问于2014-02-26
得票数 3
回答已采纳
1
回答
Azure
队列
消息
优先级
azure
、
azure-storage-queues
我在Azure存储中有一个
队列
,名为“messages”。每1小时,某个服务推送到这个
队列
,需要更新数据的
消息
数量。但是,在某些情况下,我也从另一个地方推送到这个
队列
消息
,我希望这个
消息
被立即进行,并且我不能为这个
消息
设置优先级。 解决这个问题的最好办法是什么?我是否可以使用两个不同的
队列
(“
消息
”和“
消息
-优先级”),或者这是一种糟糕的方法?
浏览 2
提问于2014-01-19
得票数 11
回答已采纳
2
回答
是否可以选择创建只接受RabbitMQ和Spring中优先级较高的
消息
的使用者?
java
、
spring
、
rabbitmq
、
spring-rabbit
当具有
高
优先级的
消息
到达时,即使所有使用者实例都在处理其他
消息
,也必须对其进行处理。我试图添加带有x优先级=10标志的
队列
,并增加用户数量,但这并没有解决我的问题。假设我们运行50个消费者
并发<
浏览 0
提问于2019-08-29
得票数 0
回答已采纳
3
回答
如何并行处理
消息
,同时确保每个实体的FIFO?
concurrency
、
message-queue
、
activemq
、
rabbitmq
、
hornetq
ActiveMQ支持用户订阅通配符,但我看不到将每个
队列
上的
并发
限制为1的方法。如果我可以这样做,那么解决方案将是简单明了的: /queue/person.Publisher 以某种方式告诉代理允许所有
队列
的
并发
性为1,开头为:写事件到
队列
,使用
队列
名中的Person ID。如果所有的人
队列
都在使用,一些消费者可能处于空闲状态,这是在处理
消息
后的,使用者发送一个ACK,它告诉代理它已经完成了该
消息
,并允许将该人<e
浏览 7
提问于2011-04-15
得票数 8
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
消息队列新宠—“kafka”能给高并发应用带来怎样的变革?
linux消息队列源码解析
Linux 高级编程-消息队列 MsgQueue
消息队列是如何保证高可用的
如何打造高可靠高性能的消息队列
热门
标签
更多标签
云服务器
即时通信 IM
ICP备案
对象存储
实时音视频
活动推荐
运营活动
广告
关闭
领券