public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
super.channelRead(ctx, msg);
//write our own code here
｝
我们是否应该编写super.channelRead？为什么？
浏览 0提问于2016-04-29得票数 0
我有一个netty服务器，在其中我在管道中添加了2个ChannelOutboundHandlerAdapters，并且这两个服务器都有channelRead(ChannelHandlerContext ctx, Object msg)，我们在其中接收消息。channelRead()的定义是：
Calls ChannelHandlerContext.fireChannelRead(Object) to forward to the next ChannelInboundHandler in
the ChanelPipeLine.
因此，这意味着通过实现channelRead()，我们的消息将被
浏览 1提问于2021-05-01得票数 0
2回答
在我正在写入文件的channelRead handler适配器的ChannelRead中，我知道如何使用embeddedchannel来对netty处理程序进行单元测试，但是当我们在其中执行文件I/O (ChannelRead)时，如何对这个处理程序进行单元测试呢？类似mock，不依赖于i/O文件。 public class LogHandler : ChannelHandlerAdapter
{
const string Path = @"L:\Log.txt";
public override void ChannelActive(I
浏览 38提问于2019-02-18得票数 0
我看到以下代码(基于netty的服务器)：
public class NettyServerHandler extends ChannelInboundHandlerAdapter {
@Override
public void channelRead(ChannelHandlerContext ctx, Object msg) {
// Release IO thread
AllChannelHandler.channelRead(() -> {
// business logic...
浏览 3提问于2020-01-05得票数 1
回答已采纳
我想知道channelReadComplete()到底是如何工作的。它会在channelRead()完成或channelRead()方法中的读取操作完成时被调用吗？
浏览 125提问于2021-07-29得票数 2
read()的Javadoc说：
请求将数据从通道读取到第一个入站缓冲区，如果读取数据，则触发ChannelInboundHandler#channelRead事件，并触发ChannelInboundHandler#channelReadComplete事件，以便处理程序决定继续读取。
当手动调用channel.config().setAutoRead(false)和read()时，实际读取了多少？假设一个TCP连接没有编解码器，它会读取到入站缓冲区填满，启动ChannelInboundHandler#channelRead，然后停止读取吗？
查看一下，它为每个channelRead调
浏览 0提问于2015-04-08得票数 0
回答已采纳
1回答
我三个月前就开始使用Netty了。最初，它看起来非常简单和直接使用，因为我遵循了在主页为4.x系列提供的例子。
当我更深入地探索它时，我无法理解某些事件或回调名称。例如，我无法理解以下几点之间的区别：
ChannelRead(ChannelHandleContext ctx, Object msg) { ... }
channelRead0(ChannelHandlerContext ctx, String message) { ... }
messageReceived(ChannelHandlerContext, I) { ...}
看到网络主页的例子总是使用channelRead，但
浏览 2提问于2015-03-30得票数 4
回答已采纳
class ClientWebSocketHandler extends SimpleChannelInboundHandler<WebSocketFrame> {
@Override
protected void channelRead0(ChannelHandlerContext ctx, WebSocketFrame frame) throws Exception {
}
}
我只能在channelRead0中接收TextWebSocketFrame & BinaryWebSocketFrame
如何处理PingWebSocketFrame和P
浏览 130提问于2016-07-26得票数 1
回答已采纳
我应该把业务逻辑放在netty4中的什么地方？
我应该把我的代码放在@Override channelRead0()里，还是在里面运行一个任务？我知道这两者都会遇到相同的IO eventLoop，但它们之间有什么不同呢？哪一个更好？
解决方案1：
@Override
channelRead0(){
business code;
}
解决方案2：
@Override
channelRead0(){
ctx.executor().submit(new task(){business code});
//or ctx.channel().eventLoop().submi
浏览 9提问于2017-03-06得票数 0
回答已采纳
1回答
我正在使用gremlin-java访问AWS海王星。我想用一个值列表来设置顶点属性的值。我尝试了以下操作： g.V(<id of vertex>).property(Cardinality.set, "countries", new HashSet<>()).next(); 当我执行它时，我得到了以下异常： Caused by: org.apache.tinkerpop.gremlin.driver.exception.ResponseException: {"requestId":"39207d15-75df-4e04-9c2
浏览 30提问于2019-10-03得票数 2
回答已采纳
我使用ChannelInboundHandlerAdapter类和writeAndFlush来处理来自channelRead()的每一条消息；
public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
ByteBuf msgBuffer = (ByteBuf)msg;
BinaryWebSocketFrame frame= new BinaryWebSocketFrame(msgBuffer);
ctx.writeAndFlush(frame);
}
在本例中:
浏览 0提问于2017-04-27得票数 2
回答已采纳
Play 2.5.0使用Netty4.0.33，而gRPC需要Netty4.1.0(用于http2支持)，这将导致以下异常：
[error] p.c.s.n.PlayRequestHandler - Exception caught in Netty
java.lang.AbstractMethodError: null
at io.netty.util.ReferenceCountUtil.touch(ReferenceCountUtil.java:73)
at io.netty.channel.DefaultChannelPipeline.touch(DefaultChan
浏览 9提问于2016-03-06得票数 7
回答已采纳
JsonInclude.Include.NON_EMPTY是JSON序列化的默认配置，它不包含空值或空值。但是，我需要包含空值和空值，所以到目前为止我所做的-
@Introspected
@JsonInclude(ALWAYS)
public class FindVendorViewModel extends PaginationViewModel {
private List<VendorViewModel> vendors;
public List<VendorViewModel> getVendors() {
return ven
浏览 2提问于2021-01-18得票数 3
我正在测试一个微型控制器。控制器代码如下： @Get("/")
HttpResponse<String> getData(String crsNumber ) {
try {
final HttpResponse response = formDataService.getData(crsNumber);
return response;
} catch (HttpClientException e) {
return HttpResponse.s
浏览 27提问于2020-10-15得票数 0
我以前从未与Netty合作过，我创建了一个Netty服务器。当我发送一些东西给它时，channelRead0永远不会被解雇；只有channelRead。那是为什么，我怎么触发它？我使用的是netty版本4.0.12。谢谢!
服务器：
void run() {
EventLoopGroup bossGroup = new NioEventLoopGroup();
EventLoopGroup workerGroup = new NioEventLoopGroup();
try {
ServerBootstrap b = new ServerBootst
浏览 1提问于2015-07-25得票数 2
回答已采纳
我使用netty编写了一个应用程序，客户端以channelActive方式向服务器发送字符串消息，但服务器不接收该消息。我不知道原因。 服务器代码： public static void main(String[] args) throws InterruptedException {
NioEventLoopGroup boss = new NioEventLoopGroup();
NioEventLoopGroup worker = new NioEventLoopGroup();
try {
ServerBootstrap bootstrap =
浏览 38提问于2019-01-14得票数 0
回答已采纳
2回答
我编写了一个基于netty 4的REST服务器。客户端处理程序如下所示。
netty提供的msg中的bytebuffer容量是变化的。当客户端消息大于缓冲区时，消息被拆分。我发现每个片段都调用了channelRead和ChannelReadComplete。我通常看到的是ByteBuf在512左右，消息在600左右。我得到了前512个字节的channelRead，然后是它们的ChannelReadComplete，然后是剩下的100个字节的另一个channelRead和它们的channelReadComplete -2条消息而不是1条。
我在这里发现了一些相关的问题，但我想知道channelR
浏览 2提问于2014-04-15得票数 1
我正在使用flink 1.3，我已经提交了一份flink申请，工作模式如下：
flink run -m yarn-cluster ....
在控制台上，我已经看到应用程序已经启动，并且我能够看到mysql的接收器。
但是，当我在yarn web ui上导航到这个正在运行的应用程序，并单击它以打开flink web ui时，
flink ui没有打开，出现如下错误，我想问一下这里出了什么问题，谢谢！
16:05:01.858 [nioEventLoopGroup-3-2] ERROR org.apache.flink.runtime.webmonitor.files.StaticFileSer
浏览 33提问于2019-10-29得票数 1
回答已采纳
我有一个复制因子为2的keyspace，我使用的是单实例集群。
我试图用“如果不存在”选项将值插入到该键空间中的一个表中，但得到了一个错误。
在不使用"if not exists“的情况下使用时，将创建行。
来自cli：
insert into domains (domain, time) values ('test.com', 10) if not exists;
我得到了: NoHostAvailable：
从java客户端运行会产生以下错误：
at org.apache.kafka.streams.processor.internals.StreamThread.
浏览 0提问于2018-07-23得票数 0
我的Flink程序在IntellijIdea中成功运行，但当我创建该程序的jar文件以将其作为jar提交时，它显示以下错误
ava.lang.RuntimeException: Could not look up the main(String[]) method from the class org.carleton.cep.monitoring.latest.MobileCEP: org/apache/flink/cep/pattern/conditions/IterativeCondition
at org.apache.flink.client.program.Packaged
浏览 0提问于2017-10-24得票数 2
我正面临着这个错误：
堆栈跟踪：
16/09/22 12:35:01 ERROR QueryExecutor: Failed to execute: com.datastax.spark.connector.writer.RichBoundStatement@58aafaf
com.datastax.driver.core.exceptions.InvalidQueryException: Key length of 105500 is longer than maximum of 65535
at com.datastax.driver.core.Responses$Error.as
浏览 21提问于2016-09-22得票数 1
回答已采纳
应用程序可以从different timezone访问，因此我试图使用类java.time.OffsetDateTime存储日期时间。
startTime: "1996-12-19T16:39:57-08:00",
endTime: "1996-12-19T16:39:57-08:00"
应用程序/API使用OffsetDateTime接收上述格式的时间，我试图使用Apache在Apache中保存同样的时间，但是我得到了以下错误，
org.apache.tinkerpop.gremlin.driver.exception.ResponseException: {
浏览 23提问于2022-08-19得票数 1
1回答
我设置了一个由DynamoDB支持的DynamoDB实例(如中所描述的)，在中创建了一个简单的API来测试CRUD操作，并开始创建和读取。当我试图删除数据时，问题就出现了。在添加时，我调用：
Vertex v = this.g.addV("student").property("name", student.getName()).next()
和回归
Long id = (Long) v.id()
return Long.toString(id)
删除时，我调用：
this.g.V(Long.valueOf(id)).drop().iterate()
并从Gre
浏览 1提问于2018-07-03得票数 2
回答已采纳
我正在用Netty编写一个HTTP代理服务器。
我希望channelRead最多只能在我打电话给read之后才被解雇一次--而不是在其他时间。换句话说，我不希望channelRead在我准备好收到消息之前启动。
我设定了AUTO_READ=false。我曾在ctx.read()的channelActive (其他地方)打过一次电话。
但是，对于基本的curl http://localhost:8080/，channelRead处理程序会触发两次：
io.netty.handler.codec.http.DefaultHttpRequest
io.netty.handler.codec.http
浏览 5提问于2017-08-25得票数 3
我在EMR上运行spark 1.4.1。我正在尝试使用10个节点处理EMR上的大量数据，每个节点的内存为122G和16core。过了一段时间后，我开始出现异常情况。
org.apache.spark.shuffle.FetchFailedException: java.lang.RuntimeException: Executor is not registered (appId=application_1439264479594_0002, execId=17)
at org.apache.spark.network.shuffle.ExternalShuffleBlock
浏览 0提问于2015-08-11得票数 6
我想在HttpDecompressor之前计算压缩大小。
我试着打电话给connection.addHandlerFirst，但不起作用。
HttpClient.create()
.mapConnect((connection, bootstrap) -> connection.map(
conn -> {
conn.addHandlerFirst(new ChannelInboundHandlerAdapter() {
@Override
public void cha
浏览 1提问于2019-09-11得票数 0
回答已采纳
除非使用SimpleChannelInboundHandler channelRead0，否则如果不调用ctx.fireChannelRead，则应该释放输入数据包。
public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
log.error("receive {}", msg);
if (msg instanceof FullHttpRequest) {
FullHttpRequest req = (FullHtt
浏览 0提问于2018-07-05得票数 1
回答已采纳
我正在运行一个防火墙防火墙和身份验证模拟器，在运行它时出现的控制台中，以下信息消息可能每秒钟显示20-50次：
Nov 30, 2022 1:55:13 AM io.gapi.emulators.netty.HttpVersionRoutingHandler channelRead
INFO: Detected non-HTTP/2 connection.
Nov 30, 2022 1:55:13 AM io.gapi.emulators.netty.HttpVersionRoutingHandler channelRead
INFO: Detected non-HTTP/2 connecti
浏览 11提问于2022-11-30得票数 0
我试图使用@MongoFindQuery编写自定义查询，但是它不能处理多个文件，
存储接口
@MongoRepository
public interface BookRepository extends CrudRepository<Book, String> {
@MongoFindQuery("{name: :name, pages: :pages}")
Optional<Book> findBook(String name, int pages);
}
实体类：
@NoArgsConstructor
@Data
@Introsp
浏览 5提问于2022-04-24得票数 0
我已经为SwiftNIO编写了自己的处理程序，但无法让它发送任何内容。
class MyHandler: ChannelInboundHandler
{
public typealias InboundIn = ByteBuffer
public typealias OutboundOut = ByteBuffer
public func channelRead(context: ChannelHandlerContext, data: NIOAny)
{
let message = "The weather is sunny.
浏览 10提问于2022-10-02得票数 0
我使用Netty中的服务器和Java中的客户端。我的目标是上传文件，但我不知道如何从"channelRead0“方法中的httpObject中检索HttpContent和HttpHeader。
@Override
public void channelRead0(final ChannelHandlerContext chctx, final HttpObject object) throws Exception {
System.out.println("ok ici");
如何检索数据以上传其参数由来自客户端的Http请求提供的文件
浏览 0提问于2015-07-01得票数 0
我正在使用netty 4.0.33构建SSL/TLS客户端/服务器。对于每个连接，我希望记录一条消息，表明两个对等点之间的TLS连接成功。我应该把这段代码放在哪里？channelActive还是channelRead0？我对channelActive和channelRead0的用途有点困惑。看起来在服务器端，我们根本不需要channelActive。这是真的吗？
浏览 4提问于2017-04-01得票数 1
1回答
在Cypher for gremlin项目的帮助下，我将cypher查询转换为gremlin。按照所有步骤进行配置，但在运行cypher查询时会遇到以下问题。 301195 [gremlin-server-worker-1] INFO org.opencypher.gremlin.server.op.cypher.CypherOpProcessor - Cypher: MATCH (n) RETURN n
301209 [gremlin-server-worker-1] INFO org.opencypher.gremlin.server.op.cypher.CypherOpProce
浏览 75提问于2021-10-22得票数 0
我正在尝试用HDFS中的Apache 1.2创建一个保存点。我在我的机器上的本地集群中运行Flink。HDFS正在虚拟机中运行。我设法在Flink流作业中写入HDFS，但保存点不会这样做。我的保存点路径是hdfs://hadoop:54310/savepoint/testpoint，在提交任务之前，我在UI中指定了它。
它提供了以下错误消息：(无效路径)
org.apache.flink.client.program.ProgramInvocationException: Failed to submit the job to the job manager
at org.apache
浏览 1提问于2017-05-29得票数 1
回答已采纳
我不知道是什么导致了运行几个小时后运行我的星火作业的异常。
我正在运行星火2.0.2
有调试提示吗？
2016-12-27 03:11:22,199 [shuffle-server-3] ERROR org.apache.spark.network.server.TransportRequestHandler - Error while invoking RpcHandler#receive() for one-way message.
org.apache.spark.SparkException: Could not find CoarseGrainedScheduler.
at
浏览 11提问于2016-12-27得票数 27
回答已采纳
我正在使用netty 4，我正在尝试适应他们的编程模型。但是，在netty的文档中，我还没有找到一个令人满意的答案：
在ChannelInboundHandler.channelRead()中执行长操作是可以的吗？如果这样做，我是否会损害我的应用程序的吞吐量？我是否应该避免这样做，而只将channelRead()用于将任务排队到Executor中
浏览 0提问于2014-02-14得票数 2
回答已采纳
2回答
我使用netty和redis (jedis client)，在每个请求中使用redisdb调用的查询方法，当我用下面的命令在Apache基准测试中测试它时
ab -c 10 -n 10本地主机:2080
发生以下错误。
Mar 10, 2014 3:29:48 PM io.netty.channel.DefaultChannelPipeline$TailHandler exceptionCaught
WARNING: An exceptionCaught() event was fired, and it reached at the tail of the pipeline.
浏览 10提问于2014-03-10得票数 0
回答已采纳
1回答
每次我尝试使用Hadoop-2.6.0-forSequence连接器加载一个庞大的elasticsearch索引时，我都会得到一个错误。
我在亚恩上运行火花。
15/09/30 17:57:21 ERROR shuffle.OneForOneBlockFetcher: Failed while starting block fetches
java.lang.RuntimeException: java.lang.IllegalArgumentException: Size exceeds Integer.MAX_VALUE
at sun.nio.ch.FileChannelImpl.map(
浏览 6提问于2015-10-01得票数 0
回答已采纳
在ChannelInboundHandler.channelRead()方法中，我想调用ByteBuf.nioBuffer()方法来获取ByteBuffer，因为某些逻辑使用的是在NIO ByteBuffer上操作的库(而其他逻辑是在Netty的ByteBuf上操作的)。但是，如果每个ByteBuf.nioBuffer()调用都会导致内存复制操作，那么代价就会很高，我可能需要寻找其他解决方案。因此，我写了以下简单的测试作为试探性调查：
object InboundReadBufferUnderlying {
def main(args: Array[String]): Unit = {
浏览 2提问于2022-03-21得票数 0
我正在使用Micronaut HttpFilter截取请求和其中一个请求体参数。 这就是我到目前为止所做的尝试，但我无法在拦截器中获得请求主体参数。 这里的目的是检查url body参数，如果它与白名单域名不匹配，则将url body参数替换为白名单域名。 拦截器类 package com.aabingunz.web
import groovy.json.JsonSlurper
import io.micronaut.http.HttpRequest
import io.micronaut.http.HttpRequestWrapper
import io.micronaut.http.H
浏览 66提问于2021-07-14得票数 1
回答已采纳
我有播放框架2.5.4与scala版本2.11.7和SBT0.13，事情停止工作后，添加"com.google.firebase" % "firebase-admin" % "6.12.2"到build.sbt文件
应请求获取以下错误
[error] p.c.s.n.PlayRequestHandler - Exception caught in Netty
java.lang.AbstractMethodError: null
at io.netty.util.ReferenceCountUtil.touch(ReferenceCoun
浏览 9提问于2020-02-27得票数 0
网络服务器可以接收来自DontNetyy客户端的信息，但是DontNetty客户端不能接收来自网络服务器的信息
它们使用protobuf序列化对象
c#客户端
var bootstrap = new Bootstrap();
bootstrap
.Group(group)
.Channel<TcpSocketChannel>()
.Option(ChannelOption.TcpNodelay, true)
.Option(C
浏览 0提问于2017-10-23得票数 0
对于某些用例，例如:当它是GET请求或WebSocket升级请求时，HttpObjectAggregator结果是性能开销，可以很容易地省略。
我可以通过检测HttpObjectAggregator不是GET请求还是websocket请求来有条件地添加它吗？
更新1
// on channelRead()
if (req.isInstanceOf[JFullHttpRequest]) {
val aggregator = new JHttpObjectAggregator(Int.MaxValue)
val pipeline = ctx.channel().pipelin
浏览 1提问于2021-03-07得票数 0
回答已采纳
我对CouchbaseVersion 5.5.1有以下问题。
2018-11-01 12:36:51.452 WARN [promotion-customercriteria-ms,,,] [,] 1
--- [cb-io-1-2] c.c.client.core.endpoint.Endpoint : [][KeyValueEndpoint]: Authentication Failure. 2018-11-01 12:36:51.516 WARN [promotion-customercriteria-ms,,,] [,] 1 --- [cb-io-1-2] c.couc
浏览 0提问于2018-11-01得票数 0
我是Helidon框架的新手，从Helidon 2开始，我们的微型服务由JDK11开始。根据需求，我们需要调用外部HTTP/HTTPS端点，并为此开始从下面的资源中探索helidon。
对于成功的场景很好，但是对于错误用例(例如，g 400 )。)，我们希望捕获由外部API引发的错误消息，但不想获得任何方便的方法，并且始终支持堆栈跟踪。
Caused by: io.helidon.webclient.WebClientException: Request failed with code 400
at io.helidon.webclient.WebClientRequestBuild
浏览 17提问于2022-09-26得票数 2
背景：我对整个星火平台和概念完全陌生，我正在努力学习如何通过R和sparklyr来操作它。我开始学习一门关于这个主题的在线课程，我试图用它来进行我自己的数据分析，作为学习它的一种方式。
Problem：我正在尝试加载一个6.3GbCSV数据集(~30百万行，~20 cols)，但是我得到了以下错误(据我所知，相同的块一直在重复，我在这里给出了前3条，否则我将达到帖子的字符限制)。代码运行，但17分钟后退出，出现以下错误(未加载数据)：
Error: java.lang.IllegalStateException: Cannot call methods on a stopped SparkCo
浏览 0提问于2019-01-29得票数 1
回答已采纳
我是新来的，我的第一个问题是关于使用Apache PLC4x的PLC值的请求。我想循环所有的实际I，Q和DB在PLC上可用。因为我不想完成这个任务，所以我循环通过了一组DB，但是如果不能访问这个DB，它只会打印出“错误处理消息”。
是否有可能遍历所有实体？
通过尝试和错误，我找到了一些可访问的DB，但是无法遍历所有可用的数据。
谢谢!
for (int m = 1; m < 10; m++) {
for (int j = 1; j < 9; j++) {
readBuilder.addItem("value_int " + m + "."
浏览 2提问于2019-08-22得票数 4
我使用的是Netty4.1.0.Final，我面临一个消息没有通过出站处理程序传递的问题。我正在张贴一个示例程序，其中有一个入站和一个出站处理程序。入站处理程序在writeAndFlush中使用ChannelHandlerContext，我的理解是它应该将消息转发给管道中可用的第一个可用的出站处理程序。为了简单起见，内存管理被忽略了。
引导码
EventLoopGroup bossGroup = new NioEventLoopGroup();
EventLoopGroup workerGroup = new NioEventLoopGroup();
ServerBootstrap boots
浏览 2提问于2016-09-01得票数 4
for (int i = 1; i <= 100; i++) {
ctx.writeAndFlush(Unpooled.copiedBuffer(Integer.toString(i).getBytes(Charsets.US_ASCII)));
}
ctx.writeAndFlush(Unpooled.copiedBuffer("ABCD".getBytes(Charsets.US_ASCII))).addListener(new ChannelFutureListener() {
@Override
浏览 6提问于2013-12-02得票数 0
回答已采纳
我注意到ctx在不同的处理程序之间是不同的，即使这些处理程序处于相同的管道中，例如
p.addLast("myHandler1", new MyHandler1());
p.addLast("myHandler2", new MyHandler2());
在MyHander1中
@Override
public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
System.err.println("My 1 ctx: "
浏览 2提问于2013-12-04得票数 11
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
