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服务器项目"是一个综合性的Web服务开发实例,结合了三个核心的开源技术框架:Spring、Mybatis和Netty3.6。这个项目旨在创建一个高性能、可扩展的HTTP服务器,能够处理GET和...
标题中的"C# Netty 客户端,服务器端包含双向接收"揭示了这是一个关于使用C#语言实现基于Netty框架的客户端和服务器端通信的项目。Netty是Java平台上的一个高性能、异步事件驱动的网络应用程序框架,用于快速开发可...
在这个项目中,我们将深入理解如何利用 Netty 4 来编写服务器和客户端,实现自定义的消息编解码,并进行通信。 首先,我们要创建一个自定义的消息类。这个消息类通常会包含必要的字段,比如消息头、消息体等,以...
在基于Netty编写的socket服务端中,首先需要定义一个`ChannelHandler`,这个处理器负责处理接收到的网络事件,如连接建立、数据读取、连接关闭等。`ChannelHandlerContext`则是`ChannelHandler`和`ChannelPipeline`...
Netty 是一个高性能、异步事件驱动的网络应用程序框架,用于快速开发可维护的高性能协议服务器和客户端。在游戏服务器领域,Netty 的优势在于它的灵活性、可扩展性和高效的性能,使得它成为构建游戏服务器核心层的...
Netty的HTTP模块允许开发者轻松地构建HTTP服务器和客户端,支持GET、POST等各种请求方法,并且能够处理Cookie和HTTP头部。 接下来是Socket,它是网络编程的基础,Netty的Socket API提供了TCP和UDP的支持。通过使用...
3. **编写服务器端代码**: - **Bootstrap**: 创建一个`ServerBootstrap`实例,配置线程池、通道工厂、绑定地址和端口。 - **ChannelHandler**: 实现`ChannelInboundHandlerAdapter`,处理接收到的客户端连接和...
这是一个关于使用Java Netty构建TCP服务器以及Flash ActionScript3开发客户端的游戏C/S程序源代码的项目。这个项目展示了如何在服务器端使用Java Netty框架来处理网络通信,以及在客户端利用ActionScript3来实现游戏...
在本文中,我们将深入探讨如何使用 Netty 实现 HTTP 协议的开发,结合提供的“NettyStudyServer”文件,我们来详细了解一下相关知识点。 1. **HTTP 协议基础** - HTTP(超文本传输协议)是互联网上应用最为广泛的...
3. 创建RestEasy应用上下文:使用ResteasyBootstrap类初始化RestEasy,并将RestEasy的ContextProvider注册到Netty服务器中。 4. 注册REST资源:通过使用@Provider和@Path注解,定义RESTful服务的接口和实现。 5. ...
总的来说,这个"Netty4.0 http案例"涵盖了如何使用Netty构建高效、可扩展的HTTP服务器和客户端,以及如何处理JSON数据。通过理解这些知识点,你不仅可以实现基本的HTTP通信,还能进一步探索更复杂的网络应用场景。
基于Netty编写的WebSocket服务器,前端为Web界面,可以实现一个简单的聊天室的功能,纯文字。(~.~),赚点积分,我要下载的三个文件一共要150的积分(|||.|||)。具体的讲解在我的博客里,全部的代码也在我的博客里...
- 使用 Netty 创建 WebSocket 服务器,首先需要定义一个 ChannelInitializer,配置处理 WebSocket 数据的 ChannelHandler。例如,WebSocketFrameDecoder 和 WebSocketFrameEncoder 用于解码和编码 WebSocket 帧。 ...
- 实践是最好的老师,尝试构建自己的网络应用,如聊天服务器、文件传输服务等,以巩固 Netty 的使用技巧。 这个压缩包提供的 Netty 示例是一个宝贵的教育资源,对于想要理解和使用 Netty 构建网络应用的开发者来说...
在实际项目中,Netty通常用于构建高性能的服务器,而Socket则可能作为客户端与之交互,尤其是在旧有的系统中,可能已经存在使用Socket编写的服务,这时Netty作为一个现代的网络库,可以帮助我们更高效地与这些服务...
MyFtpV7 使用Netty Framework的基于Java的FTP服务器配置文件位置/ conf / server-config 文件“ user.db”是由sqlite DB浏览器创建的。 要启动服务器,只需执行...
Netty 是一个高性能、异步事件驱动的网络应用程序框架,用于快速开发可维护的高性能协议服务器和客户端。在本文中,我们将深入探讨如何在 Netty 服务器中解析 JSON 数据,这是许多现代网络服务中常见的需求。 JSON...
Netty 是一个高性能、异步事件驱动的网络应用程序框架,用于快速开发可维护的高性能协议服务器和客户端。在 Netty 中,编解码器是处理数据传输的关键组件,它们负责将原始字节流转换为有意义的对象,反之亦然。本文...
本文将深入探讨如何使用 Netty 结合 MQTT 协议在 SpringBoot 框架下构建 IoT 服务器。 **1. MQTT 协议介绍** MQTT(Message Queuing Telemetry Transport)是一种轻量级的发布/订阅式消息协议,特别适合资源有限的...
【本科毕业设计——基于Netty的Web服务器及基础开发框架】 在本科毕业设计中,学生通常会选择一个实际问题或技术领域进行深入研究,并构建一个具有实际应用价值的项目。本项目选择的是基于Netty实现的Web服务器,...