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

RESTful源码学习笔记之RPC和Restful深入理解

RPC 即远程过程调用(Remote Procedure Call Protocol,简称RPC),像调用本地服务(方法)一样调用服务器的服务(方法)。通常的实...

653
来自专栏Java编程技术

创建线程以及线程池时候要指定与业务相关的名字,以便于追溯问题

日常开发中当一个应用中需要创建多个线程或者线程池时候最好给每个线程或者线程池根据业务类型设置具体的名字,以便在出现问题时候方便进行定位,下面就通过实例来说明不设...

611
来自专栏Java架构沉思录

分布式ID常见解决方案

在分布式系统中,往往需要对大量的数据如订单、账户进行标识,以一个有意义的有序的序列号来作为全局唯一的ID。

1862
来自专栏木东居士的专栏

漫谈并发编程:Future模型(Java、Clojure、Scala多语言角度分析)

2213
来自专栏技术记录

如何减轻ajax定时触发对服务器造成的压力和带宽的压力?ajax-长轮训

AJAX长轮询的方法来解决频繁对后台的请求,进一步减小压力 在实现过程发现AJAX的多次请求会出现多线程并发的问题又使用线程同步来解决该问题 个人对ajax长轮...

1835
来自专栏IT 指南者专栏

Spring框架系列之AOP思想

微信公众号:compassblog 欢迎关注、转发,互相学习,共同进步! 有任何问题,请后台留言联系! 1、AOP概述 (1)、什么是 AOP AOP 为 As...

3157
来自专栏微服务生态

跟我学Kafka之NIO通信机制

很久没有做技术方面的分享了,今天闲来有空写一篇关于Kafka通信方面的文章与大家共同学习。

523
来自专栏linux驱动个人学习

Intel P4 CPU

1413
来自专栏老马说编程

(61) 内存映射文件及其应用 - 实现一个简单的消息队列 / 计算机程序的思维逻辑

本节介绍内存映射文件,内存映射文件不是Java引入的概念,而是操作系统提供的一种功能,大部分操作系统都支持。 我们先来介绍内存映射文件的基本概念,它是什么,能解...

2175
来自专栏java 成神之路

NIO 之 FileChannel

1153

扫码关注云+社区