我尝试通过简单地实现以下示例来学习Netty4.x。我有一个服务器和一个客户端。在某个时间点,客户想知道当前的日期时间,他会问服务器“现在几点了?”。服务器意识到问题后,他将以当前日期时间答复。
我的实现如下
TimeClientInboundHandler.java
public class TimeClientInboundHandler extends ChannelInboundHandlerAdapter {
@Override
public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
ByteBuf byteBuf = (ByteBuf) msg;
try {
long currentTimeMillis = (byteBuf.readUnsignedInt() - 2208988800L) * 1000L;
System.out.println(new Date(currentTimeMillis));
ctx.close();
} finally {
byteBuf.release();
}
}
@Override
public void channelActive(ChannelHandlerContext ctx) throws Exception {
ctx.write("What time is it?");
ctx.flush();
}
@Override
public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
cause.printStackTrace();
ctx.close();
}
}
TimeServerInboundHandler.java
public class TimeServerInboundHandler extends ChannelInboundHandlerAdapter {
@Override
public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
ByteBuf byteBuf = (ByteBuf) msg;
try {
byteBuf.readCharSequence(1024, StandardCharsets.UTF_8);
System.out.println(byteBuf.toString());
} finally {
((ByteBuf) msg).release();
}
}
@Override
public void channelActive(ChannelHandlerContext ctx) throws Exception {
final ByteBuf byteBuf = ctx.alloc().buffer(4);
byteBuf.writeInt((int) (System.currentTimeMillis() / 1000L + 2208988800L));
final ChannelFuture f = ctx.writeAndFlush(byteBuf);
f.addListener(new ChannelFutureListener() {
@Override
public void operationComplete(ChannelFuture future) throws Exception {
assert f == future;
ctx.close();
}
});
}
@Override
public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
cause.printStackTrace();
ctx.close();
}
}
但是,我没有得到预期的结果。具体来说,在服务器端,问题“现在几点了?” 尚未在控制台上打印出来。
我实施了什么错误?
HTTP定义的事务处理由以下四步组成:
1.建立连接。
2.客户端发送HTTP请求头。
3.服务器端响应生成结果回发。
4.服务器端关闭连接,客户端解析回发响应头,恢复页面。
1.建立连接:以下用我的另一篇文章的地址做为例子
Servlet容器(Tomacat)介绍及配置
客户端,也就是我请求一个地址时,即打开了到 Web 服务器的HTTP端口的一个套接字。因为在网络中间作为传递数据的实体介质就是网线,数据实质上是通过IO流进行输出和输入,这就不难理解我们为什么在写一个Servlet的时候要引用 import java.io.*; 的原因,包括我们在向客户端回发结果的时候要用到 PrintWriter 对象的println()方法。
比如我在这里请求CSDN社区的一个地址http://blog.csdn.net,
实际上首先要请求这个地址,以及一个端口80(8080)http://blog.csdn.net:80 80可以不写,是因为浏览器网页服务默认的端口号是 80.
在Java底层代码中是这样实现的,只不过它们已经帮我们做了。
Socket socket=new Socket("blog.csdn.net",8080);
InputStream in=socket.getInputStream();
OutputStream out=socket.getOutputStream();
2.客户端发送HTTP请求头
一旦建立了TCP连接,Web浏览器就会向Web服务器发送请求命令,是一个ASCII文本请求行,后跟0个或多个HTTP头标,一个空行和实现请求的任意数据。四个部分:请求行,请求头标,空行和请求数据。
1)请求行由三个标记组成:请求方法 请求URL HTTP版本,中间用空格分开
例如:GET lvpin/archive/2007/06/09/1645767.aspx HTTP/1.1
HTTP规范定义了8种可能的请求方法:(最常见的就是 GET 和 POST 两种方法)
GET 检索URI中标识资源的一个简单请求
HEAD 与GET方法相同,服务器只返回状态行和头标,并不返回请求文档
POST 服务器接受被写入客户端输出流中的数据的请求
PUT 服务器保存请求数据作为指定URI新内容的请求
DELETE 服务器删除URI中命名的资源的请求
OPTIONS 关于服务器支持的请求方法信息的请求
TRACE Web服务器反馈Http请求和其头标的请求
CONNECT 已文档化但当前未实现的一个方法,预留做隧道处理
2)请求头标:由key :value 键值组成,每行一对。请求头标通知服务器有关客户端的功能和标识。
HOST 请求的哪一个服务器端地址,主地址 ,比如 我现在所在的CSDN blog.csdn.net/
User-Agent 用户即客户端可以使用的浏览器 ,如 : Mozilla/4.0
Accept 即客户端可以接受的MIME 类型列表,如image/gif text/html, application/msword
Content-Length 只适用于POST请求,以字节给出POST数据的尺寸
3)空行 发送回车符和退行,通知服务器以下不再有头标。
4)请求数据:使用POST传送数据,最常使用的是Content-Type和Content-Length头标。
总结以上 我们可以这样写出一个标准的 HTTP请求
POST /lvpin/archive/2007/06/09/1645767.aspx HTTP1.1
HOST: blog.csdn.net/
User-Agent :Mozilla/4.0
Accpt: image/gif,text/html,application/pdf,image/png...
key=value&key=value&key=value.....................................(POST()请求的数据)
那么,这上面的一个例子说明的就是
我要去访问的服务器端的地址是blog.csdn.net/ 它下面的资源 /lvpin/archive/2007/06/09/1645767.aspx连起来就是 http://blog.csdn.net/lvpin/archive/2007/06/09/1645767.aspx
这个页面用的是 HTTP1.1 规范 我的浏览器版本是Mozilla/4.0
可以支持的MIME格式为 image/gif,text/html,application/pdf,image/png...等等
这个MIME格式我们response.setContentType("text/html;charset=gb2312");或者在一个 <%@ page contentType="text/html;charset=gb2312"%> 或者<meta .....contentType="text/html;charset=gb2312"..>总能见到
那么在这里如何理解 GET 和 POST 最直观的区别,最明显的就是 GET方法将数据的请求跟在了所请求的URL后面,也就是在请求行里面我们是这么样来做的:
GET lvpin/archive/2007/06/09/1645767.aspx?
key=value&key=value&key=value......HTTP1.1
也实际上就是 用 GET 如此传递数据 :
http://blog.csdn.net/lvpin/archive/2007/06/09/1645767.aspx?name=simon&password=simonlv........
3.服务器端接受请求,处理数据后生成响应返回数据到客户端 (部分Servlet 内容穿插)
Web 服务器 解析请求,定位指定的资源http://blog.csdn.net/lvpin/archive/2007/06/09/1645767.aspx
1)根据在 请求时的 GET/POST 来按照响应的 doGet() /doPost()方法来处理(有可能是一些业务逻辑,也有可能是一些验证等等,也有可能是一些数据查询,提交等等)其有效的数据就来源于name=simon&password=simonlv,还有其它的一些封装在 request 对象中的数据资源。
2)处理请求之后,由 response 对象得到 PriterWriter 输出流对象out ,通过 out.println () 将数据以 在客户端提交过的采用的Accpt: 中形式的一种 如 按照 response.setcontentType("text/html;charset=gb2312' )的格式输出流。
它的响应信息与请求信息非常类似,其区别就在于 我们在请求阶段的请求行被状态行给替换了,一个响应由四个部分组成:状态行、响应头标、空行、响应数据
1.状态行:状态行由三个标记组成:HTTP版本、响应代码和响应描述。
HTTP1.1 100 continue ------继续追加后继内容
HTTP1.1 200 OK -----一切正常
HTTP1.1 301 Moved Permanently ---请求的文档在其它地方,会自动连接
HTTP1.1 403 Forbidden -------绝对拒绝你访问这个资源,不管授权没有
HTTP1.1 400 Bad Request -----客户端请求中的不良语法
HTTP1.1 404 Not Found ---最常见,绝对是大名鼎鼎的找不到
HTTP响应码:
1xx:提示性信息,告诉客户端应该对某些其它的动作做出响应
2xx:这些就代表了请求成功
3xx:重定向,为了完成请求,必须进一步执行的动作
4xx:客户端错误
500-599:服务器端的错误
2.响应头标:像请求头标一样,它们指出服务器的功能,标识出响应数据的细节。
Date: Sat,31 Dec 2005 23:59:59 GMT --响应生成的日期和时间
ContentType: text/html;charset=gb2312'
Content-Length: 122 ---响应中的字节数,只在浏览器使用永久(Keep-alive)HTTP连接时需要。
3.空行:最后一个响应头标之后是一个空行,发送回车符和退行,表明服务器以下不再有头标。
4.响应数据:HTML文档和图像等,也就是HTML本身。out.println("").......写出的。。。
<html>
<head>
<title>Welcom to simon lv 's home</title>
</head>
<body>
<!-- 这里是具体的内容,看到了这里
相信大家对 HTTP 工作原理和服务器交互过程已经很清楚了吧
-->
</body>
</html>
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。