Mina、Netty、Twisted一起学(八):HTTP服务器

HTTP协议应该是目前使用最多的应用层协议了,用浏览器打开一个网站就是使用HTTP协议进行数据传输。

HTTP协议也是基于TCP协议,所以也有服务器和客户端。HTTP客户端一般是浏览器,当然还有可能是其他东西。HTTP服务器,也就是Web服务器,目前已经有很多成熟的产品,例如Apache HTTP Server、Tomcat、Nginx、IIS等。

本文的内容不是讲解如何使用以上的HTTP服务器,而是要分别用MINA、Netty、Twisted实现一个简单的HTTP服务器。

首先,要简单了解一下HTTP协议。

HTTP协议是请求/响应式的协议,客户端需要发送一个请求,服务器才会返回响应内容。例如在浏览器上输入一个网址按下Enter,或者提交一个Form表单,浏览器就会发送一个请求到服务器,而打开的网页的内容,就是服务器返回的响应。

下面了解一下HTTP请求和响应包含的内容。

HTTP请求有很多种method,最常用的就是GET和POST,每种method的请求之间会有细微的区别。下面分别分析一下GET和POST请求。

GET请求:

下面是浏览器对http://localhost:8081/test?name=XXG&age=23的GET请求时发送给服务器的数据:

可以看出请求包含request line和header两部分。其中request line中包含method(例如GET、POST)、request uri和protocol version三部分,三个部分之间以空格分开。request line和每个header各占一行,以换行符CRLF(即\r\n)分割。

POST请求:

下面是浏览器对http://localhost:8081/test的POST请求时发送给服务器的数据,同样带上参数name=XXG&age=23:

可以看出,上面的请求包含三个部分:request line、header、message,比之前的GET请求多了一个message body,其中header和message body之间用一个空行分割。POST请求的参数不在URL中,而是在message body中,header中多了一项Content-Length用于表示message body的字节数,这样服务器才能知道请求是否发送结束。这也就是GET请求和POST请求的主要区别。

HTTP响应和HTTP请求非常相似,HTTP响应包含三个部分:status line、header、massage body。其中status line包含protocol version、状态码(status code)、reason phrase三部分。状态码用于描述HTTP响应的状态,例如200表示成功,404表示资源未找到,500表示服务器出错。

HTTP响应:

在上面的HTTP响应中,Header中的Content-Length同样用于表示message body的字节数。Content-Type表示message body的类型,通常浏览网页其类型是HTML,当然还会有其他类型,比如图片、视频等。

学习了HTTP协议后,那么就可以分别通过MINA、Netty、Twisted实现针对请求的解码器和针对响应的编码器来实现一个HTTP服务器。实际上HTTP协议的细节还有很多,自己实现起来没那么容易。不过,MINA、Netty、Twisted都已经提供了针对HTTP协议的编码解码器和一些实用的API。

下面分别用MINA、Netty、Twisted来实现一个HTTP服务器,用浏览器访问:

http://localhost:8080/?name=叉叉哥

就可以打开一个页面,将参数显示在页面上:

MINA:

MINA中有一个mina-http-2.0.7.jar包,专门用于处理HTTP协议。在下面的代码中,需要将这个jar包引入到项目中。

HTTP协议的请求解码器和响应编码器即HttpServerCodec,它会将HTTP客户端请求转成HttpRequest对象,将HttpResponse对象编码成HTTP响应发送给客户端。需要注意的是,HttpRequest和HttpResponse的实现类对象都没有包含message body部分,所以下面代码中body还通过原始的IoBuffer类型来构造。

public class HttpServer {

	public static void main(String[] args) throws IOException {
		IoAcceptor acceptor = new NioSocketAcceptor();
		acceptor.getFilterChain().addLast("codec", new HttpServerCodec());
		acceptor.setHandler(new HttpServerHandle());
		acceptor.bind(new InetSocketAddress(8080));
	}
}

class HttpServerHandle extends IoHandlerAdapter {

	@Override
	public void exceptionCaught(IoSession session, Throwable cause)
			throws Exception {
		cause.printStackTrace();
	}

	@Override
	public void messageReceived(IoSession session, Object message)
			throws Exception {

		if (message instanceof HttpRequest) {

			// 请求,解码器将请求转换成HttpRequest对象
			HttpRequest request = (HttpRequest) message;

			// 获取请求参数
			String name = request.getParameter("name");
			name = URLDecoder.decode(name, "UTF-8");

			// 响应HTML
			String responseHtml = "<html><body>Hello, " + name + "</body></html>";
			byte[] responseBytes = responseHtml.getBytes("UTF-8");
			int contentLength = responseBytes.length;

			// 构造HttpResponse对象,HttpResponse只包含响应的status line和header部分
			Map<String, String> headers = new HashMap<String, String>();
			headers.put("Content-Type", "text/html; charset=utf-8");
			headers.put("Content-Length", Integer.toString(contentLength));
			HttpResponse response = new DefaultHttpResponse(HttpVersion.HTTP_1_1, HttpStatus.SUCCESS_OK, headers);

			// 响应BODY
			IoBuffer responseIoBuffer = IoBuffer.allocate(contentLength);
			responseIoBuffer.put(responseBytes);
	        responseIoBuffer.flip();

	        session.write(response); // 响应的status line和header部分
	        session.write(responseIoBuffer); // 响应body部分
		}
	}
}

Netty:

Netty和MINA非常类似。唯一有区别的地方就是FullHttpResponse可以包含响应的message body。

public class HttpServer {

	public static void main(String[] args) throws InterruptedException {
		EventLoopGroup bossGroup = new NioEventLoopGroup();
		EventLoopGroup workerGroup = new NioEventLoopGroup();
		try {
			ServerBootstrap b = new ServerBootstrap();
			b.group(bossGroup, workerGroup)
					.channel(NioServerSocketChannel.class)
					.childHandler(new ChannelInitializer<SocketChannel>() {
						@Override
						public void initChannel(SocketChannel ch) throws Exception {
							ChannelPipeline pipeline = ch.pipeline();
							pipeline.addLast(new HttpServerCodec());
							pipeline.addLast(new HttpServerHandler());
						}
					});
			ChannelFuture f = b.bind(8080).sync();
			f.channel().closeFuture().sync();
		} finally {
			workerGroup.shutdownGracefully();
			bossGroup.shutdownGracefully();
		}
	}
}

class HttpServerHandler extends ChannelInboundHandlerAdapter {

	@Override
	public void channelRead(ChannelHandlerContext ctx, Object msg) throws UnsupportedEncodingException {

		if (msg instanceof HttpRequest) {

			// 请求,解码器将请求转换成HttpRequest对象
			HttpRequest request = (HttpRequest) msg;

			// 获取请求参数
			QueryStringDecoder queryStringDecoder = new QueryStringDecoder(request.getUri());
			String name = queryStringDecoder.parameters().get("name").get(0);

			// 响应HTML
			String responseHtml = "<html><body>Hello, " + name + "</body></html>";
			byte[] responseBytes = responseHtml.getBytes("UTF-8");
			int contentLength = responseBytes.length;

			// 构造FullHttpResponse对象,FullHttpResponse包含message body
			FullHttpResponse response = new DefaultFullHttpResponse(HttpVersion.HTTP_1_1, HttpResponseStatus.OK, Unpooled.wrappedBuffer(responseBytes));
			response.headers().set("Content-Type", "text/html; charset=utf-8");
			response.headers().set("Content-Length", Integer.toString(contentLength));

			ctx.writeAndFlush(response);
		}
	}

	@Override
	public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {
		cause.printStackTrace();
		ctx.close();
	}
}

Twisted:

Twisted的HTTP相比MINA、Netty来说功能最完善。Twisted不但包含HTTP协议的编码器和解码器以及相关API,还提供了一整套Web应用解决方案。想完整学习的话可以参考官方文档。

# -*- coding:utf-8 –*-

from twisted.web import server, resource
from twisted.internet import reactor

class MainResource(resource.Resource):

    isLeaf = True

    # 用于处理GET类型请求
    def render_GET(self, request):

        # name参数
        name = request.args[‘name‘][0]

        # 设置响应编码
        request.responseHeaders.addRawHeader("Content-Type", "text/html; charset=utf-8")

        # 响应的内容直接返回
        return "<html><body>Hello, " + name + "</body></html>"

site = server.Site(MainResource())
reactor.listenTCP(8080, site)
reactor.run()

作者:叉叉哥   转载请注明出处:http://blog.csdn.net/xiao__gui/article/details/39500913

时间: 2024-11-04 03:34:18

Mina、Netty、Twisted一起学(八):HTTP服务器的相关文章

Mina、Netty、Twisted一起学:实现简单的TCP服务器

MINA.Netty.Twisted为什么放在一起学习?首先,不妨先看一下他们官方网站对其的介绍: MINA: Apache MINA is a network application framework which helps users develop high performance and high scalability network applications easily. It provides an abstract event-driven asynchronous API

Mina、Netty、Twisted一起学(五):整合protobuf

protobuf是谷歌的Protocol Buffers的简称,用于结构化数据和字节码之间互相转换(序列化.反序列化),一般应用于网络传输,可支持多种编程语言. protobuf怎样使用这里不再介绍,本文主要介绍在MINA.Netty.Twisted中怎样使用protobuf,不了解protobuf的同学能够去參考我的还有一篇博文. 在前面的一篇博文中.有介绍到一种用一个固定为4字节的前缀Header来指定Body的字节数的一种消息切割方式.在这里相同要使用到. 仅仅是当中Body的内容不再是字

Mina、Netty、Twisted一起学(十):线程模型

要想开发一个高性能的TCPserver,熟悉所使用框架的线程模型非常重要.MINA.Netty.Twisted本身都是高性能的网络框架,假设再搭配上高效率的代码.才干实现一个高大上的server. 可是假设不了解它们的线程模型.就非常难写出高性能的代码.框架本身效率再高.程序写的太差,那么server总体的性能也不会太高.就像一个电脑,CPU再好.内存小硬盘慢散热差,总体的性能也不会太高. 玩过Android开发的同学会知道,在Android应用中有一个非常重要线程:UI线程(即主线程). UI

Mina、Netty、Twisted一起学(七):公布/订阅(Publish/Subscribe)

消息传递有非常多种方式.请求/响应(Request/Reply)是最经常使用的.在前面的博文的样例中.非常多都是採用请求/响应的方式.当server接收到消息后,会马上write回写一条消息到client. HTTP协议也是基于请求/响应的方式. 可是请求/响应并不能满足全部的消息传递的需求,有些需求可能须要服务端主动推送消息到client,而不是被动的等待请求后再给出响应. 公布/订阅(Publish/Subscribe)是一种server主动发送消息到client的消息传递方式.订阅者Sub

谈谈如何使用Netty开发实现高性能的RPC服务器

RPC(Remote Procedure Call Protocol)远程过程调用协议,它是一种通过网络,从远程计算机程序上请求服务,而不必了解底层网络技术的协议.说的再直白一点,就是客户端在不必知道调用细节的前提之下,调用远程计算机上运行的某个对象,使用起来就像调用本地的对象一样.目前典型的RPC实现框架有:Thrift(facebook开源).Dubbo(alibaba开源)等等.RPC框架针对网络协议.网络I/O模型的封装是透明的,对于调用的客户端而言,它就认为自己在调用本地的一个对象.至

Netty开发实现高性能的RPC服务器

Netty开发实现高性能的RPC服务器 RPC(Remote Procedure Call Protocol)远程过程调用协议,它是一种通过网络,从远程计算机程序上请求服务,而不必了解底层网络技术的协议.说的再直白一点,就是客户端在不必知道调用细节的前提之下,调用远程计算机上运行的某个对象,使用起来就像调用本地的对象一样.目前典型的RPC实现框架有:Thrift(facebook开源).Dubbo(alibaba开源)等等.RPC框架针对网络协议.网络I/O模型的封装是透明的,对于调用的客户端而

Netty简单应用与线上服务器部署_netty视频

Netty简单应用与线上服务器部署 课程学习地址:http://www.xuetuwuyou.com/course/198 课程出自学途无忧网:http://www.xuetuwuyou.com 一.开发环境 4.1.11.Final   jdk1.8 maven 3.2 Spring 4.3.9 二.适合人群 ①想深入学习java ClassLoader ②想在线上linux服务器上运行netty或Springboot服务 三.课程目标 ①掌控ClassLoader ②学会编写shell脚本

netty 3.9.2 UDP协议服务器和客户端DEMO

说明:基于netty 3.9.2的udp协议实现的(如果你使用的版本是4.X或5.X,请参考其他方法):程序的逻辑结构是,客户端发送给服务端一串数据,服务器端返回给客户端“A”.在进行游戏开发时需要对udp的丢包进行处理,可以利用服务器端的返回值进行相关处理,以确定是否重发,这方面具体没有实现. 文章结构: 一.服务器端 1.UDPServer 2.UdpChannelPipelineFactory 3.UDPServerHandler 二.客户端 1.UDPClient 2.UDPClient

Netty入门(二)时间服务器及客户端

在这个例子中,我在服务器和客户端连接被创立时发送一个消息,然后在客户端解析收到的消息并输出.并且,在这个项目中我使用 POJO 代替 ByteBuf 来作为传输对象. 一.服务器实现 1.  首先我们自定义传输数据对象 1 package com.coder.client; 2 3 import java.util.Date; 4 5 /** 6 * 自定义时间数据类 7 * @author Coder 8 * 9 */ 10 public class Time { 11 private fin