以前，我们使用Netty4.0.0.Alpha7开发我们的Websocket应用程序，一切都很好。一旦Netty 4.0.0.Beta 1发布，我们就将它们合并到应用程序中。但是，没有任何客户端能够连接到应用程序。最初，我认为这是我们的问题，所以我们从github获得了websocket示例，而且它也不起作用。
奇怪的是，当我们在本地机器上运行时，我们的应用程序和示例可以正常工作，但是，一旦部署到服务器上，它就不能工作了。当我们回滚到同一台服务器上的Netty Alpha7时，它再次正常工作。有人遇到过这样的问题吗？
下面是在我们的服务器(Linux)中运行Websocket示例时发现的异常。
浏览 1提问于2013-02-18得票数 0
我想使用Netty框架创建一个安全的websocket客户端-服务器通信。我查看了netty示例，其中有一个使用websocket ssl服务器的示例：
还有另一个使用websocket客户端的示例，但没有ssl：
因此，我将SslHandler作为ChannelPipelinehandle中的第一个处理程序，如下所示：
但它仍然不起作用。客户端成功连接到服务器(握手成功)，但是当客户端向服务器发送消息(例如PingWebSocketFrame或任何其他WebSocketFrame)时，没有任何反应。服务器未收到任何消息。
你知道可能出了什么问题吗？
编辑:我使用的是4.0.0.CR5，确切地
浏览 7提问于2013-06-16得票数 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
我有一个netty服务器，它被设置为接收http请求和发送http响应。但是，服务器无法接收http响应。
最初，我在管道中有以下两个处理程序，它作为常规服务器工作得很好。
org.jboss.netty.handler.codec.http.HttpRequestDecoder org.jboss.netty.handler.codec.http.HttpResponseEncoder
为了接收响应，我添加了
org.jboss.netty.handler.codec.http.HttpResponseDecoder
到管道上。但这并没有帮助。
我需要如何配置服务器才能接收http响应？
浏览 3提问于2012-07-18得票数 0
我正在使用Netty开发一个websocket应用程序。我想知道一条消息是否真的从一个源传递到一个目的地。特别是，让我们假设客户机和服务器有一个开放的通道，并交换一些消息。在某种程度上，客户端会出现故障，但Netty中的通道仍然处于活动状态。在发送消息之前，我尝试使用isReachable()，但是在某些场景中，这个方法似乎是错误的(例如，有Win7的机器已经启动，但是isReachable()返回false)。现在，我的想法是使用ack实现一种机制，即服务器发送消息，客户端发送ack。要做到这一点，我需要一个超时来查看，在某个间隔之后，相应的ack是否没有到达。在Netty有类似的东西吗？
浏览 2提问于2014-03-14得票数 0
回答已采纳
我是一个Netty初学者，很难管理客户名单。当客户端连接时，当不同的客户端想通过设备ID向客户端发送消息时，我保存设备ID和区分名称，我如何处理？我已经看过如何使用ChannelGroup来保存连接的客户端的示例。但它只适用于频道，它有attributeKey，但用途不同。我是否只是映射或列表而不是ChannelGroup？有什么好主意吗？你的回答将不胜感激。
浏览 3提问于2014-06-10得票数 1
回答已采纳
1回答
我正试图以一种干净的方式构建应用程序的体系结构。我想我可以在Netty中做到这一点，因为它是著名的java网络框架选项。
我有连接到Netty服务器(通过GPRS的TCP)的设备。假设它们都是永久连接的(保持活动)，并且有几种情况我需要用这个体系结构来讨论：
案例1：设备可以将消息发送给Netty和Netty对该消息的响应
案例2：设备可以将消息发送到Netty和Netty对该消息的响应，但是立即Netty应该向设备发送多条消息，但对于每条消息，它必须等待响应才能发送下一条消息。
Case 3：应用程序中发生了一些事件( Netty作用域之外)，Netty应该对该事件做出反应，并向特定设备发送
浏览 3提问于2016-10-21得票数 0
回答已采纳
1回答
我目前正在为我的“我的世界”服务器系统开发一个web界面。web界面在PHP上运行，插件当然也在java上运行。 我只需要找到一种安全的方法来在Minecraft服务器和HTTP服务器之间交换数据。此外，用户应该能够在web界面中执行命令，然后将这些命令发送到Minecraft服务器并执行。 实际上，我想坚持使用由Spigot和Bungeecord提供的Netty.io，但是我真的看不到在Netty.io中包含PHP的方法。 你们中有谁有办法解决我的问题吗？有什么替代方案吗？我可以做得更好吗?如何在PHP上设置Netty.io？ 非常感谢你的帮助，克里斯
浏览 18提问于2020-12-23得票数 0
回答已采纳
2回答
我想使用Netty或Ratpack来使用json流数据。我的用例是请求体将包含大型json数据(MBs中的json数组)。处理数据的一种方法是阻塞，直到接收到完整的数据，然后启动processing.But，我希望异步处理意味着一旦收到json对象的一个块就会处理它。
我在Netty中偶然发现了JsonObjectDecoder，但我没有运气使用它。这是我的ChannelInitializer课程：
public class ServerInitializer extends ChannelInitializer<SocketChannel> {
@Override
浏览 27提问于2017-02-01得票数 1
我正在构建一个使用Micronaut + Consul + Token Propagation的微服务系统，所以现在我想添加一个API网关，我的第一选择是Netflix Zuul，但Zuul使用Netty代理请求，而Micronaut也是一个构建在netty上的服务器，如何管理这一点？如果我使用ad hoc Zuul (没有Micronaut)，我就会失去Token Propagation。
浏览 10提问于2020-01-29得票数 0
回答已采纳
我建立了一个星星之火的独立集群环境，如下所示：
主人:在云上，有公共IP地址: master_ip_address
工作人员:云上，有公共IP地址
client: NAT网络内部
我在客户端机器中运行以下命令:shell主火花://master_ip_address:7077
在worker web UI中，我查看了stderr日志，它显示：
17/10/17 00:54:39 INFO CoarseGrainedExecutorBackend: Started daemon with process name: 1060@jrWS2016-mSpark
17/10/17 00:54:39 W
浏览 2提问于2017-10-17得票数 0
我正在使用一个现有的Java服务器，该服务器使用Netty4.1接收专有协议。有时，必须将这些消息传递到的下游系统将无法接受它们。当发生这种情况时，将在我的管道中抛出一个异常。在这种情况下，与其实现我自己的恢复机制，我更愿意利用以下事实：(现有的)客户端将重新发送未接收到TCP ACK的消息。
如果是这样，我应该如何实施我的管道来实现这一点？我管道中的所有ChannelHandler实现都在父组中运行，因为它们的操作速度是可以接受的。
浏览 0提问于2020-06-08得票数 1
回答已采纳
2回答
我有两个相同版本的火花。192.168.2.230作为主服务器，192.168.2.5作为从服务器。
我在2.5和2.230上试用了./spark-submit --version
Welcome to
____ __
/ __/__ ___ _____/ /__
_\ \/ _ \/ _ `/ __/ '_/
/___/ .__/\_,_/_/ /_/\_\ version 2.1.0
/_/
Using Scala version 2.11.8, OpenJDK 64-Bit Server VM,
浏览 1提问于2017-04-18得票数 3
回答已采纳
我有2个版本的消息传递项目，较新版本的项目使用Netty 4.1.19最终，旧版本使用Netty 3.6.10最终。
一些客户在项目的两个版本之间发送/接收消息时遇到问题，调试后指出这可能是Netty 4.1.19最终无法从Netty 3.6.10获取响应的原因。
那么Netty 4.1可以和netty 3.6通信吗？提前谢谢你！
浏览 3提问于2018-01-11得票数 0
2回答
我每个人。
我问你是因为我对Netty的解码器中的ByteBuf有问题。
我想对通过服务器到达的消息进行解码，但ByteBuf不能像我那样工作。
问题是ByteBuf并不接受消息的所有字节。
我解释说，我有一个长度为1221字节的消息(这是一个例子)，但缓冲区大小只有64字节。
当我尝试读的时候，缓冲区和我的长度一样，我有一个这样的错误：
io.netty.handler.codec.DecoderException: java.lang.IndexOutOfBoundsException: readerIndex(117) + length(101) exceeds writerIndex(
浏览 20提问于2020-02-07得票数 1
回答已采纳
我使用Oracle作为虚拟机运行Ubuntu。在运行中的VM中，使用以下命令到达停靠点：
sudo docker run -d --name elasticsearch -p 9200:9200 -p 9300:9300 elasticsearch
在Oracle VM机器网络设置中，我添加了以下端口转发：
主客
127.0.0.1:9200 -> 127.0.0.1:9200 127.0.0.1:9300 -> 127.0.0.1:9300
当我尝试使用chrome将http请求发送到地址127.0.0.1:9200和127.0.0.1:9300时，我将得到一个没有问题的
浏览 2提问于2015-06-25得票数 2
我是netty的新手。我更改了HexDumpProxy的示例，添加了http编解码器处理程序，将解码后的http消息从服务器通道写入后端客户端通道，当客户端获得http响应时，它将解码该消息并将响应消息写回inboundChannel (在messageReceived事件中)。但这总是会导致io.netty.buffer.IllegalBufferAccessException异常。我将非常感谢你的任何帮助。耽误您时间，实在对不起。
io.netty.buffer.AbstractReferenceCountedByteBuf.release(AbstractReferenceCounted
浏览 0提问于2013-07-05得票数 0
我遵循了官方Quarkus消息传递指南，并创建了一个简单的示例，以尝试使用AMQP(Apache Artemis)的响应式消息传递功能。 完整的代码是here。 示例运行正常，但这是一个小问题，我必须首先启动一个curl来消费消息，然后使用另一个curl来发送消息。 // start consumer side.
curl http://localhost:8080/messages -H "Accept:text/event-stream"
// start sending.
curl http://localhost:8080/messages -d "Hell
浏览 42提问于2020-10-12得票数 0
1回答
无法注册链码并成功启动区块链网络
、、、、
我正在遵循hyperledger fabric教程，注册我的链码并可能启动docker图像时遇到问题：
以下是我尝试注册链码时遇到的错误：
$ ./Example
Hello world! starting [Ljava.lang.String;@5fd0d5ae
May 10, 2017 9:40:34 PM example.Example main
INFO: starting
May 10, 2017 9:40:34 PM io.grpc.internal.TransportSet$1 call
INFO: Created transport io.grpc.netty.NettyCli
浏览 0提问于2017-05-12得票数 0
1回答
我正在编写一个应用服务器，它将从网络接收、SIP、和DNS消息。
当我收到来自网络的消息时，我从文档中了解到，首先，我得到了一个ChannelBuffer。我想确定哪种消息已经收到(SIP或DNS)，并解码它。
要确定消息类型，我可以将端口专用于每种类型的消息，但我想知道是否存在另一种解决方案。我的问题是更多关于如何解码ChannelBuffer。
是否有Netty提供的ChannelHandler来解码SIP或DNS消息？如果没有，在类型层次结构中编写自定义ChannelHandler的正确位置是什么？
为了说明我的问题，让我们以HttpRequestDecoder为例，层次结构是：
jav
浏览 1提问于2012-07-05得票数 0
我正在制作一个聊天应用程序，其中我使用netty客户端和服务器。假设我使用java客户端向netty服务器发送消息，如何使用netty客户端服务器实现QOS1服务？假设我从客户端使用下面java代码向netty服务器发送消息，
channel.writeAndFlush(uMessage);
谢谢,
浏览 4提问于2017-01-09得票数 0
我遇到了一个非常奇怪的问题，我的程序是使用Netty。
我正在监听一个端口并解析消息(使用FrameDecoder实现)。如果我接收到一个连接，一切正常，但是当我在同一个端口上接收两个连接(每个连接来自不同的服务器)时，我会遇到一种罕见但非常关键的情况，即我得到了corruptedFrameException。
当我的程序接收具有完全相同时间戳(以非常高的速率发送信息时)的TCP数据包时，会发生以下问题
TCP数据包来自服务器1TCP数据包来自服务器2TCP数据包来自服务器1(它是在项目1中开始的消息的延续)TCP数据包来自服务器2(它是标记在项目2中的消息的延续)
我的程序试图将1和2解析为
浏览 3提问于2012-06-04得票数 2
回答已采纳
让我们假设以下管道：
pipeline.addLast(MY_STATELESS_DECODER);
pipeline.addLast(SHARED_EVENT_EXECUTOR, MY_STATELESS_BUSINESS_LOGIC_HANDLER);
我注册了一个ShutdownHook，它像这样关闭NettyServer：
boundChannel.close().await(5000);
bossGroup.shutdownGracefully(0, 10, TimeUnit.SECONDS);
workerGroup.shutdownGracefully(0, 10, TimeUn
浏览 3提问于2013-12-12得票数 2
我在netty4 4-http中使用camel 2.14.0，并得到以下异常。
场景是这样的:我有一个发送请求的路由，等待响应(inOut)，然后发送另一个请求。第一个请求起作用，然后第二个请求失败。
而且，如果我在失败后做得足够快，那么第一个请求也会失败。
在调试bit (HttpObjectEncoder)时，我看到在工作流程中，请求的状态是: state = ST_INIT (0)，在失败的请求中是: ST_CONTENT_NON_CHUNK (1)，当消息类型为HttpMessage时，ST_CONTENT_NON_CHUNK(1)会导致非法状态。
这是一个bug，还是有什么我可以配置
浏览 3提问于2014-10-05得票数 0
回答已采纳
我想建立一个接受包含xml消息的tcp请求的Apache路由模型。
每条消息都可能导致大量响应，这些响应应该被发送回传入套接字上。我在同步模式下玩过骆驼网组件，它适用于单个消息。但是，是否有可能在套接字上发送多条消息？基本上是回归前的分裂。
from(String.format("netty:tcp://0.0.0.0:%s?sync=true&decoders=#length-decoder,#string-decoder&encoders=#string-encoder,#length-encoder", INBOUND_PORT))
浏览 3提问于2015-10-23得票数 0
回答已采纳
1回答
我有一个远程演员，Bar和一个本地演员，Foo。我希望在每次调用CLI时使用Foo将消息传递给Bar。
Bar可以成功地传递消息，但是Foo在等待消息时挂起。为了解决这个问题，我在Foo的main末尾添加了一个Foo，这就导致了Foo系统的关联问题。
如何在连续的CLI发行之间关闭本地演员而不手动杀死本地演员？
闭嘴把密码给我！
Foo：
build.sbt
name := "Foo"
version := "1.0"
scalaVersion := "2.11.8"
libraryDependencies += "com
浏览 0提问于2016-11-23得票数 2
回答已采纳
Spark1.6可以配置为对RPC使用AKKA或Netty。如果配置了Netty，这是否意味着Spark运行时不使用参与者模型进行消息传递(例如，工作人员和驱动程序块管理器之间的消息传递)，甚至在Netty配置的情况下，依赖netty使用自定义简化的参与者模型。
我认为AKKA本身依赖于netty，而Spark只使用AKKA的一个子集。尽管如此，与netty相比，配置AKKA是否更有利于可伸缩性(就工作人员的数量而言)？对这种特殊的火花结构有什么建议吗？
浏览 3提问于2016-12-25得票数 4
回答已采纳
因此，我使用netty编写了一个应用程序，它运行得很好，但它提供了如下所示的调试消息：
WARNING: An illegal reflective access operation has occurred
WARNING: Illegal reflective access by io.netty.util.internal.PlatformDependent0
(file:/C:/Users/******/.m2/repository/io/netty/netty-all/5.0.0.Alpha2/netty-all-5.0.0.Alpha2.jar) to
field java.n
浏览 1提问于2020-06-20得票数 1
回答已采纳
我们使用qpid-jms-client-0.57.0发布和接收来自Azure ServiceBus的消息。ServiceBus提供了从会话接收消息以维护消息顺序的功能。有关更多细节，请参阅这里-
我能够用JMXGroupId发布消息，但不能从启用会话的队列中接收消息。获取错误- javax.jms.JMSException：需要会话的实体不可能创建非会话消息接收方 TrackingId:*，时间戳:2021-07-28T11:07:49 TrackingId:** SystemTracker:gateway7 7，时间戳:2021-07-28T11:07条件=amqp:不允许
您是否可以建议
浏览 7提问于2021-07-28得票数 0
我无法让Google pubsub Java异步客户端干净利落地关闭。在调用Subscriber.stopAsync()之后，我得到的异常如下所示
14:30:07.600 [grpc-default-worker-ELG-1-2] WARN io.grpc.netty.shaded.io.netty.util.concurrent.DefaultPromise - An exception was thrown by io.grpc.netty.shaded.io.grpc.netty.NettyClientHandler$4.operationComplete()
浏览 1提问于2018-11-07得票数 1
在我的spring-boot项目中，我遇到了一些特定依赖项的问题。我正在使用netty-tcnative-boringssl-static，并已将我的spring-boot版本从2.0.5升级到2.1.3，现在我收到以下无法破译的错误消息： ***************************
APPLICATION FAILED TO START
***************************
Description:
An attempt was made to call the method io.netty.internal.tcnative.SSLContext.set
浏览 215提问于2019-05-08得票数 0
我在Hazelcast集群上有一个Vert.x服务器应用程序，客户端连接到集群。应用程序部署在Docker容器中。容器具有具有桥接地址172.17.0.2的网络适配器，运行容器的linux主机具有地址192.168.107.105的网络适配器。在容器属性中，端口1199和5702到外部网络适配器的转发被配置并运行良好。
来自码头检查：
"ExposedPorts": {
"1199/tcp": {},
"5702/tcp": {}
},
其他服务使用的端口11
浏览 0提问于2018-03-25得票数 3
回答已采纳
我有一个两个服务器的服务器结构:一个是内容的主服务器，另一个是运行Play的Scala服务器，执行包括社交登录(fb，tw，g+)在内的用户管理。两台服务器使用相同的通配符SSL证书。
我最近将主服务器从Apache切换到nginx，由于某种原因，Scala服务器抱怨SSL不匹配(这在Apache下以前从未出现过问题)。
当我尝试登录时，我从Play中得到以下错误：
[error] s.c.ProviderController - Unable to log user in. An exception was thrown
java.net.ConnectException: General
浏览 0提问于2014-08-15得票数 11
在我的netty处理程序中，我重写了exceptionCaught方法以捕获由netty ObjectDecoder引发的TooLongFrameException。如果出现这种异常，我将向服务器发送一条消息，其中包含有关该错误的信息。服务器接收到该消息，然后尝试继续发送更多数据。问题是，我的处理程序似乎没有继续读取这些数据。
我使用netty 4.1.18.netty
import io.netty.channel.SimpleChannelInboundHandler;
import io.netty.handler.codec.TooLongFrameException;
public
浏览 4提问于2017-12-11得票数 0
回答已采纳
1回答
我正在评估新的Netty 4.0，并试图了解我需要做些什么才能从3.5转到新的版本。我有几个人要向Netty 4.0.0询问
在Netty4.0.0中，messageReceived方法替换为inboundBufferUpdated方法。用户将一个或多个消息排队到入站(或出站)缓冲区，并触发inboundBufferUpdated (或刷新)事件。
这种方法意味着在用户线程中执行处理程序时，对入站(或出站)缓冲区进行同步。您能建议另一种不使用同步对象(例如Netty3.5中的messageReceived方法)发送内部(或出站)消息的方法吗？
在Netty3.5中，我们使用Simple
浏览 2提问于2012-08-16得票数 1
1回答
TL；博士如何通过SOCKS代理将本地驱动程序连接到星火集群。
我们有一个现场火花集群，它位于防火墙后面，可以阻塞大多数端口。我们有ssh访问权限，所以我可以用ssh -D 7777 ...创建一个SOCKS代理。
当我的浏览器使用代理时，它可以很好地浏览web-UI，但是我不知道如何让本地驱动程序使用它。
到目前为止，我已经知道了这一点，它显然没有配置任何代理：
val sconf = new SparkConf()
.setMaster("spark://masterserver:7077")
.setAppName("MySpark")
new S
浏览 2提问于2015-01-20得票数 7
如果我有以下camel路由并发送udp消息，则不会将任何内容打印到stdout：
<route>
<from uri="netty:udp://0.0.0.0:5000"/>
<to uri="mock:stdout"/>
</route>
但是，如果我添加一个解码器，我可以看到udp消息打印在stdout上
<bean class="org.jboss.netty.handler.codec.string.StringDecoder" id=&
浏览 0提问于2015-01-14得票数 1
我正在构建一个简单的反应性服务器，它应该使用来自多个客户端的传入的protobuf/Protu瘤消息，对它们执行一些业务逻辑，并可能向其他用户发送触发和遗忘消息。我想在Netty中实现传输和解码部分。我的问题是:向Disruptor的环形缓冲区性能发布解码消息是否有意义--或者Disruptor提供的额外性能将被内部Netty调度所否定？我应该为Netty提供两个线程(一个用于“接受”，另一个用于“连接”组)，还是一个更好？也许，我应该在Netty的处理程序中按长度字段拆分消息，并在Disruptor的处理程序中执行解码吗？
浏览 0提问于2014-04-10得票数 6
回答已采纳
我正在使用Netty 4.1。假设我有一个活动的netty通道(TCP或SSL)，并且我为它写了一条消息。这条消息通过我所有的处理程序都没有问题。如果netty由于任何原因无法发送此消息，是否可以保证通道将被关闭(并关闭以后调用的侦听器)？
我试图了解是否可以避免为每次写入和使用voidPromise()优化注册侦听器：
nettyChannel.writeAndFlush(message, nettyChannel.voidPromise());
浏览 1提问于2016-08-31得票数 1
回答已采纳
我正在开发一个Spring项目，其中还包括一个基于netty的socketIO服务器。因此，两个客户端: web客户端和android客户端！他们都在当地工作得很好！但是，当我将在线服务器部署在J弹性中时，只有访问netty-SocketIO服务器的web客户机，但android客户端无法连接到netty-SocketIO服务器。有人可以帮助我将netty-socketIO服务器配置为接受来自端口8888上任何地址的所有请求。
服务器配置
Configuration config = new Configuration();
//config.setHostname("
浏览 3提问于2020-08-07得票数 0
1回答
我正在使用Netty camel-netty:jar:2.10.0.redhat-60024.下面是我对Netty侦听器的配置
netty:tcp://10.1.33.204:9001?textline=true&autoAppendDelimiter=true&delimiter=LINE&keepAlive=true&synchronous=false&orderedThreadPoolExecutor=false&sendBufferSize=2000&receiveBufferSize=2000&decoderMaxLi
浏览 3提问于2014-08-23得票数 0
Netty的页面上写着：“除了JDK 1.5 (或更高版本)，没有其他依赖项”，然而，当我尝试在JDK 1.5下使用Netty 4.0.18编译一个项目时，我得到一条消息：
bad class file: [...]netty-all-4.0.18.Final.jar(io/netty/channel/ChannelHandlerContext.class)
class file has wrong version 50.0, should be 49.0
Netty不再支持Java 1.5了吗？如果是，则应该更新该网页。
浏览 2提问于2014-05-07得票数 0
我一直在开发一个使用Errai消息传递的GWT应用程序。在我通过在errai.bus.enable_web_socket_server=true文件中添加"errai.bus.enable_web_socket_server=true“启用Websocket之前，一切都很好。
在我尝试在Internet上运行之前，没有出现任何问题，当第一条消息在客户端服务器之间发送时，如下所示，消息永远不会到达另一边。
io.netty.handler.codec.http.websocketx.PongWebSocketFrame : org.jboss.errai.bus.server.io.w
浏览 0提问于2014-04-25得票数 1
我实现了类似于基于netty的邮件服务器，它每条消息接收大约160k的数据，一个客户端连接发送一条消息。因此netty可以处理许多短连接和大数据。在这种情况下，有没有更好的方法？也许，在网络配置中有很多最优的选项？我是netty的新用户，请帮助我，谢谢
浏览 0提问于2013-07-04得票数 0
我的公司正在探索使用Netty框架实现消息路由器的可能性。它将路由的消息来自许多不同的来源，并且都有自己的格式。在大多数情况下，消息都是XML格式的，其中包含一个包含正文长度的头部。然而，我们有一个供应商，他的消息是不同的，不包含正文的长度。
这一条供应商消息包含标题、正文和尾部。报头是1个字节，是STX (0x02)，主体是可变长度，尾部是2个字节，其中包含ETX(0x03)，后跟LRC。
因此，典型的消息可能如下所示：
STX BODY ETX LRC
02 37000000 06 18
我们最初使用定义ETX作为分隔符的DelimiterBasedFrameDecoder
浏览 5提问于2014-05-08得票数 2
我正在尝试创建一个Netty (4.1) POC，它可以将h2c (没有TLS的HTTP2)帧转发到h2c服务器--即实质上创建一个Netty h2c代理服务。Wireshark显示了Netty将帧发送出去，以及h2c服务器的应答(例如，使用响应头和数据)，尽管我在Netty本身中接收/处理响应HTTP帧时遇到了一些问题。
首先，我调整了multiplex.server示例(io.netty.example.http2.helloworld.multiplex.server)，以便在HelloWorldHttp2Handler中，而不是使用虚拟消息响应，连接到远程节点：
@Overri
浏览 0提问于2019-05-01得票数 1
1回答
我已经阅读了netty代理服务器的例子。然而，我想知道如何实现一个客户端来与代理进行对话。我正在实现的解决方案是一个服务器，每当客户端连接到server.So时，它都需要连接到套接字服务器，每个连接到服务器的客户端都将能够从另一个服务器发送/接收数据。
我需要帮助来实现这样的架构与netty，因为服务器端是建立在netty上。
浏览 2提问于2013-02-12得票数 1
1回答
活动MQ消息顺序处理
、、、、
我们有两台服务器: server1和server2。这两台服务器都在Wildfly 11的域模式配置下运行。下面是我们如何配置这两台服务器的。
让我们以本例中的server1域节点为例。
问题：
如果具有相同组ID的两个消息同时到达server1和server2，它们将不知道消息应该发送给哪个消费者。因此，消息最终由不同的使用者处理，有时先到达的消息会在稍后得到处理，这是不可取的。我们希望对系统进行配置，使两个节点都知道消息应该由哪个使用者处理。
我们尝试过的解决方案：
已使用组处理程序本地配置server1，并使用远程配置server2。现在，只要消息到达，本地组处理程序就会识别出该特定组I
浏览 12提问于2019-11-14得票数 0
我正在学习Netty和代码示例，用于中的第2章示例
我添加了另一个AnotherEchoServerHandler扩展ChannelInboundHandlerAdapter，在AnotherEchoServerHandler.channelRead方法中，我将它更新为：
public void channelRead(ChannelHandlerContext ctx, Object msg) {
ByteBuf in = (ByteBuf) msg;
System.out.println(
"Log from AnotherEchoServe
浏览 5提问于2021-03-30得票数 0
回答已采纳
1回答
带有GRPC的AWS ALB
、、、、
我试图在AWS ECS (在Fargate上)上运行一个带有GRPC的netty服务器，它位于一个用于连接到Android客户端的应用程序负载均衡器后面。调用被转发，但服务器日志显示的错误如下
io.grpc.netty.shaded.io.netty.handler.codec.http2.Http2Exception: HTTP/2 client preface string missing or corrupt. Hex dump for received bytes: 1603010102010000fe03036a5663244616ee784100b9d61c
我读过，这样的错误与
浏览 9提问于2022-07-06得票数 2
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
