您现在的位置是：主页 > news > 开发微信微网站建设/可口可乐软文营销案例

开发微信微网站建设/可口可乐软文营销案例

admin2025/6/6 16:20:06【news】

简介开发微信微网站建设,可口可乐软文营销案例,云做网站,教育主管部门建设的专题资源网站网上有很多方式搭建Netty项目，但是都很繁琐，而且不够详细，然后这里列一下最简单的创建方式。一、新建项目： File->New->Project: 然后新建maven项目，不知道maven的可以参考如下链接，其中对后面的项…

开发微信微网站建设,可口可乐软文营销案例,云做网站,教育主管部门建设的专题资源网站网上有很多方式搭建Netty项目，但是都很繁琐，而且不够详细，然后这里列一下最简单的创建方式。一、新建项目： File->New->Project: 然后新建maven项目，不知道maven的可以参考如下链接，其中对后面的项…

网上有很多方式搭建Netty项目，但是都很繁琐，而且不够详细，然后这里列一下最简单的创建方式。

一、新建项目：

File->New->Project:

然后新建maven项目，不知道maven的可以参考如下链接，其中对后面的项目结构也有说明：

https://www.cnblogs.com/whgk/p/7112560.html

填名称和项目标签，示例如下：

填文件位置：

新建完后项目文件结构如下：

二、添加依赖

看完上面关于maven的介绍后这一部分就很好理解了，直接在pom.xml下添加如下语句即可：

三、测试

测试代码随便网上找，这里我引用一下别人的代码

EchoSeverHandler:


import io.netty.buffer.ByteBuf;
import io.netty.buffer.Unpooled;
import io.netty.channel.ChannelFutureListener;
import io.netty.channel.ChannelHandler.Sharable;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelInboundHandlerAdapter;
import io.netty.util.CharsetUtil;@Sharable
public class EchoServerHandler extends ChannelInboundHandlerAdapter{@Overridepublic void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {//将客户端传入的消息转换为Netty的ByteBuf类型ByteBuf in = (ByteBuf) msg;// 在控制台打印传入的消息System.out.println("Server received: " + in.toString(CharsetUtil.UTF_8));//将接收到的消息写给发送者，而不冲刷出站消息ctx.write(in);}@Overridepublic void channelReadComplete(ChannelHandlerContext ctx) throws Exception {// 将未处决消息冲刷到远程节点， 并且关闭该Channelctx.writeAndFlush(Unpooled.EMPTY_BUFFER).addListener(ChannelFutureListener.CLOSE);}/*** 异常处理* @param ctx* @param cause* @throws Exception*/@Overridepublic void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {//打印异常栈跟踪cause.printStackTrace();// 关闭该Channelctx.close();}
}

EchoServer:

import io.netty.bootstrap.ServerBootstrap;
import io.netty.channel.ChannelFuture;
import io.netty.channel.ChannelInitializer;
import io.netty.channel.EventLoopGroup;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.SocketChannel;
import io.netty.channel.socket.nio.NioServerSocketChannel;import java.net.InetSocketAddress;public class EchoServer {private final static int port = 1234;public static void main(String[] args) {start();}private static void start() {final EchoServerHandler serverHandler = new EchoServerHandler();// 创建EventLoopGroupEventLoopGroup bossGroup = new NioEventLoopGroup();EventLoopGroup workerGroup = new NioEventLoopGroup();// 创建EventLoopGroupServerBootstrap b = new ServerBootstrap();b.group(bossGroup, workerGroup)//指定所使用的NIO传输Channel.channel(NioServerSocketChannel.class)//使用指定的端口设置套接字地址.localAddress(new InetSocketAddress(port))// 添加一个EchoServerHandler到Channle的ChannelPipeline.childHandler(new ChannelInitializer<SocketChannel>() {@Overrideprotected void initChannel(SocketChannel socketChannel) throws Exception {//EchoServerHandler被标注为@shareable,所以我们可以总是使用同样的案例socketChannel.pipeline().addLast(serverHandler);}});try {// 异步地绑定服务器;调用sync方法阻塞等待直到绑定完成ChannelFuture f = b.bind().sync();// 获取Channel的CloseFuture，并且阻塞当前线程直到它完成f.channel().closeFuture().sync();} catch (InterruptedException e) {e.printStackTrace();} finally {// 优雅的关闭EventLoopGroup，释放所有的资源bossGroup.shutdownGracefully();workerGroup.shutdownGracefully();}}
}

客户端直接用Sockettool测试：网上下载，很小的一个软件。