I see you can get containers for some of the services. Is there a common way to deploy from docker compose/kubernetes? For things like cloud functions + api gateways.
When sending a IByteBuffer to a channel via WriteAsync/WriteAndFlushAsync - will it a) increment the reference counter when passed in, and b) decrement it once it has been sent?
Trying to work out when I need to decrement my reference (i.e. can I do it after calling .Async, or do I need to .ContinueWith to release it?)
I'm having issues where with libuv the channel is made immediately Inactive. When not using libuv, it seems to work (but perf is terrible)
the client should open and close connection for every request
and we should be able to throttle number of requests
@vsudhini see the samples here:
https://github.com/Azure/DotNetty/tree/dev/examples
The EchoClient is probably the easiest to get started with
_bootstrap = new Bootstrap();
_bootstrap
.Group(_eventGroup)
.Channel<TcpSocketChannel>()
.Option(ChannelOption.TcpNodelay, true)
.Option(ChannelOption.SoBacklog, 100)
.Option(ChannelOption.SoRcvbuf, int.MaxValue)
.Handler(new LoggingHandler("LSTN"))
.Handler(new ActionChannelInitializer<ISocketChannel>(channel =>
{
IChannelPipeline pipeline = channel.Pipeline;
//pipeline.AddLast(new DelimiterBasedFrameDecoder(int.MaxValue, BetaMessageEndDelimeter));
_bootstrap
.Group(_eventGroup)
.Channel<TcpSocketChannel>()
.Option(ChannelOption.TcpNodelay, true)
.Option(ChannelOption.SoBacklog, 100)
.Option(ChannelOption.SoRcvbuf, int.MaxValue)
.Handler(new LoggingHandler("LSTN"))
.Handler(new ActionChannelInitializer<ISocketChannel>(channel =>
{
IChannelPipeline pipeline = channel.Pipeline;
//pipeline.AddLast(new DelimiterBasedFrameDecoder(int.MaxValue, BetaMessageEndDelimeter));
pipeline.AddLast(new ClientHandler());
}));
ClientHandler is getting only partial message
how can i read the entire message coming back from server
@vsudhini Good question. You could create a state machine, but there are really many different possible ways to create a request and response system for any type of socket server, in any language that supports socket servers. Anyway, you could create a class that parses the responses and pass the socket object inside the constructor, and then create a class that takes the socket object to respond to as a parameter as well as the parsed message (or the parsed message object if you were to create a MessageParser class or something), and since you passed those two objects as parameters, you can use those object to send data back to the client using the socket object that was passed as a parameter in the responder class. Make sense? If not, DM me! :smile:
Hi... What would be the best way to block/wait reading more messages for a certain Channel/Context? I have a solution that is acting as a TCP bridge between a Gateway and an IoT Hub.. And while the application is connecting to the IoT hub, I would like to paus reading more messages from the Gateway. Is this solvable with DotNetty or do I have to create my own locking mechanism?
Have anyone experienced that your application after a while runs out of memory because the PooledByteBufferAllocator eats all the memory from the instance? And in that case does anyone have a solution for it?
The problem is that when a client disconnects it still doesn't release the memory, and our clients goes up and down quite often.
The problem is that when a client disconnects it still doesn't release the memory, and our clients goes up and down quite often.
Hello Everyone
I am trying to do something like this :
Logger.info("nested function 1.......", 123);
context.log("context nested function 1.......", 123);
Where Logger is my own library :
static info(...message: any[]) {
context.log(message);
}
Output is :
nested function 1.......,123
context nested function 1....... 123
there is anyway to get out same like context ?
Hi, I wonder if DotNetty has any known security vulnerabilities? On GiHub, none are listed but I can't imagine there aren't any. Does anybody know where I should have a look? In particular, I'd like to know if DotNetty also suffers from a specific vulnerability the Java version "Netty" had in the past (see the corresponding Azure/DotNetty#576 for details).
No response here and no response for the corresponding issue #576? Nobody is able to help with security concerns?
io.netty.allocator.numDirectArenas
dot is invalid symbol
Hi everyone!
I just started with DotNetty/Netty
I'm working on a decoder for my custom protocol. Currently I'm using ReplayingDecoder<Enum> decoder.
Now I'm running into IndexOutOfRangeException: readerIndex(4) + length(1280) exceeds writerIndex(10): PooledHeapByteBuffer(ridx: 4, widx: 10, cap: 256)
So I tried to fix it as followed:
if (input.ReadableBytes >= _messageFrame.Length)
{
_messageFrame.Payload = input.ReadBytes(_messageFrame.Length);
Checkpoint(ProtocolDecoderState.ReadEpilog);
}which breaks my next switch case. case ProtocolDecoderState.ReadEpilog
Here is the whole code:
protected override void Decode(IChannelHandlerContext context, IByteBuffer input, List<object> output)
{
switch (State)
{
case ProtocolDecoderState.ReadProlog:
_messageFrame.Prolog = input.ReadByte();
Checkpoint(ProtocolDecoderState.ReadMessageType);
break;
case ProtocolDecoderState.ReadMessageType:
_messageFrame.SetMessageType(input.ReadByte());
Checkpoint(ProtocolDecoderState.ReadLength);
break;
case ProtocolDecoderState.ReadLength:
_messageFrame.Length = input.ReadShort();
Checkpoint(ProtocolDecoderState.ReadPayload);
break;
case ProtocolDecoderState.ReadPayload:
if (input.ReadableBytes >= _messageFrame.Length)
{
_messageFrame.Payload = input.ReadBytes(_messageFrame.Length);
Checkpoint(ProtocolDecoderState.ReadEpilog);
}
break;
case ProtocolDecoderState.ReadEpilog:
_messageFrame.Epilog = input.ReadByte();
output.Add(ProtocolHelper.CovertByteFrameToMessage(_messageFrame));
Checkpoint(ProtocolDecoderState.ReadProlog);
_messageFrame = new MessageFrame();
break;
default:
throw new InvalidDataException("Shouldn't reach here.");
}
}Do I need to use the ByteToMessageDecoder instead?
Can I not use the ReadBytes(int length) in the ReplayingDecoder?
Thanks!!
1 reply