Netty(二) 创建简单的服务器

本篇文章是延续上一篇Netty文章,因此推荐先去看上一篇文章Netty(一),当然对Netty有一定认识略过。开始利用Netty创建一个简单的服务器

先上代码,运行后,再讲解!

NettyServer

package com.tanoak.demo3.server;

import io.netty.bootstrap.ServerBootstrap;
import io.netty.channel.ChannelFuture;
import io.netty.channel.ChannelInitializer;
import io.netty.channel.ChannelOption;
import io.netty.channel.EventLoopGroup;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.SocketChannel;
import io.netty.channel.socket.nio.NioServerSocketChannel;
import io.netty.handler.codec.http.HttpServerCodec;

/** 
 * @author tanoak@qq.com
 * @date 2018/7/1 0:45    
 * @Desc
 */ 
public class HttpServer {

	public void start(final int port) throws Exception {
		EventLoopGroup boss = new NioEventLoopGroup();
		EventLoopGroup woker = new NioEventLoopGroup();
		ServerBootstrap serverBootstrap = new ServerBootstrap();

		try {
			serverBootstrap.channel(NioServerSocketChannel.class)
					.group(boss, woker)
					//测试链接的状态
					.childOption(ChannelOption.SO_KEEPALIVE, true)
					// 用来初始化服务端可连接队列,服务端处理客户端连接请求是顺序处理的;指定队列的大小
					.option(ChannelOption.SO_BACKLOG, 1024)
					.childHandler(new ChannelInitializer<SocketChannel>() {
						@Override
						protected void initChannel(SocketChannel ch) throws Exception {
							//重点  添加HttpServer
							ch.pipeline().addLast("http-decoder",new HttpServerCodec());
							//添加自定义的ChannelHandler
							ch.pipeline().addLast(new HttpServerHandler());
						}
					});

			ChannelFuture future = serverBootstrap.bind(port).sync();
			future.channel().closeFuture().sync();
		} finally {
			boss.shutdownGracefully();
			woker.shutdownGracefully();
		}
	}
	public static void main(String[] args) {
		try{
			System.out.println("服务器正在启动中");

			new HttpServer().start(8080);
		}catch (Exception e){
			System.out.println("服务器启动失败");
			e.printStackTrace();
		}
	}
}

这里有几个基本的概念。

Channel — Socket ;

基本的 I/O 操作(bind()、connect()、read()和 write())依赖于底层网络传输所提
供的原语。在基于 Java 的网络编程中,其基本的构造是 class Socket。Netty 的 Channel 接口所提供的 API,大大地降低了直接使用 Socket 类的复杂性

EventLoop — 控制流、多线程处理、并发;

EventLoop 定义了 Netty 的核心抽象,用于处理连接的生命周期中所发生的事件
  1. 一个 EventLoopGroup 包含一个或者多个 EventLoop; Netty 中所有的 I/O 操作都是异步的。因为一个操作可能不会立即返回,所以我们需要一种用于在之后的某个时间点确定其结果的方法。为此,Netty 提供了ChannelFuture 接口ChannelHandlerNetty 的主要组件是 ChannelHandler,它充当了所有处理入站和出站数据的应用程序逻辑的容器ChannelPipelineChannelPipeline 提供了 ChannelHandler 链的容器,并定义了用于在该链上传播入站 和出站事件流的 APIChannelOption 部分参数
  2. 一个 EventLoop 在它的生命周期内只和一个 Thread 绑定;
  3. 所有由 EventLoop 处理的 I/O 事件都将在它专有的 Thread 上被处理;
  4. 一个 Channel 在它的生命周期内只注册于一个 EventLoop;
  5. 一个 EventLoop 可能会被分配给一个或多个 Channel。ChannelFuture — 异步通知
  6. ChannelOption.SO_BACKLOG

   用来初始化服务端可连接队列,服务端处理客户端连接请求是顺序处理的,同一时间只能处理一个客户端连接,多个客户端时,服务端将不能处理的客户端连接请求放在队列中等待处理,backlog参数指定了队列的大小

  1. ChannelOption.SO_REUSEADDR

   对应于套接字选项中的SO_REUSEADDR,这个参数表示允许重复使用本地地址和端口,该参数允许共用该端口。

  1. 、ChannelOption.SO_KEEPALIVE

    对应于套接字选项中的SO_KEEPALIVE,该参数用于设置TCP连接,当设置该选项以后,连接会测试链接的状态,可能长时间没有数据交流的连接。当设置该选项以后,如果在两小时内没有数据的通信时,TCP会自动发送一个活动探测数据报文。

ChannelOption参数详解:传送门

有了这些基本的概念后我们就开始ChannelHandler的编写,这里是使用它的子类

ChannelHandler

package com.tanoak.demo3.server;

import io.netty.channel.ChannelFutureListener;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelInboundHandlerAdapter;
import io.netty.handler.codec.http.*;

import java.util.HashMap;
import java.util.Map;

/**
 * @author 656443534@qq.com
 * @date 2018/7/1 0:12    
 * @Desc
 */ 
public class HttpServerHandler extends ChannelInboundHandlerAdapter {

	private static String yes = "<h1> this is yes Page </h1>";
	private static String  helloPage = "<h1> this is Hello wolrd page </h1>";
	private String error = "<h1>404</h1>访问入径不存在";
	private static Map<String, String> mapUrl = new HashMap<>();

	static {
		mapUrl.put("hello",helloPage) ;
		mapUrl.put("yes",yes) ;
	}

	@Override
	public void channelActive(ChannelHandlerContext ctx) throws Exception {
		System.out.println("客户端连上了...");
	}

	@Override
	public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
		if (msg instanceof HttpRequest) {
			HttpRequest request = (HttpRequest) msg;
			boolean keepaLive = HttpUtil.isKeepAlive(request);
			System.out.println("访问的方式是:" + request.method()+"类型");
			System.out.println("访问的URI:" + request.uri());
			//获取访问的url
			String uri = request.uri().replace("/", "").trim();
			FullHttpResponse response = new DefaultFullHttpResponse(HttpVersion.HTTP_1_1, HttpResponseStatus.OK);
			if(mapUrl.get(uri)!=null){
				response.content().writeBytes(mapUrl.get(uri).getBytes());
			}else{
				response.content().writeBytes(error.getBytes());
			}
			//重定向处理
			if (response.status().equals(HttpResponseStatus.FOUND)) {
				response.headers().set(HttpHeaderNames.LOCATION, "https://www.baidu.com/");
			}

			response.headers().set(HttpHeaderNames.CONTENT_TYPE, "text/html;charset=UTF-8");
			response.headers().setInt(HttpHeaderNames.CONTENT_LENGTH, response.content().readableBytes());
			if (keepaLive) {
				response.headers().set(HttpHeaderNames.CONNECTION, HttpHeaderValues.KEEP_ALIVE);
				ctx.writeAndFlush(response);
			} else {
				ctx.writeAndFlush(response).addListener(ChannelFutureListener.CLOSE);
			}
		}
	}
	/**
	 *  有异常抛出时会调用。
	 * @param ctx
	 * @param cause
	 */
	@Override
	public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {
		/**
		 * 并且关闭该 Channel
		 */

		System.out.println("发生了异常");
		cause.printStackTrace();
		ctx.close() ;
		System.out.println("已关闭ChannelHandlerContext");
	}

}

可以看到主要的业务逻辑集中在channelRead(ChannelHandlerContext ctx, Object msg) ;这个方法主要还是使用Netty封装好的一些方法,指定Http的版本,状态码和accrpt

致此一个简单的请求响应的服务器就完成了,如理解有误,请指正,谢谢!!!

原创声明,本文系作者授权云+社区发表,未经许可,不得转载。

如有侵权,请联系 yunjia_community@tencent.com 删除。

发表于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏JetpropelledSnake

Python入门之logging模块

本章目录:     一、logging模块简介     二、logging模块的使用     三、通过JSON或者YMAL文件配置logging模块 ====...

32212
来自专栏.NET开发者社区

支持Ajax跨域访问ASP.NET Web Api 2(Cors)的简单示例教程演示

随着深入使用ASP.NET Web Api,我们可能会在项目中考虑将前端的业务分得更细。比如前端项目使用Angularjs的框架来做UI,而数据则由另一个Web...

1959
来自专栏依乐祝

ASP.NET Core WebApi使用Swagger生成api说明文档看这篇就够了

将 Swagger 生成器添加到 Startup.ConfigureServices 方法中的服务集合中:

871
来自专栏我的博客

ab压力测试

ab -n 1000 -c 50 http://test.xxxx.com/www/ Document Path: /www/ Document Length...

2925
来自专栏WindCoder

WebService入门初使用(一)创建WebService服务

本文所用WebService基于maven-ssm-cxf,此处暂时仅使用做记录,后期看心情适当整理相关知识点。

1871
来自专栏开发技术

spring-boot-2.0.3不一样系列之源码篇 - 阶段总结

    朋友喜欢去按摩,第一次推门进来的是一个学生美眉,感觉还不错;后来经常去,有时是护士,有时是空姐,有时候是教师。昨天晚上推门进去的是一个女警察,长得贼好看...

712
来自专栏猿天地

高性能NIO框架Netty入门篇

Netty介绍 Netty是由JBOSS提供的一个java开源框架。Netty提供异步的、事件驱动的网络应用程序框架和工具,用以快速开发高性能、高可靠性的网络服...

36110
来自专栏潇涧技术专栏

Art of Android Development Reading Notes 2

(1)任何一个操作系统都需要有相应的IPC机制,Linux上可以通过命名通道、共享内存、信号量等来进行进程间通信。 (2)Android系统不仅可以使用Bin...

722
来自专栏DeveWork

WordPress主题后台选项开发框架 Options Framework 介绍

最近一直在学习 WordPress 主题后台的开发,看了不少教程,但作为一只PHP菜鸟,颇为感到吃力。后来谷歌搜索找到了这个WordPress主题后台选项开发框...

2005
来自专栏IT笔记

SpringBoot开发案例之微信小程序文件上传

前言 最近在做一个口语测评的小程序服务端,小程序涉及到了音频文件的上传,按理说应该统一封装一个第三方上传接口服务提供给前段调用,但是开发没有那么多道理,暂且为了...

4036

扫码关注云+社区