从Asp.net客户端上传大文件到JBoss Issue [英] Upload large file to JBoss Issue from Asp.net Client

查看：339
本文介绍了从Asp.net客户端上传大文件到JBoss Issue的处理方法，对大家解决问题具有一定的参考价值，需要的朋友们下面随着小编来一起学习吧！

问题描述

所有的，我有一个使用apache-common-fileupload组件的JBoss应用程序，我测试过它可以从一个使用HttpWebRequest的asp.net客户端在post方法中上传大文件。但经过几次成功的上传。它在JBoss控制台下面的例外失败。请帮忙检查一下。谢谢。

  org.apache.commons.fileupload.FileUploadBase $ IOFileUploadException：处理multipart / form-数据请求失败。流意外终止
在org.apache.commons.fileupload.FileUploadBase.parseRequest（FileUploadBase.java:359）
在com.accela.deploy.servlet.RequestHandler.getUploadFileFromRequest（RequestHandler.java:86）
，位于com.accela.deploy.servlet.DeployServlet.doPost（DeployServlet.java:122）
位于javax.servlet.http.HttpServlet.service（HttpServlet.java:710）
位于javax。 servlet.http.HttpServlet.service（HttpServlet.java:803）
位于org.apache.catalina.core.ApplicationFilterChain.internalDoFilter（ApplicationFilterChain.java:290）
位于org.apache.catalina.core。 ApplicationFilterChain.doFilter（ApplicationFilterChain.java:206）
 at com.accela.commom.filter.AuthFilter.doFilter（AuthFilter.java:99）
 at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter（ ApplicationFilterChain.java:235）
在org.apache.catalina.core.ApplicationFilterChain.doFilter（ApplicationFilterChain.java:206）
在org.jboss.web .tomcat.filters.ReplyHeaderFilter.doFilter（ReplyHeaderFilter.java:96）
 at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter（ApplicationFilterChain.java:235）
 at org.apache.catalina.core .ApplicationFilterChain.doFilter（ApplicationFilterChain.java:206）
 at org.apache.catalina.core.StandardWrapperValve.invoke（StandardWrapperValve.java:233）
 at org.apache.catalina.core.StandardContextValve.invoke （StandardContextValve.java:191）
 at org.jboss.web.tomcat.security.SecurityAssociationValve.invoke（SecurityAssociationValve.java:182）
 at org.jboss.web.tomcat.security.JaccContextValve.invoke （JaccContextValve.java:84）
 at org.apache.catalina.core.StandardHostValve.invoke（StandardHostValve.java:127）
 at org.apache.catalina.valves.ErrorReportValve.invoke（ErrorReportValve.java ：102）
在org.jboss.web.tomcat.service.jca.CachedConnectionValve.invoke（CachedConnectionValve.java:157）
在org.apa在org.apache.catalina上
（org.apache.catalina.core.StandardEngineValve.invoke（StandardEngineValve.java:109）
。 connector.CoyoteAdapter.service（CoyoteAdapter.java:293）
 at org.apache.coyote.http11.Http11AprProcessor.process（Http11AprProcessor.java:877）
 at org.apache.coyote.http11.Http11AprProtocol $ Http11ConnectionHandler.process（Http11AprProtocol.java:594）
 at org.apache.tomcat.util.net.AprEndpoint $ Worker.run（AprEndpoint.java:1733）$ b $ at java.lang.Thread.run（ Thread.java:722）

这里是server.xml的内容。请检查它。 

 <！ -  APR library装载机。 /docs/apr.html上的文档 - > 
< Listener className =org.apache.catalina.core.AprLifecycleListenerSSLEngine =on/> 
 <！ - 在加载webapps之前初始化Jasper。 /docs/jasper-howto.html上的文档 - > 
< Listener className =org.apache.catalina.core.JasperListener/> 
 
 
<服务名称=jboss.web> 
 
 
 <！ - 一个HTTP / 1.1连接器（Http11协议Http11NioProtocol Http11AprProtocol） - > 
< Connector protocol =org.apache.coyote.http11.Http11AprProtocol
 address =$ {jboss.bind.address}port =$ {av.http.port}
 scheme =httpsecure =false
 URIEncoding =UTF-8
 redirectPort =$ {av.https.port}
 maxHttpHeaderSize =8192
 maxThreads =$ {av.http.maxThreads：500}
 acceptCount =$ {av.http.acceptCount：200}
 enableLookups =false
 disableUploadTimeout =真
 /> 
 
 
 <！ -   - 使用Apache Portable Runtime（APR）的Java SSL Coyote HTTP / 1.1连接器 - > 
< Connector protocol =org.apache.coyote.http11.Http11AprProtocol
 address =$ {jboss.bind.address}port =$ {av.https.port}
 scheme =httpssecure =true
 URIEncoding =UTF-8
 maxHttpHeaderSize =8192
 maxThreads =$ {av.https.maxThreads：500} 
 acceptCount =$ {av.https.acceptCount：200}
 enableLookups =false
 disableUploadTimeout =true
 SSLEnabled =true
 SSLVerifyClient =none
 SSLProtocol =all
 SSLCipherSuite =！aNULL：！ADH：！eNULL：！LOW：！EXP：！SSLv2：RC4 + RSA：+ HIGH：+ MEDIUM：ALL 
 SSLCertificateFile =$ {jboss.server.home.dir} / conf / certs / $ {av.host} .crt
 SSLCertificateKeyFile =$ {jboss.server.home.dir} / conf /certs/${av.host}.key
 /> 
 
 
 
 
<引擎名称=jboss.webdefaultHost =localhost> 
 
< Realm className =org.jboss.web.tomcat.security.JBossSecurityMgrRealm
 certificatePrincipal =org.jboss.security.auth.certs.SubjectDNMapping
 allRolesMode =authOnly
 /> 
 $ b $ hostname =localhost
 autoDeploy =falsedeployOnStartup =falsedeployXML =false
 configClass =org.jboss.web.tomcat。 security.config.JBossContextConfig> 
 
< Valve className =org.apache.catalina.valves.AccessLogValve
 prefix =av.web。$ {jboss.bind.address} .access。 
 suffix =。log
 pattern =％a％t％T& quot;％r& quot;％s％b％u％S％p
 directory = $ {jboss.server.log.dir}
 resolveHosts =false/> 
 
< Valve className =org.jboss.web.tomcat.service.sso.ClusteredSingleSignOn/> 
  - > 
 
 <！ - 检查servlets / jsps中的未关闭连接和事务终止检查
。 
 
重要提示：对META-INF / jboss-service.xml中的CachedConnectionManager 
的依赖也必须取消注释
  - > 
< Valve className =org.jboss.web.tomcat.service.jca.CachedConnectionValve
 cachedConnectionManagerObjectName =jboss.jca：service = CachedConnectionManager
 transactionManagerObjectName =jboss：service = TransactionManager/> 
< / Host> 
< / Engine> 
 
< / Service>



编辑并添加Asp.net客户端代码。


$ b 

 public static bool SendSingleChunk（string sRequestUrl，int iOffset，int iChunkSize）
 {
 string sPackFullUriName =d：\\2GB.zip; 
 string border =---------------------------+ DateTime.Now.Ticks.ToString（x）; 
 byte [] boundarybytes = System.Text.Encoding.ASCII.GetBytes（ - + boundary +\r\\\
）; 
 string headerTemplate =Content-Disposition：form-data; name = \{0} \; filename = \{1} \\r\\\

 +Content-Type：application / octet-stream \r\\\
\r\\\
; 
 
 sFName = Path.GetFileName（sPackFullUriName）; 
 
 string header = string.Format（headerTemplate，sFName，sPackFullUriName）; 
 byte [] headerbytes = System.Text.Encoding.UTF8.GetBytes（header）; 
 
 byte [] endBoundarybytes = System.Text.Encoding.ASCII.GetBytes（\r\\\
--+ boundary +--\r\\\
）; 
 Stream requestStream = null; 
 HttpWebRequest request = null; 
 
 byte [] bData = null; 
尝试
 {
 bData = StorageHelper.ChunkReadFromDiskFile（sPackFullUriName，iOffset，iChunkSize）; 
 $ b $ Log.Write（这是+ iChunkindex +次发送chunk，大小是+ bData.Length.ToString（））; 
 long lContentLen = bData.Length + boundarybytes.Length + headerbytes.Length + endBoundarybytes.Length; 
 
 string sContentType =multipart / form-data; boundary =+ boundary; 
 
 HttpWebRequest请求=（HttpWebRequest）HttpWebRequest.Create（sRequestUrl）; 
 request.Method = WebRequestMethods.Http.Post; 
 request.KeepAlive = false; 
 request.Timeout = 300 * 60 * 1000; // 300分钟; 
 request.ContentLength = lContentLen; 
 request.AllowAutoRedirect = false; 
 request.ContentType = sContentType; 
 
 using（requestStream = request.GetRequestStream（））
 {
 requestStream.Write（boundarybytes，0，boundarybytes.Length）; 
 requestStream.Write（headerbytes，0，headerbytes.Length）; 
 
 if（bData！= null）
 {
 requestStream.Write（bData，0，bData.Length）; 
} 
 else 
 {
 return false; 
} 
 
 //requestStream.Write（formitembytes，0，formitembytes.Length）; 
 requestStream.Write（endBoundarybytes，0，endBoundarybytes.Length）; 
 requestStream.Flush（）; 
 requestStream.Close（）; 
} 
 
字符串returnedContent = string.Empty; 
 using（var response =（HttpWebResponse）request.GetResponse（））
使用（var responseStream = response.GetResponseStream（））
 {
 using（StreamReader reader = new StreamReader（responseStream））
 {
 returnedContent = reader.ReadToEnd（）; 
 reader.Close（）; 
} 
} 
 response.Close（）; 
 if（DeployConfig.ResultSucceed.Equals（OK，StringComparison.InvariantCultureIgnoreCase））
 {
 return true; 
} 
 else 
 {
 return false; 
 
 
 $ b catch（Exception ex）
 {
 return false; 
} 
 finally 
 {
 bData = null; 
 
 
 $ / code $ / pre 
 $ b 
 我的想法： 
我相信 Stream的根本原因意外地结束了异常是我发布到服务器的流的长度不完全等于我在HttpWebRequest中指定的长度。的ContentLength。 
 
 
 
 我的问题： 
 
 
 
 <如果HttpWebRequest.ContentLength的长度大于或小于我发送给服务器的实际大小？
 
如果我继续执行 SendSingleChunk 失败的帖子后？看来服务器将这两个请求流识别为同一个。 
 
 
 
 
解决方案
 
 
 
  ..流意外结束
  
因为 asp.net 客户端应用程序在几次成功上传之后意外地关闭了套接字，或者可能存在连接问题。请参阅下面的线索，以获得有关此错误的可能原因的完整讨论。
 
 
 
 为什么我得到FileUploadException：Stream意外结束用Apache Commons FileUpload？ 
 
All , I had a JBoss application which uses apache-common-fileupload component, I had tested it can be uploaded large file from a asp.net Client which use HttpWebRequest in post method. But after several times of successful upload.It failed with a exception below in JBoss console. Please help to check it .Thanks.
org.apache.commons.fileupload.FileUploadBase$IOFileUploadException: Processing of multipart/form-data request failed. Stream ended unexpectedly
      at org.apache.commons.fileupload.FileUploadBase.parseRequest(FileUploadBase.java:359)
      at com.accela.deploy.servlet.RequestHandler.getUploadFileFromRequest(RequestHandler.java:86)
      at com.accela.deploy.servlet.DeployServlet.doPost(DeployServlet.java:122)
      at javax.servlet.http.HttpServlet.service(HttpServlet.java:710)
      at javax.servlet.http.HttpServlet.service(HttpServlet.java:803)
      at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:290)
      at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:206)
      at com.accela.commom.filter.AuthFilter.doFilter(AuthFilter.java:99)
      at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:235)
      at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:206)
      at org.jboss.web.tomcat.filters.ReplyHeaderFilter.doFilter(ReplyHeaderFilter.java:96)
      at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:235)
      at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:206)
      at org.apache.catalina.core.StandardWrapperValve.invoke(StandardWrapperValve.java:233)
      at org.apache.catalina.core.StandardContextValve.invoke(StandardContextValve.java:191)
      at org.jboss.web.tomcat.security.SecurityAssociationValve.invoke(SecurityAssociationValve.java:182)
      at org.jboss.web.tomcat.security.JaccContextValve.invoke(JaccContextValve.java:84)
      at org.apache.catalina.core.StandardHostValve.invoke(StandardHostValve.java:127)
      at org.apache.catalina.valves.ErrorReportValve.invoke(ErrorReportValve.java:102)
      at org.jboss.web.tomcat.service.jca.CachedConnectionValve.invoke(CachedConnectionValve.java:157)
      at org.apache.catalina.valves.AccessLogValve.invoke(AccessLogValve.java:615)
      at org.apache.catalina.core.StandardEngineValve.invoke(StandardEngineValve.java:109)
      at org.apache.catalina.connector.CoyoteAdapter.service(CoyoteAdapter.java:293)
      at org.apache.coyote.http11.Http11AprProcessor.process(Http11AprProcessor.java:877)
      at org.apache.coyote.http11.Http11AprProtocol$Http11ConnectionHandler.process(Http11AprProtocol.java:594)
      at org.apache.tomcat.util.net.AprEndpoint$Worker.run(AprEndpoint.java:1733)
      at java.lang.Thread.run(Thread.java:722)

Here is the server.xml content. Please check it .



<!--APR library loader. Documentation at /docs/apr.html -->
<Listener className="org.apache.catalina.core.AprLifecycleListener" SSLEngine="on" />
<!--Initialize Jasper prior to webapps are loaded. Documentation at /docs/jasper-howto.html -->
<Listener className="org.apache.catalina.core.JasperListener" />


<Service name="jboss.web">


    <!--  A HTTP/1.1 Connector (Http11Protocol Http11NioProtocol Http11AprProtocol)-->
    <Connector protocol="org.apache.coyote.http11.Http11AprProtocol"
        address="${jboss.bind.address}" port="${av.http.port}"
        scheme="http" secure="false"
        URIEncoding="UTF-8"
        redirectPort="${av.https.port}"
        maxHttpHeaderSize="8192"
        maxThreads="${av.http.maxThreads:500}" 
        acceptCount="${av.http.acceptCount:200}" 
        enableLookups="false"
        disableUploadTimeout="true"
        /> 


    <!--  Java SSL Coyote HTTP/1.1 Connector using Apache Portable Runtime (APR) -->
    <Connector protocol="org.apache.coyote.http11.Http11AprProtocol"
        address="${jboss.bind.address}" port="${av.https.port}"
        scheme="https" secure="true"
        URIEncoding="UTF-8"
        maxHttpHeaderSize="8192"
        maxThreads="${av.https.maxThreads:500}"
        acceptCount="${av.https.acceptCount:200}"
        enableLookups="false"
        disableUploadTimeout="true"
        SSLEnabled="true"
        SSLVerifyClient="none"
        SSLProtocol="all"
        SSLCipherSuite="!aNULL:!ADH:!eNULL:!LOW:!EXP:!SSLv2:RC4+RSA:+HIGH:+MEDIUM:ALL"
        SSLCertificateFile="${jboss.server.home.dir}/conf/certs/${av.host}.crt" 
        SSLCertificateKeyFile="${jboss.server.home.dir}/conf/certs/${av.host}.key"
    /> 




    <Engine name="jboss.web" defaultHost="localhost">

        <Realm className="org.jboss.web.tomcat.security.JBossSecurityMgrRealm"
        certificatePrincipal="org.jboss.security.auth.certs.SubjectDNMapping"
        allRolesMode="authOnly"
        />

        <Host name="localhost"
            autoDeploy="false" deployOnStartup="false" deployXML="false"
            configClass="org.jboss.web.tomcat.security.config.JBossContextConfig">

            <Valve className="org.apache.catalina.valves.AccessLogValve"
                prefix="av.web.${jboss.bind.address}.access." 
                suffix=".log" 
                pattern="%a %t %T &quot;%r&quot; %s %b %u %S %p" 
                directory="${jboss.server.log.dir}" 
                resolveHosts="false" />

                <Valve className="org.jboss.web.tomcat.service.sso.ClusteredSingleSignOn" />
            -->

            <!-- Check for unclosed connections and transaction terminated checks
                in servlets/jsps.

                Important: The dependency on the CachedConnectionManager
                in META-INF/jboss-service.xml must be uncommented, too
            -->
            <Valve className="org.jboss.web.tomcat.service.jca.CachedConnectionValve"
            cachedConnectionManagerObjectName="jboss.jca:service=CachedConnectionManager"
            transactionManagerObjectName="jboss:service=TransactionManager" />          
        </Host>
    </Engine>

</Service>




Edited and Added Asp.net client code .
public static bool SendSingleChunk(string sRequestUrl,int iOffset, int iChunkSize)
        {
            string sPackFullUriName = "d:\\2GB.zip";
            string boundary = "---------------------------" + DateTime.Now.Ticks.ToString("x");
            byte[] boundarybytes = System.Text.Encoding.ASCII.GetBytes("--" + boundary + "\r\n");
            string headerTemplate = "Content-Disposition: form-data; name=\"{0}\"; filename=\"{1}\"\r\n"
                                    + "Content-Type: application/octet-stream\r\n\r\n";

            sFName = Path.GetFileName(sPackFullUriName);

            string header = string.Format(headerTemplate, sFName, sPackFullUriName);
            byte[] headerbytes = System.Text.Encoding.UTF8.GetBytes(header);

            byte[] endBoundarybytes = System.Text.Encoding.ASCII.GetBytes("\r\n--" + boundary + "--\r\n");
            Stream requestStream = null;
            HttpWebRequest request = null;

            byte[] bData = null;
            try
            {
                bData = StorageHelper.ChunkReadFromDiskFile(sPackFullUriName, iOffset, iChunkSize);

                Log.Write("This is the " + iChunkindex + " times to send chunk, size is " + bData.Length.ToString());
                long lContentLen = bData.Length + boundarybytes.Length + headerbytes.Length + endBoundarybytes.Length;

                string sContentType = "multipart/form-data; boundary=" + boundary;

                HttpWebRequest request = (HttpWebRequest)HttpWebRequest.Create(sRequestUrl);
                request.Method = WebRequestMethods.Http.Post;
                request.KeepAlive = false;
                request.Timeout = 300 * 60 * 1000; //300 mins;
                request.ContentLength = lContentLen;
                request.AllowAutoRedirect = false;
                request.ContentType = sContentType;

                using (requestStream = request.GetRequestStream())
                {
                    requestStream.Write(boundarybytes, 0, boundarybytes.Length);
                    requestStream.Write(headerbytes, 0, headerbytes.Length);

                    if (bData != null)
                    {
                        requestStream.Write(bData, 0, bData.Length);
                    }
                    else
                    {
                        return false;
                    }

                    //requestStream.Write(formitembytes, 0, formitembytes.Length);
                    requestStream.Write(endBoundarybytes, 0, endBoundarybytes.Length);
                    requestStream.Flush();
                    requestStream.Close();
                }

                string returnedContent = string.Empty;
                using (var response = (HttpWebResponse)request.GetResponse())
                {
                    using (var responseStream = response.GetResponseStream())
                    {
                        using (StreamReader reader = new StreamReader(responseStream))
                        {
                            returnedContent = reader.ReadToEnd();
                            reader.Close();
                        }
                    }
                    response.Close();
                    if (DeployConfig.ResultSucceed.Equals("OK", StringComparison.InvariantCultureIgnoreCase))
                    {
                        return true;
                    }
                    else
                    {
                        return false;
                    }
                }
            }
            catch (Exception ex)
            {
                return false;
            }
            finally
            {
                bData = null;
            }
        }

My idea:
I believe the root reason of the Stream ended unexpectedly exception is the length of the stream I post to server is not exactly equal to the length i specified in the HttpWebRequest.ContentLength. 



My Questions:

  
1.What if the the length of the HttpWebRequest.ContentLength is larger or smaller than the actual size of I sent to server ?

  
  
2.What if I continue to execute SendSingleChunk after a failed post ? It seems the server recognized these two request streams as the same one. 




 解决方案 
The error message says:
.. Stream ended unexpectedly

This is most probably because the asp.net client application closes the socket unexpectedly after several successful uploads or may be there is a connection problem. Please see the below thread for a full discussion on the possible reasons for this error.



Why did I get "FileUploadException: Stream ended unexpectedly" with Apache Commons FileUpload?


                        
这篇关于从Asp.net客户端上传大文件到JBoss Issue的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！
查看全文
相关文章
开发方法最新文章
热门教程
热门工具
登录 关闭
扫码关注1秒登录
发送“验证码”获取 | 15天全站免登陆