split to core module plus protocol modules

[WANGXINJ]

Great job!
Is it possible to split the code into core module plus protocol modules (servlet, mqtt...) and
auto loading the protocol modules when application startup depending on protocol modules dependency involved.

And is there embeded support for http file server besides servlet.

[wangzihaogithub]

可能是文档没写清楚，我刚才补充了一下文档， 你看下这个链接刚补充的文档。

还有/src/test目录下也有代码示例， 有上传下载文件， mqtt等的使用方法。

目前除了http，nrpc。 其他mqtt或其他协议都是默认不开启的。

https://github.com/wangzihaogithub/spring-boot-protocol/wiki#%E7%A4%BA%E4%BE%8B1-springboot%E7%89%88%E4%BD%BF%E7%94%A8http%E6%88%96websocket%E6%A8%A1%E5%9D%97%E4%BD%BF%E7%94%A8springboot%E5%90%8E%E9%BB%98%E8%AE%A4%E6%98%AF%E5%BC%80%E5%90%AFhttp%E7%9A%84

[WANGXINJ]

你好， 子豪： 我想了解的是否有 HTML file request 支持，而不仅仅是 servlet. 例如： http://server_address/.../xxx.html 现在有内置支持功能吗？ 还是需要添加一个类似 FileRequestDispatcher 的功能，并Override ServletContext. getRequestDispatcher。 还有返回的生成数据，是在哪个地方被 ctx.write 的。 我可以返回一个数据list，让 ctx 可以逐个 write吗？ 另外返回的数据可以是个 Consumer<ctx> 吗？ 从 Windows 版邮件<https://go.microsoft.com/fwlink/?LinkId=550986>发送 发件人: ***@***.***> 发送时间: 2022年4月10日 11:32 收件人: ***@***.***> 抄送: Xingjian ***@***.***>; ***@***.***> 主题: Re: [wangzihaogithub/spring-boot-protocol] split to core module plus protocol modules (Issue #16) 可能是文档没写清楚，我刚才补充了一下文档， 你看下这个链接刚补充的文档。 还有/src/test目录下也有代码示例， 有上传下载文件， mqtt等的使用方法。 目前除了http，nrpc。 其他mqtt或其他协议都是默认不开启的。 https://github.com/wangzihaogithub/spring-boot-protocol/wiki#%E7%A4%BA%E4%BE%8B1-springboot%E7%89%88%E4%BD%BF%E7%94%A8http%E6%88%96websocket%E6%A8%A1%E5%9D%97%E4%BD%BF%E7%94%A8springboot%E5%90%8E%E9%BB%98%E8%AE%A4%E6%98%AF%E5%BC%80%E5%90%AFhttp%E7%9A%84 ― Reply to this email directly, view it on GitHub<#16 (comment)>, or unsubscribe<https://github.com/notifications/unsubscribe-auth/AAH3LDHCSRQQFHWBL7OY6A3VEJDWPANCNFSM5TACC4XQ>. You are receiving this because you authored the thread.Message ID: ***@***.***>

[wangzihaogithub]

下面这个问题, 这样用.

我可以返回一个数据list，让 ctx 可以逐个 write吗？
另外返回的数据可以是个 Consumer 吗？

,

                  try(NettyOutputStream outputStream = (NettyOutputStream)response.getOutputStream()){
          
                      outputStream.write(mappedByteBuffer);

                      outputStream.write(mappedByteBuffer);

                      outputStream.write(mappedByteBuffer);

                  }
          
          
          
          `package com.github.netty.protocol.servlet;
          
          /**
           * use netty zero copy
           * if you need flush {@link ServletOutputStream#flush()}
           * @author wangzihaogithub
           * 2020-06-07 14:13:36
           */
          public interface NettyOutputStream extends Flushable, Closeable {
          
              /**
               * batch send packet. Immediately other side peer receive write finish data
               * Try not to use this method, it is possible for maximum performance.
               * Unless you need to need to get to the end part of the data received immediately
               * @throws IOException if close
               */
              @Override
              void flush() throws IOException;
          
              /**
               * close http.
               * if keepAlive. It does not turn off tcpConnection. Otherwise, turn off tcpConnection
               */
              @Override
              void close();
          
              /**
               * direct write to tcp outputStream.
               * @param httpBody jdk ByteBuffer httpBody
               * @see MappedByteBuffer
               * @see ByteBuffer
               * @return ChannelProgressivePromise
               * @throws IOException if close
               */
              ChannelProgressivePromise write(ByteBuffer httpBody) throws IOException;
          
              /**
               * direct write to tcp outputStream
               * @param httpBody netty ByteBuf httpBody
               * @see ChunkedFile
               * @see ChunkedNioStream
               * @see ChunkedNioFile
               * @see ChunkedStream
               * @return ChannelProgressivePromise
               * @throws IOException if close
               */
              ChannelProgressivePromise write(ByteBuf httpBody) throws IOException;
          
              /**
               * use netty batch write
               * @param httpBody ChunkedInput httpBody
               * @see ChunkedFile
               * @see ChunkedNioStream
               * @see ChunkedNioFile
               * @see ChunkedStream
               * @return ChannelProgressivePromise
               * @throws IOException if close
               */
              ChannelProgressivePromise write(ChunkedInput httpBody) throws IOException;
          
              /**
               * use netty zero copy
               * @param httpBody FileChannel httpBody
               * @param count count
               * @param position position
               * @return ChannelProgressivePromise {@link ChannelProgressivePromise#addListener(GenericFutureListener)} }
               * @see GenericProgressiveFutureListener
               * @throws IOException if close
               */
              ChannelProgressivePromise write(FileChannel httpBody, long position, long count) throws IOException;
          
              /**
               * use netty zero copy
               * @param httpBody File httpBody
               * @param count count
               * @param position position
               * @return ChannelProgressivePromise {@link ChannelProgressivePromise#addListener(GenericFutureListener)} }
               * @see GenericProgressiveFutureListener
               * @throws IOException if close
               */
              ChannelProgressivePromise write(File httpBody, long position, long count) throws IOException;
          
              /**
               * use netty zero copy
               * @param httpBody File httpBody
               * @return ChannelProgressivePromise {@link ChannelProgressivePromise#addListener(GenericFutureListener)} }
               * @see GenericProgressiveFutureListener
               * @throws IOException if close
               */
              ChannelProgressivePromise write(File httpBody) throws IOException;
          
          }

`

[wangzihaogithub]

这个问题, springboot本身就支持. spring怎么用,这里就怎么用.
spring的用法是, 在resources包下, 建立静态目录, 访问目录下的文件.index.html即可, 不需要多余的配置

HTML file request 支持，而不仅仅是 servlet.

[wangzihaogithub]

下面这个问题.
这个是spring处理完后, 会帮你序列化, 然后response.getOutputStream().write(byte[]), 因为spring默认实现了一个servlet.

还有返回的生成数据，是在哪个地方被 ctx.write 的。

[wangzihaogithub]

这个静态文件的内置功能, 目前没有, 但是spring有, 如果不想用spring, 可以手工写一个或者网上copy一个 FileServlet, 即可

比如 处理所有 /static/ 目录下的静态文件, 可以加一个这样的servlet

我想了解的是否有 HTML file request 支持，而不仅仅是 servlet.
例如： http://server_address/.../xxx.html
现在有内置支持功能吗？

[WANGXINJ]

Hi, Zihao, 我尝试采用 apache/Catalina 的 DefaultServlet.， 发现当前实现中 ServletHttpServletRequest 的 getPathInfo 没有实现。 ServletHttpServletRequest与 catalina 的 Request 都是 HttpServletRequest接口的实现。 ServletHttpServletRequest 在对 Netty 特性支持上有什么特别之处吗？ Xingjian 从 Windows 版邮件<https://go.microsoft.com/fwlink/?LinkId=550986>发送 发件人: ***@***.***> 发送时间: 2022年4月11日 12:00 收件人: ***@***.***> 抄送: Xingjian ***@***.***>; ***@***.***> 主题: Re: [wangzihaogithub/spring-boot-protocol] split to core module plus protocol modules (Issue #16) 这个静态文件的内置功能, 目前没有, 但是spring有, 如果不想用spring, 可以手工写一个或者网上copy一个 FileServlet, 即可 我想了解的是否有 HTML file request 支持，而不仅仅是 servlet. 例如： http://server_address/.../xxx.html 现在有内置支持功能吗？ ― Reply to this email directly, view it on GitHub<#16 (comment)>, or unsubscribe<https://github.com/notifications/unsubscribe-auth/AAH3LDC3H2HNZAD2VUPOFDTVEOPWTANCNFSM5TACC4XQ>. You are receiving this because you authored the thread.Message ID: ***@***.***>

[wangzihaogithub]

没有特别之处, 这个方法会影响到使用吗? 我可以补上

[wangzihaogithub]

我刚发布了2.2.4版本, 加了HttpServletRequest#getPathInfo方法实现. 应该可以满足你的要求.
现在除了request.login 系列的接口, 其他的都与tomcat保持一致了

发布2.2.4
1.增加HttpServletRequest#getPathInfo方法实现
2.修复springboot访问localhost时, 没有访问到index.html的问题
3.修复servlet异步时,客户端强制abort中止后,使用request对象会报空指针的bug.
4.修复forward,async,include时.获取requestURI路径不正确的bug
fix #16

[WANGXINJ]

Hi, Zihao, I try DefaultServlet @ tomcat-embed-core @ 9.0.62 First the request changed with more elements /index.html/;jsessionid=node01no75msitjo427u0tsup0ae0o0.node0/;jsessionid=node01no75msitjo427u0tsup0ae0o0.node0/;jsessionid=node01no75msitjo427u0tsup0ae0o0.node0/;jsessionid=node01no75msitjo427u0tsup0ae0o0.node0/;jsessionid=node01no75msitjo427u0tsup0ae0o0.node0/;jsessionid=node01no75msitjo427u0tsup0ae0o0.node0/;jsessionid=node01no75msitjo427u0tsup0ae0o0.node0/;jsessionid=node01no75msitjo427u0tsup0ae0o0.node0 And when request.getServletPath(); The return is “”, but not /index.html Which is called by DefaultServlet when getRelativePath Without right relativePath, DefaultServlet can not find the file resource. My init code like this: private static HttpServletProtocol newHttpProtocol() { ServletContext servletContext = new ServletContext(); servletContext.addServlet("testServlet", new TestServlet()).addMapping("/test"); servletContext.addServlet("fileServlet", new DefaultServlet()).addMapping("/"); return new HttpServletProtocol(servletContext); } Is there test case for this, and better to build a native DeaultServlet instead of Tomcat DefaltServelt. Thanks. 从 Windows 版邮件<https://go.microsoft.com/fwlink/?LinkId=550986>发送 发件人: ***@***.***> 发送时间: 2022年4月13日 20:10 收件人: ***@***.***> 抄送: Xingjian ***@***.***>; ***@***.***> 主题: Re: [wangzihaogithub/spring-boot-protocol] split to core module plus protocol modules (Issue #16) 我刚发布了2.2.4版本, 加了HttpServletRequest#getPathInfo方法实现. 应该可以满足你的要求. 现在除了request.login 系列的接口, 其他的都与tomcat保持一致了 发布2.2.4 1.增加HttpServletRequest#getPathInfo方法实现 2.修复springboot访问localhost时, 没有访问到index.html的问题 3.修复servlet异步时,客户端强制abort中止后,使用request对象会报空指针的bug. 4.修复forward,async,include时.获取requestURI路径不正确的bug fix #16<#16> ― Reply to this email directly, view it on GitHub<#16 (comment)>, or unsubscribe<https://github.com/notifications/unsubscribe-auth/AAH3LDGSOACDUNWBHYGSJ2TVE22UPANCNFSM5TACC4XQ>. You are receiving this because you authored the thread.Message ID: ***@***.***>

[wangzihaogithub]

我明白了你的意图, 改好后告诉你.

I understand what you're trying to do. I'll let you know when I fix it

[wangzihaogithub]

我刚发布了2.2.5版本, 应该过1~2天就自动同步到maven中央仓库了.

代码这样写就可以了.

`

            public static void main(String[] args) {
                StartupServer server = new StartupServer(80);
                server.addProtocol(newHttpProtocol());
                server.start();
            }

            private static HttpServletProtocol newHttpProtocol() {
                ServletContext servletContext = new ServletContext();
                servletContext.setDocBase("D://demo", "/webapp"); // 静态资源文件夹
                servletContext.addServlet("myHttpServlet", new com.github.netty.protocol.servlet.DefaultServlet())
                        .addMapping("/*");
                return new HttpServletProtocol(servletContext);
            }

`

发布2.2.5
1.实现默认的文件Servlet服务,com.github.netty.protocol.servlet.DefaultServlet

[WANGXINJ]

Hi, Zihao, Fantastic, the html page is show correctly with css/js; There was a implemented code for rpc/netty-message, how can I integrate the code into the protocols. Is there a demo for this? Thanks; 从 Windows 版邮件<https://go.microsoft.com/fwlink/?LinkId=550986>发送 发件人: ***@***.***> 发送时间: 2022年4月14日 14:10 收件人: ***@***.***> 抄送: Xingjian ***@***.***>; ***@***.***> 主题: Re: [wangzihaogithub/spring-boot-protocol] split to core module plus protocol modules (Issue #16) 我刚发布了2.2.5版本, 应该过1~2天就自动同步到maven中央仓库了. 代码这样写就可以了. public static void main(String[] args) { StartupServer server = new StartupServer(80); server.addProtocol(newHttpProtocol()); server.start(); } private static HttpServletProtocol newHttpProtocol() { ServletContext servletContext = new ServletContext(); servletContext.setDocBase("D://demo", "/webapp"); // 静态资源文件夹 servletContext.addServlet("myHttpServlet", new com.github.netty.protocol.servlet.DefaultServlet()) .addMapping("/*"); return new HttpServletProtocol(servletContext); } 发布2.2.5 1.实现默认的文件Servlet服务,com.github.netty.protocol.servlet.DefaultServlet ― Reply to this email directly, view it on GitHub<#16 (comment)>, or unsubscribe<https://github.com/notifications/unsubscribe-auth/AAH3LDC473TWJHPLNKW3TRLVE6ZFZANCNFSM5TACC4XQ>. You are receiving this because you authored the thread.Message ID: ***@***.***>