`
liufei.fir
  • 浏览: 686251 次
  • 性别: Icon_minigender_1
  • 来自: 上海
社区版块
存档分类
最新评论

使用 Netty 编写 http服务器

阅读更多
import static org.jboss.netty.channel.Channels.pipeline;   
  
import java.net.InetSocketAddress;   
import java.util.concurrent.Executors;   
  
import org.jboss.netty.bootstrap.ServerBootstrap;   
import org.jboss.netty.channel.ChannelPipeline;   
import org.jboss.netty.channel.ChannelPipelineFactory;   
import org.jboss.netty.channel.Channels;   
import org.jboss.netty.channel.socket.nio.NioServerSocketChannelFactory;   
import org.jboss.netty.handler.codec.http.HttpChunkAggregator;   
import org.jboss.netty.handler.codec.http.HttpRequestDecoder;   
import org.jboss.netty.handler.codec.http.HttpResponseEncoder;   
import org.jboss.netty.handler.stream.ChunkedWriteHandler;   
  
/**  
 * 后台管理服务  
 *   
 * @author javagg  
 *   
 */  
public class AdminServer {   
    public static void main(String[] args) {   
        start(8080);   
    }   
  
    public static void start(int port) {   
        // 配置服务器-使用java线程池作为解释线程   
        ServerBootstrap bootstrap = new ServerBootstrap(new NioServerSocketChannelFactory(Executors.newCachedThreadPool(), Executors.newCachedThreadPool()));   
        // 设置 pipeline factory.   
        bootstrap.setPipelineFactory(new ServerPipelineFactory());   
        // 绑定端口   
        bootstrap.bind(new InetSocketAddress(port));   
        System.out.println(“admin start on ”+port);   
    }   
  
    private static class ServerPipelineFactory implements  
            ChannelPipelineFactory {   
        public ChannelPipeline getPipeline() throws Exception {   
            // Create a default pipeline implementation.   
            ChannelPipeline pipeline = Channels.pipeline();   
            pipeline.addLast(“decoder”, new HttpRequestDecoder());   
            pipeline.addLast(“encoder”, new HttpResponseEncoder());   
            //http处理handler   
            pipeline.addLast(“handler”, new AdminServerHandler());   
            return pipeline;   
        }   
    }   
}  
import static org.jboss.netty.handler.codec.http.HttpHeaders.Names.CONTENT_TYPE;   
import static org.jboss.netty.handler.codec.http.HttpResponseStatus.BAD_REQUEST;   
import static org.jboss.netty.handler.codec.http.HttpResponseStatus.INTERNAL_SERVER_ERROR;   
import static org.jboss.netty.handler.codec.http.HttpResponseStatus.OK;   
import static org.jboss.netty.handler.codec.http.HttpVersion.HTTP_1_1;   
  
import java.util.HashMap;   
  
import org.jboss.netty.buffer.ChannelBuffers;   
import org.jboss.netty.buffer.DynamicChannelBuffer;   
import org.jboss.netty.channel.Channel;   
import org.jboss.netty.channel.ChannelFutureListener;   
import org.jboss.netty.channel.ChannelHandlerContext;   
import org.jboss.netty.channel.ExceptionEvent;   
import org.jboss.netty.channel.MessageEvent;   
import org.jboss.netty.channel.SimpleChannelUpstreamHandler;   
import org.jboss.netty.handler.codec.frame.TooLongFrameException;   
import org.jboss.netty.handler.codec.http.DefaultHttpResponse;   
import org.jboss.netty.handler.codec.http.HttpRequest;   
import org.jboss.netty.handler.codec.http.HttpResponse;   
import org.jboss.netty.handler.codec.http.HttpResponseStatus;   
import org.jboss.netty.util.CharsetUtil;   
  
/**  
 * @author javagg  
 */  
public class AdminServerHandler extends SimpleChannelUpstreamHandler {   
  
    @Override  
    public void messageReceived(ChannelHandlerContext ctx, MessageEvent e)   
            throws Exception {   
        HttpRequest request = (HttpRequest) e.getMessage();   
        String uri = request.getUri();   
                          System.out.println(“uri:”+uri);   
        HttpResponse response = new DefaultHttpResponse(HTTP_1_1, OK);   
                          ChannelBuffer buffer=new DynamicChannelBuffer(2048);   
        buffer.writeBytes(“hello, oschina”.getBytes(“UTF-8″));   
        response.setContent(buffer);   
        response.setHeader(“Content-Type”, ”text/html; charset=UTF-8″);   
        response.setHeader(“Content-Length”, response.getContent().writerIndex());   
        Channel ch = e.getChannel();   
        // Write the initial line and the header.   
        ch.write(response);   
        ch.disconnect();   
        ch.close();   
           
    }   
  
    @Override  
    public void exceptionCaught(ChannelHandlerContext ctx, ExceptionEvent e)   
            throws Exception {   
        Channel ch = e.getChannel();   
        Throwable cause = e.getCause();   
        if (cause instanceof TooLongFrameException) {   
            sendError(ctx, BAD_REQUEST);   
            return;   
        }   
  
        cause.printStackTrace();   
        if (ch.isConnected()) {   
            sendError(ctx, INTERNAL_SERVER_ERROR);   
        }   
    }   
  
    private void sendError(ChannelHandlerContext ctx, HttpResponseStatus status) {   
        HttpResponse response = new DefaultHttpResponse(HTTP_1_1, status);   
        response.setHeader(CONTENT_TYPE, ”text/plain; charset=UTF-8″);   
        response.setContent(ChannelBuffers.copiedBuffer(“Failure: ” + status.toString() + ”\r\n”, CharsetUtil.UTF_8));   
  
        // Close the connection as soon as the error message is sent.   
        ctx.getChannel().write(response).addListener(ChannelFutureListener.CLOSE);   
    }   
}  


  


  
分享到:
评论

相关推荐

    spring+mybatis+netty3.6 HTTP服务器项目

    【标题】"Spring+Mybatis+Netty3.6 HTTP服务器项目"是一个综合性的Web服务开发实例,结合了三个核心的开源技术框架:Spring、Mybatis和Netty3.6。这个项目旨在创建一个高性能、可扩展的HTTP服务器,能够处理GET和...

    C# Netty 客户端,服务器端包含接双向接收

    标题中的"C# Netty 客户端,服务器端包含双向接收"揭示了这是一个关于使用C#语言实现基于Netty框架的客户端和服务器端通信的项目。Netty是Java平台上的一个高性能、异步事件驱动的网络应用程序框架,用于快速开发可...

    Netty4编写服务器客户端,自定义编解码,发送自定义消息

    在这个项目中,我们将深入理解如何利用 Netty 4 来编写服务器和客户端,实现自定义的消息编解码,并进行通信。 首先,我们要创建一个自定义的消息类。这个消息类通常会包含必要的字段,比如消息头、消息体等,以...

    基于netty编写的socket服务端

    在基于Netty编写的socket服务端中,首先需要定义一个`ChannelHandler`,这个处理器负责处理接收到的网络事件,如连接建立、数据读取、连接关闭等。`ChannelHandlerContext`则是`ChannelHandler`和`ChannelPipeline`...

    netty游戏服务器核心

    Netty 是一个高性能、异步事件驱动的网络应用程序框架,用于快速开发可维护的高性能协议服务器和客户端。在游戏服务器领域,Netty 的优势在于它的灵活性、可扩展性和高效的性能,使得它成为构建游戏服务器核心层的...

    netty基于http socket websocke及心跳包机制t的demo

    Netty的HTTP模块允许开发者轻松地构建HTTP服务器和客户端,支持GET、POST等各种请求方法,并且能够处理Cookie和HTTP头部。 接下来是Socket,它是网络编程的基础,Netty的Socket API提供了TCP和UDP的支持。通过使用...

    JavaNetty客户端与服务器

    3. **编写服务器端代码**: - **Bootstrap**: 创建一个`ServerBootstrap`实例,配置线程池、通道工厂、绑定地址和端口。 - **ChannelHandler**: 实现`ChannelInboundHandlerAdapter`,处理接收到的客户端连接和...

    java netty编写的socket tcp服务器+flash actionscript3编写的游戏客户端 C/S程序游戏源代码

    这是一个关于使用Java Netty构建TCP服务器以及Flash ActionScript3开发客户端的游戏C/S程序源代码的项目。这个项目展示了如何在服务器端使用Java Netty框架来处理网络通信,以及在客户端利用ActionScript3来实现游戏...

    netty http协议开发小例子

    在本文中,我们将深入探讨如何使用 Netty 实现 HTTP 协议的开发,结合提供的“NettyStudyServer”文件,我们来详细了解一下相关知识点。 1. **HTTP 协议基础** - HTTP(超文本传输协议)是互联网上应用最为广泛的...

    resteasy使用netty

    3. 创建RestEasy应用上下文:使用ResteasyBootstrap类初始化RestEasy,并将RestEasy的ContextProvider注册到Netty服务器中。 4. 注册REST资源:通过使用@Provider和@Path注解,定义RESTful服务的接口和实现。 5. ...

    Netty4.0 http案例

    总的来说,这个"Netty4.0 http案例"涵盖了如何使用Netty构建高效、可扩展的HTTP服务器和客户端,以及如何处理JSON数据。通过理解这些知识点,你不仅可以实现基本的HTTP通信,还能进一步探索更复杂的网络应用场景。

    Web聊天室(基于Netty的WebSocket服务器)

    基于Netty编写的WebSocket服务器,前端为Web界面,可以实现一个简单的聊天室的功能,纯文字。(~.~),赚点积分,我要下载的三个文件一共要150的积分(|||.|||)。具体的讲解在我的博客里,全部的代码也在我的博客里...

    整合netty实时通讯

    - 使用 Netty 创建 WebSocket 服务器,首先需要定义一个 ChannelInitializer,配置处理 WebSocket 数据的 ChannelHandler。例如,WebSocketFrameDecoder 和 WebSocketFrameEncoder 用于解码和编码 WebSocket 帧。 ...

    netty 包含客户端和服务器端

    - 实践是最好的老师,尝试构建自己的网络应用,如聊天服务器、文件传输服务等,以巩固 Netty 的使用技巧。 这个压缩包提供的 Netty 示例是一个宝贵的教育资源,对于想要理解和使用 Netty 构建网络应用的开发者来说...

    netty与socket交互实例

    在实际项目中,Netty通常用于构建高性能的服务器,而Socket则可能作为客户端与之交互,尤其是在旧有的系统中,可能已经存在使用Socket编写的服务,这时Netty作为一个现代的网络库,可以帮助我们更高效地与这些服务...

    MyFtpV7:基于Netty的FTP服务器

    MyFtpV7 使用Netty Framework的基于Java的FTP服务器配置文件位置/ conf / server-config 文件“ user.db”是由sqlite DB浏览器创建的。 要启动服务器,只需执行...

    netty服务器son解析

    Netty 是一个高性能、异步事件驱动的网络应用程序框架,用于快速开发可维护的高性能协议服务器和客户端。在本文中,我们将深入探讨如何在 Netty 服务器中解析 JSON 数据,这是许多现代网络服务中常见的需求。 JSON...

    Netty中Marshalling编解码自定义栈应用

    Netty 是一个高性能、异步事件驱动的网络应用程序框架,用于快速开发可维护的高性能协议服务器和客户端。在 Netty 中,编解码器是处理数据传输的关键组件,它们负责将原始字节流转换为有意义的对象,反之亦然。本文...

    netty应用于物联网或者即时通讯项目

    本文将深入探讨如何使用 Netty 结合 MQTT 协议在 SpringBoot 框架下构建 IoT 服务器。 **1. MQTT 协议介绍** MQTT(Message Queuing Telemetry Transport)是一种轻量级的发布/订阅式消息协议,特别适合资源有限的...

    本科毕业设计,基于netty 的web服务器以及基本开发框架.zip

    【本科毕业设计——基于Netty的Web服务器及基础开发框架】 在本科毕业设计中,学生通常会选择一个实际问题或技术领域进行深入研究,并构建一个具有实际应用价值的项目。本项目选择的是基于Netty实现的Web服务器,...

Global site tag (gtag.js) - Google Analytics