腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
如何在不同线程中处理@KafkaListener方法?
java
、
spring-boot
、
apache-kafka
、
kafka-consumer-api
、
spring-kafka
我有卡夫卡处理程序在春季靴: public void listen(String response) { } 例如,生产者每秒钟发送一条消息。但是myService.processResponse工作10秒。我需要处理每条消息并在新线程中启动myService.processResponse。我可以创建我的执行者并将每个响应委托给它。
浏览 1
提问于2019-03-19
得票数 1
回答已采纳
1
回答
如何使用spring JmsTemplate为嵌入式activeMQ设置消息优先级?
activemq
、
spring-jms
我正在遵循这个指南- https://spring.io/guides/gs/messaging-jms/我有一些具有更高优先级的消息需要在任何其他消息之前发送。 我已经试过了- jmsTemplate.execute(new ProducerCallBack(){ Message hello1 =session.createTextMessage("Hello1"); producer.send(hello1, DeliveryMo
浏览 18
提问于2019-05-13
得票数 0
回答已采纳
1
回答
卡夫卡和NodeJS的实时通知
node.js
、
websocket
、
notifications
、
apache-kafka
、
consumer
您可以看到,我使用Kafka作为队列消息传递系统,并使用NodeJS构建Websocket和Kafka
消费者
。制片人将收集通知数据并将其推送给卡夫卡。
消费者
将从Kafka读取和处理数据,如果数据属于该用户,则通过websocket将其推送到客户端。那么,我的问题是,上面的设计对于实时通知系统来说是正确的设计吗?你有什么不同的想法吗?如果我有100
浏览 2
提问于2015-10-14
得票数 4
1
回答
具有单个分区的Kafka流在错误上暂停
apache-kafka
、
apache-kafka-streams
我有一个只有一个分区的卡夫卡经纪人。这项要求如下:我使用Kafka流来实现这一点,使用以下代码KStream<Object, Object> consumerStream = builder.stream(kafkaConfiguration.getConsumerTopic()); consumerStream = consumerStream.m
浏览 5
提问于2020-02-06
得票数 0
回答已采纳
1
回答
队列可以持久吗?
rabbitmq
、
masstransit
如果我需要关闭使用者进程(例如,更新),或者需要重新启动服务器(比如Windows修补程序),我希望现有的队列保持不变,
不
丢失任何当前消息,这样,一旦一切恢复正常,处理就可以继续进行,而不需要删除已发布的消息如果没有可用的
消费者
,我希望发布的消息能够积累,直到我让
消费者
恢复
在线
。 在RabbitMQ中,我可以将队列配置为持久的,将消息配置为持久的。如果使用MassTransit,这是可能的吗?
浏览 0
提问于2016-06-24
得票数 2
回答已采纳
1
回答
用java控制kafka消费消息的正确方法
java
、
apache-kafka
什么是正确的方式配置卡夫卡
消费者
暂停一段时间的消息消费,直到消息q回到一个合理的大小。我能暂停一下或者在泳池圈里做点什么吗?我
不
这样认为,否则
消费者
将被标记为非
在线
,我能关闭卡夫卡
消费者
每次信息Q变得太大,然后重新连接,当它回到一个可管理的大小?我可以,但这似乎不是一个干净的解决方案,我想要的是说:“嘿,卡夫卡,请暂停发送信息给我的积极
消费者
,直到我告诉你继续”,因为这将允许我拉信息的速度,我可以插入到我的数据存储。 请帮帮我!
浏览 5
提问于2022-01-27
得票数 3
回答已采纳
1
回答
Web服务中的生产者和
消费者
概念
api
、
rest
、
web-services
我对web服务很陌生,只是碰到了生产者(服务器)和
消费者
(客户端)的概念。由于我可以从其他来源搜索,生产者被定义为生成数据的应用程序,而
消费者
是消费这些数据的应用程序。这是可以理解的,当您以
在线
订购服务为生产者,并将订购数据发送到后端运输服务,在这种情况下,它是
消费者
。但当用户在移动应用程序上查询帐户报表时,当后端数据库将数据返回给用户时,我开始感到困惑。在这种情况下,前端移动应用是生产者还是
消费者
?如果你说它是生产者,那么它的实际结果就是移动应用程序从后端接收数据;如果你说它是
消费者
,
浏览 0
提问于2022-08-07
得票数 0
2
回答
Spring JMS
消费者
拉动
spring
、
jms
、
jmstemplate
我需要实现一个拉动的
消费者
。我看到的大多数例子都是生产者向
消费者
推送消息;假设
消费者
总是
在线
的。我希望生产者将消息推送到队列,而
消费者
按照自己的计划使用这些消息。
浏览 2
提问于2011-05-17
得票数 0
1
回答
为什么Active MQ使用者没有接收到任何消息,即使它是
在线
的?
c#
、
activemq
、
apache-nms
创建了
消费者
Created.Producer。 Msg发送。Msg在队列中排队。但Msg没有退出队列(尽管该队列有一个
消费者
在线
)。<code>G 211</code> 系统上没有记录错误。
浏览 2
提问于2012-04-27
得票数 2
1
回答
iOS中的呼叫和短信计数器
iphone
、
ios
、
objective-c
、
xcode
我想监控iphone中的通话和短信使用情况,比如通话的时间、时间、时长等。短信的情况也是如此。在用谷歌搜索了一下之后,我发现"Consume“是一个应用程序,它可以完成我想要的类似任务。任何人都可以解释“消费”是如何工作的,或者我如何才能做到这一点?
浏览 0
提问于2013-03-20
得票数 4
回答已采纳
1
回答
RabbitMQ溢出队列到磁盘
rabbitmq
如果发布者和
消费者
在线
,这是可以的,但当需要重启
消费者
时,RabbitMQ会填满内存并阻止发布者。当出版商被阻止时,它将快速吞噬RAM。如何配置RabbitMQ使队列溢出到磁盘,内存是否已满?
浏览 0
提问于2012-06-19
得票数 1
1
回答
连接到QuickBooks
在线
IPP
intuit-partner-platform
、
quickbooks-online
我正在制作一个QuickBooks
在线
应用程序。我的客户是如何获得这些信息的: 每个客户是否有不同的访问密钥、访问密钥、
消费者
密钥和用户密钥秘密?根据我的经验,似乎只有realmId (公司ID)更改,其他信息保持不变。
浏览 0
提问于2013-01-14
得票数 0
回答已采纳
1
回答
没有web请求的ASP.NET核心应用程序中的RabbitMQ使用者
c#
、
asp.net-core
、
.net-core
、
rabbitmq
摘要我如何解决它在Setup RabbitMQ consumer in ASP.NET Core application中,但我的兔子
消费者
在线
如果我做网络请求,如果我启动IIS和
不
启动浏览器请求,兔
消费者
不
启动
浏览 15
提问于2019-05-08
得票数 0
1
回答
行动电缆--获取所有
在线
发布/订阅?
ruby-on-rails
、
actioncable
如何获取所有
在线
消费者
(发布者/订阅者)当前在特定渠道上的流媒体?
浏览 1
提问于2018-01-30
得票数 0
3
回答
为什么这个线程化代码挂起
java
、
synchronization
、
synchronized
在下面的代码中,当我执行producercon类时,有时执行会阻塞,看起来像是死锁。但是如果我使get_flag ()同步,那么就不会有这样的问题。 我不明白怎么会有问题。flag可以是true也可以是false,因此producer或consumer中只有一个会进入if语句。在其中一个进入if之后,它将进入带有对象r的监视器(两者都是用相同的对象引用初始化的)。唯一可能发生的问题是,由increment_decrement ()函数调用修改的r对象,同时get_flag ()读取标志,但即使在那时,它也不会在该迭代中进入if,但它将在下一次迭代中进入if块,并且即使第一线程没有离开监视器,它
浏览 0
提问于2011-12-10
得票数 4
回答已采纳
1
回答
VS 11 Express测试版获取开发人员许可证时出错
visual-studio-2012
在VS11Express测试版中,当我试图安装Windows 8
消费者
预览版的开发者许可证时,我收到一个错误消息:“我们无法获得您的Windows 8
消费者
预览版的开发者许可证。然而,我是
在线
的。我能做些什么?
浏览 0
提问于2012-03-05
得票数 5
回答已采纳
1
回答
如何使所有
消费者
参与处理挂起的消息?
jms
、
activemq
第二,
消费者
不消费信息。如果我在第一次
消费者
处理时间的同时向Queue再发送一条消息,第二次
消费者
使用和处理该特定消息(我们在第一次
消费者
处理时间时发送了一条消息) only.After,那么它不会消耗挂起的混乱。最后,我所理解的是,所有挂起的消息都是由第一个
消费者
处理的,而不是剩余的
消费者
。谢谢。
浏览 3
提问于2013-09-13
得票数 0
回答已采纳
1
回答
使用具有多个帐户的Asp.Net QuickBooks SDK
asp.net
、
quickbooks
问题是这个网站的用户都会有不同的QuickBooks
在线
帐户,因此我们的网站必须能够与多个QuickBooks帐户通信。这个是可能的吗??此外,我们可以做到这一点,而不需要每个用户设置一个QuickBooks应用程序,并获得一个
消费者
的秘密,
消费者
的密钥,和安全密钥? 谢谢
浏览 0
提问于2014-06-23
得票数 1
回答已采纳
3
回答
从C#
在线
创建Quickbook客户
c#
、
intuit-partner-platform
、
quickbooks-online
我需要添加新的客户到QuickBooks
在线
从C#。在哪里可以找到访问令牌、访问令牌秘密、领域id和/或公司ID?应用程序令牌,OAuth
消费者
密钥,OAuth
消费者
机密守则如下: var customer = new Customer();
浏览 1
提问于2013-11-18
得票数 2
回答已采纳
1
回答
处理Java的Kafka
消费者
WakeupException
java
、
apache-kafka
、
kafka-consumer-api
如果我
在线
程内运行kafka
消费者
,而不从外部操作它,比如让
消费者
休眠或唤醒他,那么有必要正确地处理WakeupException吗?什么是处理它的好方法?
消费者
运行在and服务上,不断地从队列中拉出数据,并且永远不应该停止这样做。此外,服务没有空闲或挂起状态。在Kafka的文档中指出,只有当kafka
消费者
被另一个线程阻塞时才会抛出异常,但这种情况永远不会发生。
浏览 0
提问于2016-06-09
得票数 5
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
不投资酒店怎么在线卖酒店房间?
到2028年,印度将有5亿在线消费者
音频格式在线转换,不损音质
到底有多看不起中国消费者 特斯拉简配:不道歉也不赔偿
在线消费者倒逼财务官“懂技术”
热门
标签
更多标签
云服务器
即时通信 IM
ICP备案
对象存储
实时音视频
活动推荐
运营活动
广告
关闭
领券