package com.ruoyi.netty.communication; import io.netty.buffer.ByteBuf; import io.netty.channel.ChannelFuture; import io.netty.channel.ChannelHandlerContext; import lombok.extern.slf4j.Slf4j; /** * @author 86175 */ @Slf4j public abstract class ChannelHandlerContextUtils { public static ChannelFuture writeAndFlush(ChannelHandlerContext ctx, byte[] msg) { ByteBuf byteBuf = ctx.alloc().buffer(); byteBuf.writeBytes(msg); return ctx.writeAndFlush(byteBuf); } }