腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
Vertx
eventbus
中
的
限制
消息
、
既然
Vertx
中
的
eventbus
是为异步
消息
传递而设计
的
,那么有可能
限制
这些
消息
的
处理速度吗?如果是这样,我们可以使用worker verticle来实现,还是必须创建一个单独
的
线程组。重点是事件总线可能能够将一百万条
消息
排队(我猜是这个数字),在工作线程/线程下发生
的
后续操作应该不会被淹没,并最终造成一些故障。请打碎一些光亮。
浏览 17
提问于2020-04-23
得票数 0
2
回答
为什么
Vertx
事件总线在高负载下会阻塞?
、
、
、
我试图在
Vertx
事件总线上发送大量
消息
,比如这样
的
消息
(使用Hazelcast集群),而不阻塞:
vertx
.setPeriodic(1, num -> { });当计时器<e
浏览 1
提问于2020-12-15
得票数 0
回答已采纳
2
回答
如何将
消息
从REST传递/获取到
消息
总线?
、
、
、
在现实生活
中
,
消息
总线应该接收来自不同来源
的
消息
,并将
消息
传递给另一个目标。因此,我们只需将
消息
发布到总线。但是,如何正确地读取和处理所有的
消息
呢?例如,从REST接口:读取该
消息
!我
的
简单应用程序开始:
Vertx
vertx
=
Vertx
.
vertx
();
浏览 2
提问于2016-06-18
得票数 1
回答已采纳
1
回答
如何使用
vertx
.
eventBus
().send()方法将RoutingContext对象从routing verticle发送到其他verticle?
、
从我
的
具有路由URL
的
路由垂直节点,我想将RoutingContext对象发送到另一个垂直节点。我相信我们只能使用
vertx
.
eventBus
().send()将
消息
从路由垂直节点发送到其他操作垂直节点。是否可以将RoutingContext对象作为
消息
发送?在路由器纵向测试
中
,我正在执行
vertx
.
eventBus
().<RoutingContext>send("address", routingCo
浏览 17
提问于2019-08-16
得票数 0
1
回答
如何在
vertx
中使用事件总线
消息
传递?
、
、
我按照
中
的
说明运行:
vertx
run
eventbus
_pointtopoint/sender.rb-cluster➜ ruby
vertx
run
eventbus
_pointtopoint/receiver.rb -cluster Starting clustering..No clust
浏览 3
提问于2014-12-12
得票数 0
回答已采纳
1
回答
如何在Vert.x
中
测试事件处理程序(从事件总线)?
、
我对Vert.x3还不熟悉,我正试图为一个简单
的
事件处理程序编写一个单元测试。现在,我所要做
的
就是检查测试
中
的
垂直线是否委托给正确
的
组件,该组件是使用Mockito作为模拟创建
的
。void setUp(TestContext context) { //verticle is set up with mockcontext) {
EventBus</
浏览 0
提问于2016-09-21
得票数 2
1
回答
eventBus
().consumer()从不被调用
、
、
通过向build.gradle添加以下依赖项,我已经将vert.x添加到了Spring Boot应用程序
中
: compile "io.
vertx
:
vertx
-core:3.8.1" compile"io.
vertx
:
vertx
-lang-groovy:3.8.1" 我想使用vert.xjvm在单个
EventBus
应用程序
中
实现反应式代码(没有Verticle)。但是,没有任何入站拦截器或使用者被调用
的</e
浏览 82
提问于2019-10-07
得票数 0
回答已采纳
2
回答
Vertx
:
消息
回复超时
我有一个发送者和一个消费者来交换
消息
:@Override
eventBus
.send(Constants.ADDRESS, "Hello from sender", res -
eventBus
= null;
浏览 3
提问于2018-03-23
得票数 3
1
回答
Vertx
发现节点但看不到
消息
当我启动一个新
的
clusteredVertx时,集群管理器找到网络上
的
其他节点,但是分布式
eventBus
看不到发布在测试地址上
的
消息
。192.168.21.51]:5703 Member [192.168.25.8]:5701 this但是当一条测试
消息
发布到通道“JsonObject”上时,如下所示:
eventBus
eB1 =
vertx
.
eventBus
(
浏览 0
提问于2015-10-09
得票数 1
1
回答
从事件总线获取用户
、
UserMongoWorker.MONGO_FIND_USER, message.body(), res -> { });我
的
问题是就像我在routingContext上做
的
那样?
浏览 3
提问于2015-10-05
得票数 0
2
回答
Vertx
:如何通过交付方式将
消息
从一个垂直转发到另一个?
我不想编写多余
的
代码来复制
消息
头,创建另一个
消息
对象并传递它。是否有一种方法可以完整地在vert.x中转发
消息
?
浏览 4
提问于2017-08-24
得票数 0
回答已采纳
1
回答
向rxjava
vertx
EventBus
添加自定义编解码器
、
、
我正在使用
vertx
-rx-java 我有两个顶点,它们使用
EventBus
相互通信,其中一个顶点返回复杂对象作为结果,为此,我创建了自定义MessageCodec,并希望在
EventBus
中注册它。在标准io.
vertx
.core.
eventbus
.
EventBus
中
,有一种方法registerCodec,它提供了为该
EventBus
注册自定义编解码器
的
可能性。但是,由于我使用
的
是io.
vertx
浏览 69
提问于2018-09-21
得票数 0
回答已采纳
3
回答
在
Vertx
中发送同步
EventBus
消息
、
、
、
、
我想在
Vertx
中
通过
EventBus
发送多条
消息
,但是要同步。我想发送一条
消息
,等待它,并发送下一条
消息
。地址是一样
的
。这就是我默认
的
方式吗?或者有必要使用executeBlocking代码?这是我
的
代码。public class EventBusSync { privat
浏览 1
提问于2018-09-11
得票数 0
1
回答
使用单线程
的
Vert.x事件循环
、
、
、
我使用
的
是vert.x 2.1.5版本。我试图在我
的
项目中使用事件循环。int x = jsonObject1.getInteger("X"); //calling another event //it will create one json object with proper for
浏览 0
提问于2016-07-21
得票数 2
1
回答
Vert.x上
的
Scala编译错误
、
我只想在Vert.x上运行一个简单
的
Verticle示例。class ScalaServer extends Verticle {
vertx
.setPeriodic(1000, { timerId:Long => })} 但是当我在Vert.x上运行这段代码时,编译器报告了以下<e
浏览 2
提问于2014-11-26
得票数 1
1
回答
跨JVM分发订阅者
、
、
、
根据我
的
理解,RXJava在单个JVM
中
工作。是否有一个wrapper/lib/api来支持具有分布式缓存、JMS或任何其他队列组合
的
集群环境,以便为订阅者提供跨分布式环境
的
扩展?
浏览 1
提问于2018-02-23
得票数 0
2
回答
Vertx
:如何将路由器划分为不同
的
类别,保持单个垂直
我们
的
MainVerticle随着路由数量
的
增加而不断增长,例如: LOG.info("Entering一种显而易见
的
方法是静态帮助器类,它接受路由器并在内部进行映射。但如果
Vertx
中
存在现有的模式,例如使用路由器,它将真的很有帮助。
浏览 6
提问于2019-03-26
得票数 1
回答已采纳
0
回答
关于部署verticle
的
上下文问题
的
Vertx
测试
、
所以这有点偷偷摸摸
的
,它不是100%发生
的
,但情况是这样
的
:Jan 09, 2017 2:43:33 PM io.
vertx
.core.impl.ContextImplpublic void start() throws E
浏览 0
提问于2017-01-09
得票数 1
回答已采纳
2
回答
Vt.x SockJSHandler类
、
、
我正在尝试用Vert.x构建一个web应用程序,我已经找到了许多使用SockJSHandler与应用程序前端
的
SockJS javascript库进行通信
的
示例。示例使用版本3.5.0 of Vert.x Core和Vert.x Web,并使用方法SockJSHandler.create(
vertx
)创建类
的
实例,通过方法SockJSHandler.bridge我使用
的
是Vert.xCore和Vert.xWeb
的
最新版本3.8.3,在这个版本
中
,bridge返回一个Ro
浏览 3
提问于2019-11-19
得票数 1
2
回答
Vert.x 4事件总线使用相同
的
编解码器序列化多个类。
、
、
、
基本上,我
的
所有类都应该使用Jackson对象映射器来序列化。但是,似乎我必须为每个类创建一个自定义编解码器(尽管我可以使用泛型对其进行一些抽象)。buffer.getBytes(pos + 4, pos + 4 + length) }}
vertx
.
eventBus
() .registerDefaultCodec(A::class.java, Jacks
浏览 4
提问于2022-02-03
得票数 1
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
WhatsApp 可能会取消删除消息的时间限制!
微软IIS中的IP限制企业实践
ZWave 中的消息队列机制
WhatsApp 消息现已支持编辑操作:限制发送后的 15 分钟内
Redis中的消息中间件
热门
标签
更多标签
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储
活动推荐
运营活动
广告
关闭
领券