netty源码分析之服务端启动全解析_Netty源码分析

java

需积分: 9 131 浏览量更新于2023-05-29 评论收藏 1.21MB PDF 举报

身份认证购VIP最低享 7 折!

领优惠券(最高得80元）

资源详情

资源评论

资源推荐

2018/7/3 20)24nettyრᎱړຉԏ๐ۓᒒސۖقᥴຉ - ᓌԡ

ᒫ 1 ᶭҁو 21 ᶭ҂https://www.jianshu.com/p/c5068caab217

nettyრᎱړຉԏ๐ۓᒒސۖقᥴຉ

(!"!#$%&'&()*+,')

ᓌԡᳬኪׂ-(!"!#$%&'&()*+,')

- ! ىဳ

(.*/0*(0*.-(.1)'2 -හ-#3+# -ᴅ᧛-*(((( ᦧᦞ-*/ ࡅཻ-'4 ᩩᩝ-(

background

5,667-ฎӞӻ୑ྍԪկḝۖጱᗑᕶ᭗מ໛ຝٌ҅ො෈໩ጱᥴ᯽ԅ

8,667-9:-;-8<=-&>9,56-:,?@,?-$?;A,BC?D-BE9&E-,5;F>,:-G"9&D-;5%-,;:7

%,@,>CHA,56-C$-5,6BC?D-;HH>9&;69C5:-:"&E-;:-H?C6C&C>-:,?@,?:-;5%-&>9,56:0-<6

I?,;6>7-:9AH>9$9,:-;5%-:6?,;A>95,:-5,6BC?D-H?CI?;AA95I-:"&E-;:-JKL-;5%-MNL

:C&D,6-:,?@,?0

౯ժࣁෛᗦၾ௳വᭆᔮᕹ:;9>$9:E(෭࣐വᭆၾ௳ᰁ+.Պ)҅ෛᗦᑏۖᒒդቘս۸ᔮᕹ

:E;?D(෭࣐ރݺᰁ).Պ)Ӿ࣐҅ᭌೠԧ5,667֢ԅବᗑᕶ᭗מ໛ຝ

෬ᆐӷইྌ᯿ᥝጱᔮᕹବ᮷ֵአکԧ5,667҅ಅզ஠ᆐᥝ5,667ጱ๢ګ҅ኜᛗრᎱԧ

ᝑ೰ഩ҅ԭฎ҅׎؛ኞԧ5,667რᎱᔮڜ෈ᒍݸᶎ҅౯տ᭗ᬦӞᔮڜጱԆ󰵭಩౯՗5,667

რᎱ᯾ಅکጱྺ෫כኸࣈՕᕨᕳ֦҅რᎱԭ#0*0/0O95;>

why netty

5,667ବԭP%Dጱ8<=҅౯ժԅՋԍӧፗളԭP%Dጱ59C౲ᘏٌ՜59C໛ຝҘӥᶎฎ౯௛

ᕮڊ๶ጱܻࢩ

*0ֵአP%Dᛔଃጱ59Cᵱᥝԧᥴጱ༷ஷ҅ᖫᑕ๥

(05,667ବ<=ཛྷࣳᵋ఺ڔഘ҅ᘒᬯӞڔݝᵱᥝ؉ஙጱදۖ

)05,667ᛔଃጱೆ۱ᥴ۱҅୑ଉ༄ၥᒵ๢ګᦏ֦՗59Cጱᔺ᯿ᕡᜓӾᚙᐶڊ๶҅ᦏ֦ݝᵱᥝ

ىஞӱۓ᭦ᬋ

#05,667ᥴ٬ԧP%Dጱஉ۱ೡᑮ󰪋ᦒࣁٖጱF"I

+05,667ବᕚᑕ҅:,>,&6C?؉ԧஉᕡጱս۸҅ᔜஞᦡᦇጱ?,;&6C?ᕚᑕ؉کᶋଉṛ

පጱଚݎቘ

/0ᛔଃݱᐿܐᦓ຾ᦏ֦ቘձ֜Ӟᐿ᭗አܐᦓ᮷پԒӧአՅᛔۖಋ

30 5,667ᐒ܄ၚ᪋᭬҅کᳯ󰵭ᵋ෸ᮒկڜᤒ౲ᘏ9::",

'05,667૪ᕪܲݱ?H&໛ຝ҅ၾ௳Ӿᳵկ҅ړ૲ୗ᭗מӾᳵկᕚӤጱଠာḵᦤ҅؋௔෫

ྲ୩

dive into netty

ԧᥴԧᬯԍ҅Ք౯ժ՗Ӟӻֺৼڊ๶҅୏ত౯ժጱ5,667რᎱԏ෢

๜ᓤԆᥝᦖᬿጱฎ5,667ฎই֜ᕬᒒݗ҅ސۖ๐ۓސۖ๐ۓጱᬦᑕӾ֦҅տԧᥴک

5,667ݱ໐ஞᕟկ҅౯ضӧտᕡᦖᬯԶᕟկ҅ᘒฎտޞᦫ֦ݱᕟկฎெԍԀ᩸๶ᕟ౮

5,667ጱ໐ஞ

example

2018/7/3 20)24nettyრᎱړຉԏ๐ۓᒒސۖقᥴຉ - ᓌԡ

ᒫ 2 ᶭҁو 21 ᶭ҂https://www.jianshu.com/p/c5068caab217

ӥᶎฎӞӻᶋଉᓌܔጱ๐ۓᒒސۖդᎱ

public final class SimpleServer {

public static void main(String[] args) throws Exception {

EventLoopGroup bossGroup = new NioEventLoopGroup(1);

EventLoopGroup workerGroup = new NioEventLoopGroup();

try {

ServerBootstrap b = new ServerBootstrap();

b.group(bossGroup, workerGroup)

.channel(NioServerSocketChannel.class)

.handler(new SimpleServerHandler())

.childHandler(new ChannelInitializer<SocketChannel>() {

@Override

public void initChannel(SocketChannel ch) throws Exceptio

n {

}

});

ChannelFuture f = b.bind(8888).sync();

f.channel().closeFuture().sync();

} finally {

bossGroup.shutdownGracefully();

workerGroup.shutdownGracefully();

}

private static class SimpleServerHandler extends ChannelInboundHandlerAdapter

{

@Override

public void channelActive(ChannelHandlerContext ctx) throws Exception {

System.out.println("channelActive");

}

@Override

public void channelRegistered(ChannelHandlerContext ctx) throws Exception

{

System.out.println("channelRegistered");

}

@Override

public void handlerAdded(ChannelHandlerContext ctx) throws Exception {

System.out.println("handlerAdded");

}

ᓌܔጱپᤈդᎱᚆ୏ސӞӻ๐ۓᒒ҅ᒒݗᕬࣁ''''ֵ҅አ59Cཛྷୗ҅ӥᶎᦖӥྯӞ

ӻྍṈጱቘᕡᜓ

EventLoopGroup -૪ᕪࣁ౯ጱٌ՜෈ᒍ-(E66H:Q!!BBB0P9;5:E"0&CA!H!.%.,,&,/%#/3)Ӿᧇ

ᕡڽຉᬦ҅᧔ጮԧ҅ฎӞӻྒ஗ሾ҅ӧ؊ࣈ༄ၥ<=Ԫկ҅ቘ<=Ԫկ҅ಗᤈձۓ

ServerBootstrap -ฎ๐ۓᒒጱӞӻސۖᬀۗᔄ҅᭗ᬦᕳ՜ᦡᗝӞᔮڜ݇හ๶ᕬᒒݗސۖ

๐ۓ

group(bossGroup, workerGroup) -౯ժᵱᥝӷᐿᔄࣳጱՈଗၚ҅Ӟӻฎᘌ຃҅Ӟӻฎૡ

Ո҅ᘌ຃ᨮᨱ՗ᶎളၚ҅ളکጱၚړᯈᕳૡՈଗ҅නکᬯ᯾҅ bossGroup ጱ֢አฎӧ

ෙࣈ;&&,H6کෛጱᬳള҅ෛጱᬳളӶᕳ workerGroup ๶ቘ

.channel(NioServerSocketChannel.class) -ᤒᐏ๐ۓᒒސۖጱฎ59Cፘىጱ&E;55,>҅

&E;55,>ࣁ5,667᯾ᶎฎӞ໐ஞ༷ஷ҅ݢզቘᥴԅӞ๵&E;55,>ฎӞӻᬳള౲ᘏӞӻ๐

ۓᒒF95%֢ۖ҅ݸᶎտᕡ᧔

.handler(new SimpleServerHandler() -ᤒᐏ๐ۓ࢏ސۖᬦᑕӾ҅ᵱᥝᕪᬦߺԶၞᑕ҅ᬯ᯾

SimpleServerHandler ๋ᕣጱᶮളݗԅ ChannelHander ҅ฎ5,667ጱӞ໐ஞ༷ஷ҅ᤒᐏ

හഝၞᕪᬦጱቘ࢏҅ݢզቘᥴԅၞ࿜ᕚӤጱྯӞ᭲ىܜ

2018/7/3 20)24nettyრᎱړຉԏ๐ۓᒒސۖقᥴຉ - ᓌԡ

ᒫ 5 ᶭҁو 21 ᶭ҂https://www.jianshu.com/p/c5068caab217

public B channelFactory(ChannelFactory<? extends C> channelFactory) {

if (channelFactory == null) {

throw new NullPointerException("channelFactory");

}

if (this.channelFactory != null) {

throw new IllegalStateException("channelFactory set already");

}

this.channelFactory = channelFactory;

return (B) this;

}

ࣁᬯ᯾ᤩᩙ꧊҅౯ժࢧშ҅ັ󰌂ᧆڍහᤩ᧣አጱࣈො҅ݎሿ๋ᕣฎࣁᬯӻڍහӾ҅

KE;55,>O;&6C?7ᤩ5,Bڊ

public B channel(Class<? extends C> channelClass) {

if (channelClass == null) {

throw new NullPointerException("channelClass");

}

return channelFactory(new ReflectiveChannelFactory<C>(channelClass));

}

ᬯ᯾҅౯ժጱ%,ACᑕଧ᧣አ channel(channelClass) ොဩጱ෸ײ҅ channelClass ֢

ԅ ReflectiveChannelFactory ጱ຅᭜ڍහڠୌڊӞӻ ReflectiveChannelFactory

%,ACᒒጱդᎱইӥғ

.channel(NioServerSocketChannel.class);

ᆐݸࢧک๜ᜓ๋୏ত

channelFactory.newChannel();

౯ժݢզവෙڊ๋҅ᕣฎ᧣አک- ReflectiveChannelFactory.newChannel() -ොဩ҅᪙ᬰ

public class ReflectiveChannelFactory<T extends Channel> implements ChannelFactor

y<T> {

private final Class<? extends T> clazz;

public ReflectiveChannelFactory(Class<? extends T> clazz) {

if (clazz == null) {

throw new NullPointerException("clazz");

}

this.clazz = clazz;

}

@Override

public T newChannel() {

try {

return clazz.newInstance();

} catch (Throwable t) {

throw new ChannelException("Unable to create Channel from class " + c

lazz, t);

}

󰌂ک clazz.newInstance(); ҅౯ժกጮԧܻ҅๶ฎ᭗ᬦݍጱොୗ๶ڠୌӞӻ᨝҅ᘒᬯ

ӻ&>;::ฎ౯ժࣁ ServerBootstrap Ӿփفጱ NioServerSocketChannel.class

ᕮຎ҅ᕰԧӞࢻ๋҅ᕣڠୌ&E;55,>ፘ୮ԭ᧣አἕᦊ຅᭜ڍහ5,BڊӞӻ-

NioServerSocketChannel ᨝

剩余20页未读，继续阅读

五坏学生

粉丝: 2
资源: 5

会员权益专享

netty源码分析之服务端启动全解析

评论0

会员权益专享

最新资源

netty源码分析之服务端启动全解析

评论0

netty实现tcp通信服务端代码

物联网netty对接socket设备-netty定义

用netty编写一个服务端和客户端。

使用java，用netty编写一个服务端和客户端，建立连接后，服务端可以发送一条数据给客户端

netty udp 服务端怎么写

springboot整合netty实现tcp

netty通过websocket主动向浏览器推送消息，代码示例

如何用netty实现高效稳定的websocketwebsocket

netty使用websocket解析mqtt

如何实现netty客户端启动给服务器发送版本号

netty通过websocket推送图片在前端<img>中实时展示

spring boot 写 netty调用

问他如何写一个netty聊天室

netty4.0和netty3.0的区别

netty通信clienthandler代码

MINA2与Netty4比较分析

Netty 怎么写聊天室

Java中的netty有一个IdleStateEvent类，该类下有一个state属性，state的值为0，代表着客户端断开连接还是代表着服务端断开连接，为什么

netty核心原理剖析与rpc实践

会员权益专享

最新资源