腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
2
回答
内
蒂
。
写入
处理
程序
外部
的
通道
netty
有没有办法在事件
处理
程序
之外
写入
通道
。我想要向
通道
写入
我在控制台中键入
的
字符串。这有可能吗?future.addListener { println(it.cause()) } } 这是我
的
服务器代码在
处理
程序
中,我只是在连接时发送一个"Hello world"字符串。我得到了O
浏览 19
提问于2019-05-20
得票数 1
1
回答
单个Netty工作线程是否管理管道中
的
所有
处理
程序
?
netty
、
worker-thread
我是新来
的
内
蒂
。我正在尝试找出
通道
流水线中
的
所有
处理
程序
是否都由单个工作线程管理。在这种情况下,工作线程不会被
处理
程序
锁定以完成。或者每个
处理
程序
由不同
的
可用工作线程
处理
?苏达
浏览 1
提问于2013-06-05
得票数 0
回答已采纳
1
回答
Netty如何
处理
在
外部
创建
的
套接字
sockets
、
netty
我们希望让Netty
处理
由该框架创建
的
工作套接字
的
消息(该框架可以获得工作套接字、
通道
、选择键等)。
内
蒂
该如何
处理
此案?
浏览 2
提问于2017-03-10
得票数 0
2
回答
如何向高亮初学者解释
通道
阻塞机制?
go
、
channel
、
goroutine
我
的
问题之一是黄金
通道
阻塞机制是如何工作
的
。这个提示并没有给我多少关于错误发生
的
知识。我已经在谷歌上搜索过了,但我收到
的
几乎每一篇文章都是关于频道
的
深层机制
的
,或者它假设理解单个单词
的
读者block已经提供了所有的信息。但作为初学者,我有很多疑问,比如: 如果一个频道被阻塞了,其他
的
程序
还
浏览 2
提问于2021-06-07
得票数 0
1
回答
以不同
的
配置运行相同脚本
的
两个不同实例
python
、
windows
、
std
、
stdout
、
stdin
我有一个简单
的
脚本,它负责从
外部
API获取数据,让我们称之为connector.py。该脚本将一些参数作为输入,完成其工作,然后将其
写入
文件并返回输出。我想要实现一个调度
程序
,它将创建和管理该脚本
的
两个实例,每个实例都有自己
的
输入(不同
的
设置),并使它们在配置好
的
时间间隔
内
使用下一个约束运行: 输入:将连接器
的
参数从设置传递到子进程,通过stdin
通道
(not as process Args)输出
浏览 1
提问于2021-09-06
得票数 0
1
回答
ASP.NET核心3.1第三方认证
asp.net-core
对于身份验证,我对检索数据
的
服务器
的
调用需要正确
的
jira凭据才能操作。但是,我使用
的
API从未通过直接登录到jira来建立连接。它使用传递
的
凭据在代码中打开一个连接。所以我
的
问题是,在ASP.NET核心3.1中如何正确地做到这一点?我不需要有人为我做所有的工作,只要给我指明正确
的
方向。在WPF中,我只是让用户输入他们
的
名称和密码,并在启动时建立了连接对象。
浏览 1
提问于2020-01-17
得票数 1
回答已采纳
1
回答
缓冲
通道
似乎比我
的
缓冲区大小存储更多
的
值。
go
我目前正在学习有关
通道
的
知识,并编写了这段代码,希望它失败,但它没有。这里到底发生了什么?根据我
的
理解,如果缓冲区大小为2,那么我一次只能存储2个值,而不会陷入僵局。我是不是错过了一个基本
的
理解?c <- 3 c <- 5}() ...因此,经过思考之后,可能
通道
被填充了2 c <- 4 c &l
浏览 2
提问于2022-09-02
得票数 0
1
回答
如何防止Netty在
通道
关闭时删除
处理
程序
?
netty
我使用
的
是Netty 4.1.65.Final。我们有一个代理服务,它接收来自客户端
的
请求,并将该请求转发到下游服务器。因此,我们有两个
通道
/管道,一个与上游客户端,另一个与下游服务器。上行客户端<--上行
通道
-->代理<--下行
通道
-->下游服务器 有一种情况是,上行客户端断开连接,而我们仍在
处理
下行
通道
上
的
下行响应。Netty关闭上游
通道
,并作为其清理过程
的
一部分,删除管道中<e
浏览 11
提问于2021-10-20
得票数 0
1
回答
Clojure - apache kafka
的
core.async接口
asynchronous
、
clojure
、
apache-kafka
、
core.async
、
clj-kafka
我收到了一些消息,但我
的
结构感觉不对劲:我要么无法停止接收消息,要么不得不再次启动go例程来接收更多消息。这是我
的
尝试: (let [consume-chan (chan)] (with-resource [c (consumer config)]
浏览 3
提问于2015-09-15
得票数 0
1
回答
Web服务与用于检索视图数据
的
消息传递
web-services
、
rest
、
integration
、
message-queue
、
messaging
我需要从一些
外部
应用
程序
中获取一些数据,以便在web门户中呈现。我可以通过创建一个简单
的
web服务来实现这一点,例如使用REST或SOAP,通过访问
外部
应用
程序
的
数据库在表示中返回
外部
应用
程序
的
数据。 我也可以通过使用请求-回复模式使用消息传递来实现这一点。如果
外部
应用
程序
的
数据库不知何故不可用,则只需返回一些错误状态,门户网站应用
程序
就可以打印轻松
的</
浏览 4
提问于2011-12-29
得票数 1
1
回答
Netty -用于握手
的
其他管道?
java
、
netty
在我
的
netty客户机中,我有一个只有一个ChannelInboundHandlerAdapter
的
初始管道。使用这个
处理
程序
,我
处理
我
的
协议
的
握手。在此之后,我需要修改管道以正常使用。这意味着我需要删除
处理
程序
,并添加LengthFieldPrepender/LengthFieldBasedFrameDecoder,编码器/解码器和一个ChannelInboundHandlerAdapter做这件事最好
的
浏览 1
提问于2017-11-02
得票数 0
1
回答
Netty客户机有时不会接收所有预期
的
消息
java
、
networking
、
netty
我有一个相当简单
的
测试Netty服务器/客户端项目。我正在测试通信稳定性
的
某些方面,方法是将消息塞满服务器,并计数返回
的
消息和字节,以确保所有内容都匹配。我尝试向我
的
客户端
处理
程序
中添加一个ChannelInterestChanged方法,以查看频道
的
兴趣是否被更改为未读取,但情况似乎并非如此。谢谢!public void run() { }
浏览 7
提问于2012-10-06
得票数 0
1
回答
向具有不同InboundHandler问题
的
同一Netty
通道
写入
同时消息
java
、
multithreading
、
sockets
、
netty
我们有一个多线程应用
程序
,希望避免基于同时请求
的
线性
通道
大小,例如,由30个开放
通道
服务
的
30个并行请求。因此,我们计划使用相同
的
通道
来
写入
多个消息,并向管道添加不同
的
入站
通道
处理
程序
。但是,在某些情况下,一个
处理
程序
的
响应消息被其他
处理
程序
读取,并且存在请求/响应不匹配
的<
浏览 2
提问于2016-07-10
得票数 0
1
回答
NATS JetStream在ASP.Net核中
的
订阅
c#
、
asp.net-core-3.1
、
subscribe
、
jetstream
、
nats.io
我订阅了NATS
通道
,并
处理
从NATS接收到
的
消息。我可以通过连接到NATS并订阅一个主题,在控制台应用
程序
中这样做。现在我正在尝试在ASP.Net核心应用
程序
中配置订阅,这样它就可以始终监听频道并
处理
接收到
的
消息。谁能帮我在ASP.Net核心应用
程序
中如何配置,在哪里配置?
蒂
娅。
浏览 21
提问于2022-07-21
得票数 2
回答已采纳
1
回答
如何将背压应用于Tcl输出
通道
?
tcl
我们有一个应用
程序
,允许用户将任意Tcl代码块(作为回调)传递给自定义API,该API在大型数据树
的
各个元素上调用它。为了提高性能,这是使用线程池来完成
的
,所以事情可以被撕掉。问题是,我们无法控制用户代码,在其中一种情况下,他们正在做一个导致内存爆炸和应用
程序
崩溃
的
放置操作。我不明白
的
是,我没有弄乱任何stdout
的
选项,所以它应该是行缓冲,阻塞,4k。所以,我
的
第一个问题是:为什么会发生这种情况?难道不应该已经施加了反压力来防止这种情况吗?我
浏览 0
提问于2022-01-07
得票数 1
1
回答
春云流发生器批次
spring
、
spring-integration
、
spring-cloud-stream
我一直在开发一个项目,使用1.0.0版本
的
云流运动绑定器()。我有一个入站
通道
(动态流1)正在被我
的
应用
程序
消耗。我
的
应用
程序
本质上是读取、修改并将一条新消息
写入
出站
通道
(动态流2)。我能够一次读取100,200条记录
的
邮件。但是,当涉及到向出站流
的
写入
时,我没有看到一种方法来配置出站
通道
来执行相当于kinesis
的
PutRecordsRequest
的</
浏览 0
提问于2018-09-28
得票数 2
回答已采纳
1
回答
什么是Netty关闭
通道
策略,如果客户端读取数据和应用
程序
继续
写入
?
netty
、
backpressure
我
的
应用
程序
使用Netty4.x和TCP套接字将相同
的
数据分发给多个客户端。我希望我
的
应用
程序
能够容忍一些客户端在数据接收中
的
延迟,但是如果客户端太慢,我希望我
的
应用
程序
放弃(关闭)连接。如果我正确理解,我可以通过适当配置来实现这一点:NettyChannelOutpu
浏览 3
提问于2021-01-12
得票数 0
回答已采纳
1
回答
通道
元素类型太大
的
Golang
arrays
、
matrix
、
go
、
channel
、
goroutine
我正在编写一个并行
处理
矩阵
的
程序
。
通道
是用以下代码创建
的
:对于12值以下
的
任何n,这都很好,但是任何更大
的
错误都会给出如下
的
错误:我是正确地使用缓冲
通道
,还是它们不是解决这个问题
的
方法?任何关于我如何推进这一点
的
浏览 3
提问于2017-05-24
得票数 5
回答已采纳
1
回答
Flume:持久化Source & Sink连接
的
可能性
flume
、
flume-ng
虽然这违反了Flume
的
基本设计原则,但我有一个问题。这有可能保持源和宿之间
的
连接并重用吗?我们使用HTTP源、文件
通道
和Kafka接收器,并使用该配置,由于每个事件
的
源和接收器
的
重新连接,因此无法获得预期
的
吞吐量。 那么,是否有可能对多个事务重用相同
的
HTTP和Kafka连接?
浏览 1
提问于2015-11-18
得票数 2
2
回答
非缓冲信道上
的
死锁
go
、
channel
我目前正在学习教程,并进入了有关频道
的
部分,在进行一些测试时,我发现了一种我很难理解
的
奇怪行为package main c := make(chan string, 1) fmt.Printf("%v", <- c)或将值设置为不同线程上
的
通道
main() { c := make(ch
浏览 9
提问于2021-05-26
得票数 1
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
外部高速缓存SDRAM的基本读写流程
大道如青天,协程来通信,Go lang1.18入门精炼教程,由白丁入鸿儒,Go lang通道channel的使用EP14
30天拿下Rust之并发
详解App Inventor 2 中的文件作用域(作用范围):App、程序包、缓存、兼容、私有、共享
微控制器的3种驱动程序设计技术
热门
标签
更多标签
活动推荐
运营活动
广告
关闭
领券