Netty实战：构建TIME协议服务器与客户端

5星 · 超过95%的资源需积分: 10 192 浏览量更新于2024-07-27 收藏 688KB PDF 举报

"Netty网络构架：The Netty Project 3.1 User Guide - The Proven Approach to Rapid Network Application Development" Netty 是一个高性能、异步事件驱动的网络应用程序框架，用于快速开发可维护的协议服务器和客户端。在本指南中，我们将深入探讨Netty的使用，并通过实现TIME协议来学习其核心概念。 TIME协议与之前示例不同，它无需接收请求就发送包含32位整数的消息，并在消息发送后断开连接。这个例子将教你如何构建并发送消息，以及在完成时关闭连接。 1.1. 开始前在开始之前，你需要了解Netty的基本环境和配置要求。 1.2. 写一个丢弃服务器这是Netty入门的简单练习，服务器接收到数据但不做任何处理，仅丢弃。 1.3. 检查接收到的数据通过分析接收到的数据，可以理解Netty如何处理网络通信中的字节流。 1.4. 写一个回显服务器回显服务器会将接收到的数据原样返回给客户端，展示了基本的双向通信。 1.5. 写一个时间服务器实现TIME协议的服务器部分，它发送当前的时间戳给客户端。 1.6. 写一个时间客户端创建能连接到时间服务器并接收时间戳的客户端。 1.7. 处理基于流的传输由于TCP是面向流的，这里讨论了如何处理可能出现的问题，如缓冲区管理和数据完整性。 1.7.1. Socket缓冲区的小问题说明了在处理流传输时，Socket缓冲区可能引发的问题。 1.7.2. 第一个解决方案介绍了一个处理流传输的初步策略。 1.7.3. 第二个解决方案提供了更完善的解决方案来确保数据正确处理。 1.8. 使用POJO而不是ChannelBuffer Netty允许你使用普通Java对象（Plain Old Java Objects, POJOs）进行数据交换，简化编码。 1.9. 关闭应用程序正确关闭应用程序以释放资源并避免潜在的问题。 1.10. 总结这部分总结了入门教程的主要内容。 2. 架构概述 2.1. 丰富的缓冲数据结构 Netty提供了高效的数据结构，如ByteBuf，用于高效地处理网络数据。 2.2. 通用异步I/O API Netty的异步I/O模型允许并发处理多个连接，提高了性能。 2.3. 基于拦截器链的事件模型 Netty采用拦截器链模式处理网络事件，增强了灵活性和可扩展性。 2.4. 用于更快开发的高级组件 - 编解码框架：Netty提供了一套强大的编码和解码组件，简化了协议处理。 - SSL/TLS支持：集成加密通信，确保网络安全。 - HTTP实现：内置的HTTP支持使开发Web服务变得更加简单。 - Google Protocol Buffer集成：无缝对接Google的序列化协议，便于数据交换。 2.5. 总结这部分概述了Netty的主要架构特性及其优势。通过以上内容，我们可以看到Netty的强大之处，它不仅提供了高效的网络通信基础，还通过各种高级组件和设计模式简化了网络应用的开发。

Writing a Discard Server

}

ChannelPipelineCoverage annotates a handler type to tell if the handler instance of the

annotated type can be shared by more than one Channel (and its associated ChannelPipeline).

DiscardServerHandler does not manage any stateful information, and therefore it is annotated

with the value "all".

DiscardServerHandler extends SimpleChannelHandler, which is an implementation

of ChannelHandler. SimpleChannelHandler provides various event handler methods that

you can override. For now, it is just enough to extend SimpleChannelHandler rather than to

implement the handler interfaces by yourself.

We override the messageReceived event handler method here. This method is called with a

MessageEvent, which contains the received data, whenever new data is received from a client. In

this example, we ignore the received data by doing nothing to implement the DISCARD protocol.

exceptionCaught event handler method is called with an ExceptionEvent when an exception

was raised by Netty due to I/O error or by a handler implementation due to the exception thrown while

processing events. In most cases, the caught exception should be logged and its associated channel

should be closed here, although the implementation of this method can be different depending on what

you want to do to deal with an exceptional situation. For example, you might want to send a response

message with an error code before closing the connection.

So far so good. We have implemented the first half of the DISCARD server. What's left now is to write the

main method which starts the server with the DiscardServerHandler.

package org.jboss.netty.example.discard;

import java.net.InetSocketAddress;

import java.util.concurrent.Executors;

public class DiscardServer {

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

ChannelFactory factory =

new NioServerSocketChannelFactory (

Executors.newCachedThreadPool(),

Executors.newCachedThreadPool());

ServerBootstrap bootstrap = new ServerBootstrap (factory);

DiscardServerHandler handler = new DiscardServerHandler();

ChannelPipeline pipeline = bootstrap.getPipeline();

pipeline.addLast("handler", handler);

bootstrap.setOption("child.tcpNoDelay", true);

剩余24页未读，继续阅读

vv55vv55

粉丝: 0
资源: 1

Netty实战：构建TIME协议服务器与客户端

Netty网络IO通讯开发新手视频教程

零基础入门Netty网络IO通信视频课程22章

Netty网络编程深度指南：从入门到实战

netty网络源码

后端netty网络编程

netty网络编程学习文档

Netty网络编程视频教程

netty网络通信jar包文件

零学习netty网络IO通讯开发

netty 网络游戏网页游戏服务端客户端源码

最新资源