服务端

package com.demo.rpc.netty;import io.netty.bootstrap.ServerBootstrap;
import io.netty.channel.*;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.nio.NioServerSocketChannel;
import io.netty.channel.socket.nio.NioSocketChannel;
import io.netty.handler.codec.string.StringDecoder;
import io.netty.handler.codec.string.StringEncoder;public class NettyServer {public static void main(String[] args) throws InterruptedException {NioEventLoopGroup bossGroup = new NioEventLoopGroup();NioEventLoopGroup workGroup = new NioEventLoopGroup();ServerBootstrap serverBootstrap = new ServerBootstrap();serverBootstrap.group(bossGroup, workGroup).channel(NioServerSocketChannel.class).childHandler(new ChannelInitializer<NioSocketChannel>() {@Overrideprotected void initChannel(NioSocketChannel nioSocketChannel) {ChannelPipeline pipeline = nioSocketChannel.pipeline();pipeline.addFirst(new StringEncoder());pipeline.addLast(new StringDecoder());pipeline.addLast(new SimpleChannelInboundHandler<String>() {@Overrideprotected void channelRead0(ChannelHandlerContext channelHandlerContext, String msg) {System.out.println(msg);}});}});ChannelFuture future = serverBootstrap.bind(9999).sync();future.channel().closeFuture();}
}

客户端

package com.demo.rpc.netty;import io.netty.bootstrap.Bootstrap;
import io.netty.channel.Channel;
import io.netty.channel.ChannelInitializer;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.nio.NioSocketChannel;
import io.netty.handler.codec.string.StringEncoder;public class NettyClient {public static void main(String[] args) throws InterruptedException {NioEventLoopGroup group = new NioEventLoopGroup();Bootstrap bootstrap = new Bootstrap();bootstrap.group(group).channel(NioSocketChannel.class).handler(new ChannelInitializer<Channel>() {@Overrideprotected void initChannel(Channel channel) throws Exception {channel.pipeline().addLast(new StringEncoder());}});Channel channel = bootstrap.connect("127.0.0.1", 9999).channel();while (true){channel.writeAndFlush("hello server");Thread.sleep(2000);}}
}

控制台打印

Netty 客户端服务器端通信 demo相关推荐

客户端服务器通信demo（续） -- 使用二进制协议（附源码）
转载连接: http://blog.csdn.net/zhuweisky/article/details/11827797 在网络上,交互的双方基于TCP或UDP进行通信,通信协议的格式通常分为两类: ...
【Netty】Netty 入门案例分析 ( Netty 模型解析 | Netty 服务器端代码 | Netty 客户端代码 )
文章目录一. Netty 模型代码解析二. Netty 案例服务器端代码 1 . 服务器主程序 2 . 服务器自定义 Handler 处理者三. Netty 案例客户端代码 1 . 客户端主程序 ...
Netty4 学习笔记之一:客户端与服务端通信 demo
前言因为以前在项目中使用过Mina框架,感受到了该框架的强大之处.于是在业余时间也学习了一下Netty.因为Netty的主要版本是Netty3和Netty4(Netty5已经被取消了),所以我就直接 ...
北风网ajax,[T8：JavaScript中利用Ajax实现客户端与服务器端通信北风网收费视频讲座.ppt...
[T8:JavaScript中利用Ajax实现客户端与服务器端通信北风网收费视频讲座 Ajax简介 XMLHttpRequest对象综合案例 1.HTTP请求现在,很多浏览器都可以直接从JavaS ...
java socket通信客户端_JavaのSocket编程之简单客户端与服务器端通信
Socket编程之简单客户端与服务器端通信 socket 通常用来实现客户端和服务端的连接,socket 是Tcp/Ip协议的一个十分流行的编程界面,一个socket 由一个Ip地址和一个端口号唯一确 ...
安卓应用开发Socket通信客户端+服务器端
安卓应用开发Socket通信客户端+服务器端 1. 添加网络权限 <uses-permission android:name="android.permission.INTERNET ...
C#+Socket 聊天室（实现公网通信客户端-服务器端-客户端）
文章目录简述功能演示视频(b站) 准备工作服务器端服务器端界面服务器端代码客户端客户端界面客户端代码总结简述关于Socket的原理我就不在这里赘述了,有大佬已经作详细的说明了: ...
Socket实现服务器端与客户端之间通信（输入文字聊天）
用Socket实现服务器端与客户端之间通信需求: 键盘输入文字使服务器端与客户端可以实现文字通信. 使用的是TCP协议. TCP协议客户端创建Socket连接服务端(指定ip地址,端口号)通过i ...
服务器客户端通信原理,客户端到服务器端通信原理
我们首先要了解一个概念性的词汇:Socket socket的英文原义是"孔"或"插座".作为进程通信机制,取后一种意思.通常也称作"套接字" ...

Netty 客户端服务器端通信 demo

服务端

客户端

控制台打印

Netty 客户端服务器端通信 demo相关推荐

最新文章

热门文章