摘要:操作指引该文件服务组件的使用需要分为两个部分,一个是服务端配置与启动,一个是客户端的配置与启动。在调用文件服务返回的路径的时候,需要用到服务端访问文件的地址,进而访问相应的文件内容。
本文所述文件服务组件在笔者此前一篇文章中已有阐述(基于netty的文件上传下载组件),不过本文将基于之前这个实现再次进行升级改造,利用基于注解的方式进行自动装配。1. 简介 1.1 Netty简介
Netty是一个异步事件驱动的网络应用程序框架,用于快速开发可维护的高性能协议服务器和客户端。关于其详细的介绍可以参考Netty官方网站。
Netty is a NIO client server framework which enables quick and easy development of network applications such as protocol servers and clients. It greatly simplifies and streamlines network programming such as TCP and UDP socket server.
Netty主要特点:
Unified API for various transport types - blocking and non-blocking socket(统一API)
Based on a flexible and extensible event model which allows clear separation of concerns(事件模型)
Highly customizable thread model - single thread, one or more thread pools such as SEDA(线程模型)
True connectionless datagram socket support (since 3.1)(无连接数据报文Socket支持)
1.2 组件功能介绍该组件基于netty3.6.3实现,具有如下功能:文件上传,文件替换,文件删除,如果是图片的话,还可以生成缩略图等功能。使用简单,只需要引入commons-doc-client-netty,即可以实现文件的以上操作。
本组件分为三个module,分别为:
commons-doc-server-netty:Netty实现文件服务组件的服务端
commons-doc-common:Netty文件服务组件公共组件
commons-doc-client-netty:Netty文件服务组件的客户端
2. 服务端 2.1 功能简介服务端组件实现以下功能:文件上传,文件替换,文件删除,如果是图片的话,还可以生成缩略图等功能。代码结构如下图所示,
所有的文件服务都是基于接口DocServerProcessor进行的,主要有以下几个实现类:
UploadDocServerHandler实现文件上传服务
ReplaceDocServerHandler实现文件替换服务
DeleteDocServerHandler实现文件删除服务
CreateThumbPictureServerHandler实现创建图片缩略图服务
2.2 实现步骤具体实现步骤以文件上传为例。
首先 org.fortune.doc.server.support.DocServerHandler类会持续监听客户端的请求,如果是文件处理动作,则会进入messageReceived方法进行相应的处理逻辑。该类定义了以下成员变量:
//http请求 private HttpRequest request; //是否需要断点续传作业 private boolean readingChunks; //接收到的文件内容 private final StringBuffer responseContent = new StringBuffer(); //解析收到的文件 private static final HttpDataFactory factory = new DefaultHttpDataFactory(DefaultHttpDataFactory.MINSIZE); //16384L //post请求的解码类,它负责把字节解码成Http请求。 private HttpPostRequestDecoder decoder; //请求参数 private RequestParam requestParams = new RequestParam();
该方法实现中,如果文件大小小于chunked的最小值,则直接进行文件上传操作。否则,需要进行分块处理。然后进行文件上传操作。
文件大小小于1k的操作:
if (request.isChunked()) { //说明还没有请求完成,继续 this.readingChunks = true; LOGGER.info("文件分块操作...."); } else { LOGGER.info("文件大小小于1KB,文件接收完成,直接进行相应的文件处理操作...."); //请求完成,则接收请求参数,进行初始化请求参数 RequestParamParser.parseParams(this.decoder, this.requestParams); //根据请求参数进行相应的文件操作 LOGGER.info("文件处理开始....requestParams参数解析:{}",requestParams); String result = DocServerHandlerFactory.process(this.requestParams); LOGGER.info("文件处理结束....FileServerHandlerFactory处理结果:{}",result); this.responseContent.append(result); //给客户端响应信息 writeResponse(e.getChannel()); e.getFuture().addListener(ChannelFutureListener.CLOSE); }
需要分块处理操作:
HttpChunk chunk = (HttpChunk) e.getMessage(); try { //chunk.getContent().capacity(); LOGGER.info("文件分块操作....文件大小:{} bytes",chunk.getContent().capacity()); this.decoder.offer(chunk); } catch (HttpPostRequestDecoder.ErrorDataDecoderException e1) { e1.printStackTrace(); this.responseContent.append(e1.getMessage()); writeResponse(e.getChannel()); Channels.close(e.getChannel()); return; } if (chunk.isLast()) { //文件末尾 this.readingChunks = false; LOGGER.info("到达文件内容的末尾,进行相应的文件处理操作....start"); RequestParamParser.parseParams(this.decoder, this.requestParams); LOGGER.info("文件处理开始....requestParams参数解析:{}",requestParams); String result = DocServerHandlerFactory.process(this.requestParams); LOGGER.info("文件处理结束....FileServerHandlerFactory处理结果:{}",result); this.responseContent.append(result); //给客户端响应信息 writeResponse(e.getChannel()); e.getFuture().addListener(ChannelFutureListener.CLOSE); LOGGER.info("到达文件内容的末尾,进行相应的文件处理操作....end"); }
以上操作主要有两个注意点:
请求参数的解析工作(根据HttpDataType进行相应参数的赋值操作)
根据解析的参数进行相应的文件处理操作(根据文件操作类型,选择相应的处理句柄进行文件处理)
3. 客户端 3.1 功能简介客户端组件主要提供对外访问服务端组件的接口,提供以下接口:文件上传,文件替换,文件删除,如果是图片的话,还可以生成缩略图等功能。代码结构如下:
org.fortune.doc.client.DocClient类是对外提供接口的工具类,具有以下主要方法:
uploadFile 文件上传,对应文件处理句柄类为:org.fortune.doc.client.handler.UploadDocClientHandler
deleteFile 删除服务端文件,对应文件处理句柄类为:org.fortune.doc.client.handler.DeleteDocClientHandler
replaceFile 替换服务端文件,对应文件处理句柄类为:org.fortune.doc.client.handler.ReplaceDocClientHandler
createThumbPicture 生成缩略图,对应文件处理句柄类为:org.fortune.doc.client.handler.CreateThumbPictureClientHandler
3.2 实现步骤实现步骤以上传文件为例,其他类似实现。直接上代码:
/** * 文件上传 * @param file 需要上传的文件 * @param fileName 文件名称 * @param thumbMark 是否需要生成缩略图 * @return * @author:landyChris */ public static String uploadFile(File file, String fileName, boolean thumbMark) { DocClientPipelineFactory clientPipelineFactory = new DocClientPipelineFactory(); //辅助类。用于帮助我们创建NETTY服务 ClientBootstrap bootstrap = createClientBootstrap(clientPipelineFactory); String strThumbMark = Constants.THUMB_MARK_NO; if (thumbMark) { strThumbMark = Constants.THUMB_MARK_YES; } //具体处理上传文件逻辑 uploadFile(bootstrap, DocClientContainer.getInstance().getHost(), DocClientContainer.getInstance().getPort(), file, fileName, strThumbMark, DocClientContainer.getInstance().getUserName(), DocClientContainer.getInstance().getPassword()); Result result = clientPipelineFactory.getResult(); if ((result != null) && (result.isSuccess())) { return result.getFilePath(); } return null; }
具有三个参数,前面几行代码都是很一些netty的初始化工作,具体看一个私有方法uploadFile,如下代码所示:
private static void uploadFile(ClientBootstrap bootstrap, String host, int port, File file, String fileName, String thumbMark, String userName, String pwd) { //1.构建uri对象 URI uri = getUri(host, port); //2.连接netty服务端 ChannelFuture future = bootstrap.connect(new InetSocketAddress(host, port)); //3.异步获取Channel对象 Channel channel = future.awaitUninterruptibly().getChannel(); if (!future.isSuccess()) { future.getCause().printStackTrace(); bootstrap.releaseExternalResources(); return; } //4.初始化文件上传句柄对象 AbstractDocClientHandler handler = new UploadDocClientHandler(host, uri, file, fileName, thumbMark, userName, pwd); //5.获取Request对象 HttpRequest request = handler.getRequest(); //6.获取Http数据处理工厂 HttpDataFactory factory = getHttpDataFactory(); //7.进行数据的包装处理,主要是进行上传文件所需要的参数的设置,此时调用的句柄是具体的UploadFileClientHandler对象 HttpPostRequestEncoder bodyRequestEncoder = handler .wrapRequestData(factory); //8.把request写到管道中,传输给服务端 channel.write(request); //9.做一些关闭资源的动作 if (bodyRequestEncoder.isChunked()) { channel.write(bodyRequestEncoder).awaitUninterruptibly(); } bodyRequestEncoder.cleanFiles(); channel.getCloseFuture().awaitUninterruptibly(); bootstrap.releaseExternalResources(); factory.cleanAllHttpDatas(); }
主要有以下实现步骤:
构建uri对象
连接netty服务端
异步获取Channel对象
初始化文件上传句柄对象
获取Request对象
获取Http数据处理工厂
进行数据的包装处理,主要是进行上传文件所需要的参数的设置,此时调用的句柄是具体的UploadFileClientHandler对象
把request写到管道中,传输给服务端
做一些关闭资源的动作
具体细节实现请参考github上的代码。如果各位读者喜欢的话,可以加个star哈。
该文件服务组件的使用需要分为两个部分,一个是服务端配置与启动,一个是客户端的配置与启动。
4.1 服务端配置与启动 4.1.1 配置服务端的配置采用yml文件的配置,更加的简洁明了,主要的注意点是文件存放位置的配置,在开发过程中,可以有两种方式配置:
Idea自启动方式:如果采用此种方式则需要把rootPath配置到工程路径下(target目录),如下所示:
# 在idea中执行的话,需要配置target目录下的打包文件 rootPath: C: 3_codeidea_workspacefortune-commonscommons-doc-server-netty argetcommons-doc-server-netty #上传文件的根目录,实际工作环境按照实际情况更改即可
打包后在tomcat独立启动方式
# 也可以多带带把打包后的war包拷贝到tomcat webapp目录下直接运行也可以 rootPath: C: 5_webserverapache-tomcat-8.5.42webappsdoc-server #上传文件的根目录,实际工作环境按照实际情况更改即可4.1.2 启动
本文采用的是idea自启动方式,则需要配置一下tomcat路径,以及引入相应的module即可,如下图所示:
需要注意的是,在Deployment页签,需要配置该项目访问的Application Context,否则有可能启动后出现404的情况。如下图所示:
配置完成即可启动文件服务组件,如下图即为启动信息日志:
.... 2019-07-20 23:48:56.174 [RMI TCP Connection(3)-127.0.0.1] DEBUG org.springframework.beans.factory.support.DefaultListableBeanFactory - Creating shared instance of singleton bean "mvcViewResolver" 2019-07-20 23:48:56.182 [RMI TCP Connection(3)-127.0.0.1] DEBUG org.springframework.beans.factory.support.DefaultListableBeanFactory - Creating shared instance of singleton bean "viewResolver" 2019-07-20 23:48:56.208 [RMI TCP Connection(3)-127.0.0.1] INFO org.fortune.commons.core.help.BeanInitializeCompletedListener - spring conf 容器初始化完毕..处理启动之后事件--start 2019-07-20 23:48:56.212 [RMI TCP Connection(3)-127.0.0.1] INFO org.fortune.doc.server.DocServerContainer - 加入账户:fortune 2019-07-20 23:48:56.212 [RMI TCP Connection(3)-127.0.0.1] INFO org.fortune.doc.server.DocServerContainer - 加入账户:fortune0 2019-07-20 23:48:56.213 [RMI TCP Connection(3)-127.0.0.1] INFO org.fortune.doc.server.DocServerContainer - 加入默认账户:Account{userName="default_account", password="lyx", rootPath="C: 5_webserverapache-tomcat-8.5.42in", level=1, thumbHeight=20, thumbWidth=20} 2019-07-20 23:48:56.296 [RMI TCP Connection(3)-127.0.0.1] INFO org.fortune.commons.core.help.BeanInitializeCompletedListener - spring conf 容器初始化完毕..处理启动之后事件--end 2019-07-20 23:48:56.302 [RMI TCP Connection(3)-127.0.0.1] DEBUG org.springframework.jndi.JndiTemplate - Looking up JNDI object with name [java:comp/env/spring.liveBeansView.mbeanDomain] 2019-07-20 23:48:56.303 [RMI TCP Connection(3)-127.0.0.1] DEBUG org.springframework.jndi.JndiLocatorDelegate - Converted JNDI name [java:comp/env/spring.liveBeansView.mbeanDomain] not found - trying original name [spring.liveBeansView.mbeanDomain]. javax.naming.NameNotFoundException: Name [spring.liveBeansView.mbeanDomain] is not bound in this Context. Unable to find [spring.liveBeansView.mbeanDomain]. 2019-07-20 23:48:56.303 [RMI TCP Connection(3)-127.0.0.1] DEBUG org.springframework.jndi.JndiTemplate - Looking up JNDI object with name [spring.liveBeansView.mbeanDomain] 2019-07-20 23:48:56.304 [RMI TCP Connection(3)-127.0.0.1] DEBUG org.springframework.jndi.JndiPropertySource - JNDI lookup for name [spring.liveBeansView.mbeanDomain] threw NamingException with message: Name [spring.liveBeansView.mbeanDomain] is not bound in this Context. Unable to find [spring.liveBeansView.mbeanDomain].. Returning null. 2019-07-20 23:48:56.307 [RMI TCP Connection(3)-127.0.0.1] INFO org.springframework.web.context.ContextLoader - Root WebApplicationContext initialized in 2216 ms 2019-07-20 23:48:56.311 [RMI TCP Connection(3)-127.0.0.1] DEBUG org.springframework.web.filter.CharacterEncodingFilter - Filter "characterEncodingFilter" configured for use 2019-07-20 23:48:56.320 [RMI TCP Connection(3)-127.0.0.1] INFO org.springframework.web.servlet.DispatcherServlet - Initializing Servlet "doc-server" ....
然后就可以访问如下页面,显示如下:
不过我们配置的netty端口是9999,我们试着访问一下,
此时我们就可以不依赖客户端,直接在网页端进行文件上传的测试操作了。输入账户,密码,选择相应的文件即可上传,上传成功的返回页面如下:
后台控制台打印出的日志信息如下:
2019-07-20 23:52:12.833 [New I/O worker #1] INFO org.fortune.doc.server.support.DocServerHandler - 文件分块操作.... 2019-07-20 23:52:12.835 [New I/O worker #1] INFO org.fortune.doc.server.support.DocServerHandler - 文件分块操作....文件大小:1024 bytes 2019-07-20 23:52:12.849 [New I/O worker #1] INFO org.fortune.doc.server.support.DocServerHandler - 文件分块操作....文件大小:2048 bytes 2019-07-20 23:52:12.849 [New I/O worker #1] INFO org.fortune.doc.server.support.DocServerHandler - 文件分块操作....文件大小:2048 bytes 2019-07-20 23:52:12.850 [New I/O worker #1] INFO org.fortune.doc.server.support.DocServerHandler - 文件分块操作....文件大小:3072 bytes 2019-07-20 23:52:12.850 [New I/O worker #1] INFO org.fortune.doc.server.support.DocServerHandler - 文件分块操作....文件大小:4096 bytes 2019-07-20 23:52:12.850 [New I/O worker #1] INFO org.fortune.doc.server.support.DocServerHandler - 文件分块操作....文件大小:6144 bytes 2019-07-20 23:52:12.852 [New I/O worker #1] INFO org.fortune.doc.server.support.DocServerHandler - 文件分块操作....文件大小:8192 bytes 2019-07-20 23:52:12.852 [New I/O worker #1] INFO org.fortune.doc.server.support.DocServerHandler - 文件分块操作....文件大小:8192 bytes 2019-07-20 23:52:12.852 [New I/O worker #1] INFO org.fortune.doc.server.support.DocServerHandler - 文件分块操作....文件大小:3072 bytes 2019-07-20 23:52:12.853 [New I/O worker #1] INFO org.fortune.doc.server.support.DocServerHandler - 文件分块操作....文件大小:8192 bytes 2019-07-20 23:52:12.853 [New I/O worker #1] INFO org.fortune.doc.server.support.DocServerHandler - 文件分块操作....文件大小:7168 bytes 2019-07-20 23:52:12.853 [New I/O worker #1] INFO org.fortune.doc.server.support.DocServerHandler - 文件分块操作....文件大小:8192 bytes 2019-07-20 23:52:12.854 [New I/O worker #1] INFO org.fortune.doc.server.support.DocServerHandler - 文件分块操作....文件大小:8192 bytes 2019-07-20 23:52:12.854 [New I/O worker #1] INFO org.fortune.doc.server.support.DocServerHandler - 文件分块操作....文件大小:6144 bytes 2019-07-20 23:52:12.856 [New I/O worker #1] INFO org.fortune.doc.server.support.DocServerHandler - 文件分块操作....文件大小:8157 bytes 2019-07-20 23:52:12.862 [New I/O worker #1] INFO org.fortune.doc.server.support.DocServerHandler - 文件分块操作....文件大小:0 bytes 2019-07-20 23:52:12.862 [New I/O worker #1] INFO org.fortune.doc.server.support.DocServerHandler - 到达文件内容的末尾,进行相应的文件处理操作....start 2019-07-20 23:52:12.865 [New I/O worker #1] INFO org.fortune.doc.server.support.DocServerHandler - 文件处理开始....requestParams参数解析: NETTY WEB Server =================================== UserName=fortune pwd=fortune action=uploadFile fileContentType=image/jpeg fileSize=81 KB getform=POST Send=Send 2019-07-20 23:52:12.867 [New I/O worker #1] INFO org.fortune.doc.server.handler.factory.DocServerHandlerFactory - 进行文件上传操作.... 2019-07-20 23:52:12.869 [New I/O worker #1] INFO org.fortune.doc.server.handler.UploadDocServerHandler - --srcFileName--psb.jpg 2019-07-20 23:52:12.871 [New I/O worker #1] INFO org.fortune.doc.server.handler.UploadDocServerHandler - 文件上传成功,保存路径为:fortunel190720235212_1027.jpg,真实路径为:C: 3_codeidea_workspacefortune-commonscommons-doc-server-netty argetcommons-doc-server-netty/fortunel190720235212_1027.jpg 2019-07-20 23:52:12.871 [New I/O worker #1] DEBUG org.fortune.doc.server.handler.UploadDocServerHandler - 生成缩略图 2019-07-20 23:52:12.872 [New I/O worker #1] INFO org.fortune.doc.server.handler.UploadDocServerHandler - 生成缩略图的名称为:190720235212_1027_thumb.jpg,路径为:C: 3_codeidea_workspacefortune-commonscommons-doc-server-netty argetcommons-doc-server-netty/fortunel190720235212_1027_thumb.jpg 2019-07-20 23:52:13.130 [New I/O worker #1] DEBUG org.fortune.doc.server.handler.factory.DocServerHandlerFactory - 执行结果:{"action":"uploadFile","code":1,"filePath":"fortunel190720235212_1027.jpg","msg":"文件上传成功","success":true} 2019-07-20 23:52:13.130 [New I/O worker #1] INFO org.fortune.doc.server.support.DocServerHandler - 文件处理结束....FileServerHandlerFactory处理结果:{"action":"uploadFile","code":1,"filePath":"fortunel190720235212_1027.jpg","msg":"文件上传成功","success":true} 2019-07-20 23:52:13.133 [New I/O worker #1] INFO org.fortune.doc.server.support.DocServerHandler - 到达文件内容的末尾,进行相应的文件处理操作....end
再观察一下netty 代码中的target目录下就有上传的文件了,如下所示:
我们可以通过如下地址进行访问,
http://localhost:8080/doc-server/fortune//l//190720235212_1027.jpg,关于如何得到图片地址,则在客户端工具类中有相应的方法获取。
4.2 客户端配置与启动 4.2.1 配置客户端的配置比较简单,也是采用yml文件方式配置如下:
#上传成功后,在需要访问文件web工程中配置以下服务器地址,正确格式为: # ${host}/${port}/${appName}/${path} # appName为远程文件服务app名称,比如doc-server # path为文件上传后服务端返回的文件相对路径 #http://localhost:8080/doc-server/fortune//p//190629082821_8300.jpg upload: server: port: 9999 #需要配置的是远程文件服务器netty服务端口号 host: 127.0.0.1 access: #访问文件 port: 8080 #访问文件 web 服务端口号 domainName: doc-server #访问文件 web 服务应用名称 userName: fortune password: fortune
需要注意的是,文件访问的端口号跟远程文件服务器netty对应的端口是不一样的,这点需要特别注意。在调用文件服务返回的路径的时候,需要用到服务端访问文件的地址,进而访问相应的文件内容。可通过方法 org.fortune.doc.client.DocClientContainer#getDocServerUrl得到相应的服务端地址,再拼接上返回的相对路径,即可得到文件的完整地址了。
4.2.2 启动/调用客户端单元测试用例如下:
/** * @author: landy * @date: 2019/5/30 23:37 * @description: */ @RunWith(SpringJUnit4ClassRunner.class) //调用Spring单元测试类 @ContextConfiguration(classes = { SettingsConfiguration.class, // common settings configuration DocClientConfiguration.class, ApplicationContextHelperConfiguration.class }) //加载Spring配置文件 public class DocClientTest { @Test public void test() { DocClient.uploadFile(new File("C: 6_temppsb.jpg"), "psb.jpg",false); } }
同样的服务端也会显示出上述相似的日志信息,
2019-07-21 00:04:26.704 [New I/O worker #4] INFO org.fortune.doc.server.handler.UploadDocServerHandler - --srcFileName--psb.jpg 2019-07-21 00:04:26.705 [New I/O worker #4] INFO org.fortune.doc.server.handler.UploadDocServerHandler - 文件上传成功,保存路径为:fortunew190721000426_6348.jpg,真实路径为:C: 3_codeidea_workspacefortune-commonscommons-doc-server-netty argetcommons-doc-server-netty/fortunew190721000426_6348.jpg 2019-07-21 00:04:26.705 [New I/O worker #4] DEBUG org.fortune.doc.server.handler.factory.DocServerHandlerFactory - 执行结果:{"action":"uploadFile","code":1,"filePath":"fortunew190721000426_6348.jpg","msg":"文件上传成功","success":true} 2019-07-21 00:04:26.705 [New I/O worker #4] INFO org.fortune.doc.server.support.DocServerHandler - 文件处理结束....FileServerHandlerFactory处理结果:{"action":"uploadFile","code":1,"filePath":"fortunew190721000426_6348.jpg","msg":"文件上传成功","success":true} 2019-07-21 00:04:26.706 [New I/O worker #4] INFO org.fortune.doc.server.support.DocServerHandler - 到达文件内容的末尾,进行相应的文件处理操作....end 2019-07-21 00:05:50.539 [http-nio-8080-exec-6] DEBUG org.springframework.web.servlet.DispatcherServlet - GET "/doc-server/fortune//w//190721000426_6348.jpg", parameters={} 2019-07-21 00:05:50.540 [http-nio-8080-exec-6] DEBUG org.springframework.web.servlet.handler.SimpleUrlHandlerMapping - Mapped to org.springframework.web.servlet.resource.DefaultServletHttpRequestHandler@4fcd8ee1 2019-07-21 00:05:50.542 [http-nio-8080-exec-6] DEBUG org.springframework.web.servlet.DispatcherServlet - Completed 200 OK
观察服务端target目录下,又多了一个文件,显示如下,
跟日志信息打印出来的路径是一致的,我们可以通过返回的地址信息进行访问文件,
5. 常见问题 5.1 Maven依赖问题如果某些jar包无法下载的话,可以手动下载然后自己手动执行maven命令安装到本地仓库即可(Then, install it using the command)。
mvn install:install-file -DgroupId=com.fasterxml.jackson.core -DartifactId=jackson-core -Dversion=2.9.9.1 -Dpackaging=jar -Dfile=/path/to/file
或者直接利用远程仓库地址进行安装也可( Alternatively, if you host your own repository you can deploy the file there: ),
mvn deploy:deploy-file -DgroupId=com.fasterxml.jackson.core -DartifactId=jackson-core -Dversion=2.9.9.1 -Dpackaging=jar -Dfile=/path/to/file -Durl=[url] -DrepositoryId=[id]5.2 Tomcat 版本问题
如果使用Tomcat7则会出现以下问题,经过对比发现,需要采用Tomcat8以上版本即可,JDK版本需要为1.8+。
七月 23, 2019 11:25:52 下午 org.apache.catalina.startup.ContextConfig processAnnotationsJar 严重: Unable to process Jar entry [module-info.class] from Jar [jar:file:/C:/03_code/idea_workspace/fortune-commons/commons-doc-server-netty/target/commons-doc-server-netty/WEB-INF/lib/asm-7.0.jar!/] for annotations org.apache.tomcat.util.bcel.classfile.ClassFormatException: Invalid byte tag in constant pool: 19 at org.apache.tomcat.util.bcel.classfile.Constant.readConstant(Constant.java:133) at org.apache.tomcat.util.bcel.classfile.ConstantPool.(ConstantPool.java:60) at org.apache.tomcat.util.bcel.classfile.ClassParser.readConstantPool(ClassParser.java:209) at org.apache.tomcat.util.bcel.classfile.ClassParser.parse(ClassParser.java:119) at org.apache.catalina.startup.ContextConfig.processAnnotationsStream(ContextConfig.java:2104) at org.apache.catalina.startup.ContextConfig.processAnnotationsJar(ContextConfig.java:1980) at org.apache.catalina.startup.ContextConfig.processAnnotationsUrl(ContextConfig.java:1946) at org.apache.catalina.startup.ContextConfig.processAnnotations(ContextConfig.java:1931) at org.apache.catalina.startup.ContextConfig.webConfig(ContextConfig.java:1325) at org.apache.catalina.startup.ContextConfig.configureStart(ContextConfig.java:878) at org.apache.catalina.startup.ContextConfig.lifecycleEvent(ContextConfig.java:369) at org.apache.catalina.util.LifecycleSupport.fireLifecycleEvent(LifecycleSupport.java:119) at org.apache.catalina.util.LifecycleBase.fireLifecycleEvent(LifecycleBase.java:90) at org.apache.catalina.core.StandardContext.startInternal(StandardContext.java:5173) at org.apache.catalina.util.LifecycleBase.start(LifecycleBase.java:150) at org.apache.catalina.core.ContainerBase.addChildInternal(ContainerBase.java:901) at org.apache.catalina.core.ContainerBase.addChild(ContainerBase.java:877) at org.apache.catalina.core.StandardHost.addChild(StandardHost.java:633) at org.apache.catalina.startup.HostConfig.manageApp(HostConfig.java:1553) at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.lang.reflect.Method.invoke(Method.java:498) at org.apache.tomcat.util.modeler.BaseModelMBean.invoke(BaseModelMBean.java:301) at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.invoke(DefaultMBeanServerInterceptor.java:819) at com.sun.jmx.mbeanserver.JmxMBeanServer.invoke(JmxMBeanServer.java:801) at org.apache.catalina.mbeans.MBeanFactory.createStandardContext(MBeanFactory.java:622) at org.apache.catalina.mbeans.MBeanFactory.createStandardContext(MBeanFactory.java:569) at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.lang.reflect.Method.invoke(Method.java:498) at org.apache.tomcat.util.modeler.BaseModelMBean.invoke(BaseModelMBean.java:301) at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.invoke(DefaultMBeanServerInterceptor.java:819) at com.sun.jmx.mbeanserver.JmxMBeanServer.invoke(JmxMBeanServer.java:801) at com.sun.jmx.remote.security.MBeanServerAccessController.invoke(MBeanServerAccessController.java:468) at javax.management.remote.rmi.RMIConnectionImpl.doOperation(RMIConnectionImpl.java:1468) at javax.management.remote.rmi.RMIConnectionImpl.access$300(RMIConnectionImpl.java:76) at javax.management.remote.rmi.RMIConnectionImpl$PrivilegedOperation.run(RMIConnectionImpl.java:1309) at java.security.AccessController.doPrivileged(Native Method) at javax.management.remote.rmi.RMIConnectionImpl.doPrivilegedOperation(RMIConnectionImpl.java:1408) at javax.management.remote.rmi.RMIConnectionImpl.invoke(RMIConnectionImpl.java:829) at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.lang.reflect.Method.invoke(Method.java:498) at sun.rmi.server.UnicastServerRef.dispatch(UnicastServerRef.java:357) at sun.rmi.transport.Transport$1.run(Transport.java:200) at sun.rmi.transport.Transport$1.run(Transport.java:197) at java.security.AccessController.doPrivileged(Native Method) at sun.rmi.transport.Transport.serviceCall(Transport.java:196) at sun.rmi.transport.tcp.TCPTransport.handleMessages(TCPTransport.java:573) at sun.rmi.transport.tcp.TCPTransport$ConnectionHandler.run0(TCPTransport.java:834) at sun.rmi.transport.tcp.TCPTransport$ConnectionHandler.lambda$run$0(TCPTransport.java:688) at java.security.AccessController.doPrivileged(Native Method) at sun.rmi.transport.tcp.TCPTransport$ConnectionHandler.run(TCPTransport.java:687) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:748) 23:25:53,087 |-INFO in ch.qos.logback.classic.LoggerContext[default] - Could NOT find resource [logback-test.xml] 23:25:53,088 |-INFO in ch.qos.logback.classic.LoggerContext[default] - Could NOT find resource [logback.groovy]
代码工程件github,地址为:https://github.com/landy8530/...
文章版权归作者所有,未经允许请勿转载,若此文章存在违规行为,您可以联系管理员删除。
转载请注明本文地址:https://www.ucloud.cn/yun/75504.html
摘要:上篇文章介绍了通用文件服务组件实现版本,本文介绍基于与的方式实现。根据官网信息可知,它是一个高性能,可为我们的应用提供文件上传服务的组件。程序可通过该对象获取服务器的响应内容。 上篇文章介绍了通用文件服务组件(Netty实现版本),本文介绍基于HTTP与Apache FileUpload的方式实现。代码地址:https://github.com/landy8530/... 1. 实现...
摘要:官网源码推荐从开始手写一个框架更多请在技术栈微信公众号后台回复关键字。是一个开放源代码的对象关系映射框架,它对进行了非常轻量级的对象封装,它将与数据库表建立映射关系,是一个全自动的框架。 Java 程序员方向太多,且不说移动开发、大数据、区块链、人工智能这些,大部分 Java 程序员都是 Java Web/后端开发。那作为一名 Java Web 开发程序员必须需要熟悉哪些框架呢? 今天...
摘要:比如面向连接的功能包发送接收数量包发送接收速率错误计数连接重连次数调用延迟连接状态等。你要处理的,就是心跳超时的逻辑,比如延迟重连。发生异常后,可以根据不同的类型选择断线重连比如一些二进制协议的编解码紊乱问题,或者调度到其他节点。 在java界,netty无疑是开发网络应用的拿手菜。你不需要太多关注复杂的nio模型和底层网络的细节,使用其丰富的接口,可以很容易的实现复杂的通讯功能。 和...
摘要:比如面向连接的功能包发送接收数量包发送接收速率错误计数连接重连次数调用延迟连接状态等。你要处理的,就是心跳超时的逻辑,比如延迟重连。发生异常后,可以根据不同的类型选择断线重连比如一些二进制协议的编解码紊乱问题,或者调度到其他节点。 在java界,netty无疑是开发网络应用的拿手菜。你不需要太多关注复杂的nio模型和底层网络的细节,使用其丰富的接口,可以很容易的实现复杂的通讯功能。 和...
阅读 2877·2021-11-11 16:55
阅读 906·2021-09-28 09:36
阅读 3774·2021-09-22 15:22
阅读 2193·2021-09-06 15:12
阅读 1726·2021-08-19 10:55
阅读 2867·2019-08-30 12:52
阅读 480·2019-08-29 14:03
阅读 1185·2019-08-29 12:27