上一篇【第65篇】Netty优雅降级与熔断——高可用Netty服务的容错设计
下一篇【第67篇】Netty Epoll传输——Linux下性能更好的原生传输层
一、Micrometer+Prometheus
// 添加监控HandlerpublicclassMetricsHandlerextendsChannelInboundHandlerAdapter{privatefinalCounterconnections=Counter.builder("netty.connections").register(Metrics.globalRegistry);privatefinalTimerreadTimer=Timer.builder("netty.read.latency").register(Metrics.globalRegistry);publicvoidchannelActive(ChannelHandlerContextctx){connections.increment();}publicvoidchannelInactive(ChannelHandlerContextctx){connections.decrement();}publicvoidchannelRead(ChannelHandlerContextctx,Objectmsg){Timer.Samplesample=Timer.start();ctx.fireChannelRead(msg);sample.stop(readTimer);}}二、SkyWalking链路追踪
// ChannelHandler集成SkyWalkingpublicclassTracingHandlerextendsChannelInboundHandlerAdapter{publicvoidchannelRead(ChannelHandlerContextctx,Objectmsg){Spanspan=ContextManager.createEntrySpan("netty/receive",null);span.setComponent(ComponentsDefine.NETTY);try{ContextManager.continued(span);ctx.fireChannelRead(msg);}finally{ContextManager.stopSpan();}}}三、LoggingHandler调试
// Netty内置的日志Handlerpipeline.addLast(newLoggingHandler(LogLevel.INFO));// 输出格式：// [id: 0x1234, L:/127.0.0.1:8080 - R:/127.0.0.1:12345] READ: 100B// [id: 0x1234, L:/127.0.0.1:8080 - R:/127.0.0.1:12345] WRITE: 50B四、关键监控指标
| 指标 | 类型 | 含义 |
|---|---|---|
netty.connections.active | Gauge | 活跃连接数 |
netty.read.bytes | Counter | 读取字节数 |
netty.write.bytes | Counter | 写入字节数 |
netty.read.latency | Timer | 读延迟 |
netty.pool.heap.used | Gauge | 堆内池使用量 |
netty.pool.direct.used | Gauge | 堆外池使用量 |
上一篇【第65篇】Netty优雅降级与熔断——高可用Netty服务的容错设计
下一篇【第67篇】Netty Epoll传输——Linux下性能更好的原生传输层
