Skip to content

Commit

Permalink
web scoket msg length>65660
Browse files Browse the repository at this point in the history
  • Loading branch information
zhangjunfeng committed Aug 1, 2024
1 parent 4325c4c commit c265fc3
Show file tree
Hide file tree
Showing 148 changed files with 10,911 additions and 5,707 deletions.
2 changes: 1 addition & 1 deletion examples/.factorypath
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
<factorypath>
<factorypathentry kind="VARJAR" id="M2_REPO/javax/cache/cache-api/1.0.0/cache-api-1.0.0.jar" enabled="true" runInBatchMode="false"/>
<factorypathentry kind="VARJAR" id="M2_REPO/javax/cache/cache-api/1.1.1/cache-api-1.1.1.jar" enabled="true" runInBatchMode="false"/>
<factorypathentry kind="VARJAR" id="M2_REPO/org/jetbrains/annotations/16.0.3/annotations-16.0.3.jar" enabled="true" runInBatchMode="false"/>
<factorypathentry kind="VARJAR" id="M2_REPO/org/springframework/spring-context/5.2.25.RELEASE/spring-context-5.2.25.RELEASE.jar" enabled="true" runInBatchMode="false"/>
<factorypathentry kind="VARJAR" id="M2_REPO/org/springframework/spring-aop/5.2.25.RELEASE/spring-aop-5.2.25.RELEASE.jar" enabled="true" runInBatchMode="false"/>
Expand Down
10 changes: 1 addition & 9 deletions ignite-extensions/modules/elasticsearch-relay/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -34,15 +34,7 @@
<artifactId>ignite-rest-http</artifactId>
<version>${ignite.version}</version>
<scope>provided</scope>
</dependency>

<dependency>
<groupId>javax.servlet</groupId>
<artifactId>javax.servlet-api</artifactId>
<version>3.1.0</version>
<scope>provided</scope>
</dependency>

</dependency>

<dependency>
<groupId>org.springframework</groupId>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,6 @@

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.util.Arrays;
Expand All @@ -15,11 +14,6 @@
import java.util.logging.Level;
import java.util.logging.Logger;

import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

import org.apache.ignite.internal.GridKernalContext;
import org.apache.ignite.internal.processors.rest.protocols.http.jetty.GridJettyObjectMapper;
import org.elasticsearch.relay.handler.ESQueryClientIgniteHandler;
Expand All @@ -29,20 +23,20 @@
import org.elasticsearch.relay.model.ESQuery;
import org.elasticsearch.relay.model.ESUpdate;
import org.elasticsearch.relay.model.ESViewQuery;

import org.elasticsearch.relay.util.ESConstants;

import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import org.springframework.util.StringUtils;

import com.fasterxml.jackson.databind.JsonNode;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.fasterxml.jackson.databind.ObjectReader;
import com.fasterxml.jackson.databind.node.ArrayNode;
import com.fasterxml.jackson.databind.node.JsonNodeFactory;
import com.fasterxml.jackson.databind.node.ObjectNode;

import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import org.springframework.util.StringUtils;
import jakarta.servlet.ServletException;
import jakarta.servlet.http.HttpServlet;
import jakarta.servlet.http.HttpServletRequest;
import jakarta.servlet.http.HttpServletResponse;


/**
Expand Down
63 changes: 24 additions & 39 deletions ignite-extensions/modules/filemanager/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -9,13 +9,12 @@
<version>1</version>
<relativePath>../../parent-internal/pom.xml</relativePath>
</parent>

<groupId>org.apache.ignite</groupId>
<artifactId>s3-filemanager</artifactId>

<artifactId>igfs-filemanager</artifactId>
<version>2.16.999-SNAPSHOT</version>
<packaging>war</packaging>

<name>s3-filemanager</name>
<name>igfs-filemanager</name>
<description>Ignite S3 project for igfs</description>

<properties>
Expand All @@ -26,8 +25,6 @@

<jmail.version>1.6.7</jmail.version>
<ignite.version>2.16.999-SNAPSHOT</ignite.version>
<commons-lang3.version>3.7</commons-lang3.version>
<commons-beanutils.version>1.9.1</commons-beanutils.version>
<commons-io.version>2.6</commons-io.version>
<guava.version>22.0</guava.version>
<lombok.version>1.18.4</lombok.version>
Expand All @@ -36,15 +33,13 @@
</properties>

<dependencies>
<!-- https://mvnrepository.com/artifact/jakarta.servlet/jakarta.servlet-api -->
<dependency>
<groupId>javax.servlet</groupId>
<artifactId>javax.servlet-api</artifactId>
<version>3.1.0</version>
<scope>provided</scope>
</dependency>


<!-- 在zeppelin里面运行,要注释掉 -->
<groupId>jakarta.servlet</groupId>
<artifactId>jakarta.servlet-api</artifactId>
<version>4.0.4</version>
<scope>provided</scope>
</dependency>

<dependency>
<groupId>org.apache.ignite</groupId>
Expand All @@ -55,8 +50,9 @@
<dependency>
<groupId>org.apache.ignite</groupId>
<artifactId>ignite-spring</artifactId>
<scope>provided</scope>
<scope>provided</scope>
</dependency>

<dependency>
<groupId>org.apache.ignite</groupId>
<artifactId>ignite-igfs</artifactId>
Expand All @@ -65,17 +61,17 @@
</dependency>

<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-webmvc</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-web</artifactId>
<version>${spring.version}</version>
</dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-webmvc</artifactId>
<version>${spring.version}</version>
</dependency>

<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-web</artifactId>
<version>${spring.version}</version>
</dependency>


<dependency>
<groupId>software.amazon.awssdk</groupId>
Expand All @@ -94,12 +90,6 @@
<version>${commons-io.version}</version>
</dependency>

<dependency>
<groupId>commons-beanutils</groupId>
<artifactId>commons-beanutils</artifactId>
<version>${commons-beanutils.version}</version>
</dependency>

<dependency>
<groupId>com.alibaba</groupId>
<artifactId>fastjson</artifactId>
Expand All @@ -112,17 +102,12 @@
<version>1.12</version>
</dependency>

<dependency>
<groupId>commons-fileupload</groupId>
<artifactId>commons-fileupload</artifactId>
<version>1.3.1</version>
</dependency>

<dependency>
<groupId>com.github.junrar</groupId>
<artifactId>junrar</artifactId>
<version>7.5.5</version>
</dependency>
</dependency>

<dependency>
<groupId>org.webjars</groupId>
<artifactId>angularjs</artifactId>
Expand Down
Original file line number Diff line number Diff line change
@@ -0,0 +1,71 @@
/*
* Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership.
* The ASF licenses this file to You under the Apache License, Version 2.0
* (the "License"); you may not use this file except in compliance with
* the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package jakarta.fileupload;

import jakarta.fileupload.disk.DiskFileItem;

import java.io.File;

/**
* <p> The default implementation of the
* {@link jakarta.fileupload.FileItem FileItem} interface.
*
* <p> After retrieving an instance of this class from a {@link
* jakarta.fileupload.DiskFileUpload DiskFileUpload} instance (see
* {@link jakarta.fileupload.DiskFileUpload
* #parseRequest(javax.servlet.http.HttpServletRequest)}), you may
* either request all contents of file at once using {@link #get()} or
* request an {@link java.io.InputStream InputStream} with
* {@link #getInputStream()} and process the file without attempting to load
* it into memory, which may come handy with large files.
*
* @deprecated 1.1 Use <code>DiskFileItem</code> instead.
*/
@Deprecated
public class DefaultFileItem
extends DiskFileItem {

// ----------------------------------------------------------- Constructors

/**
* Constructs a new <code>DefaultFileItem</code> instance.
*
* @param fieldName The name of the form field.
* @param contentType The content type passed by the browser or
* <code>null</code> if not specified.
* @param isFormField Whether or not this item is a plain form field, as
* opposed to a file upload.
* @param fileName The original filename in the user's filesystem, or
* <code>null</code> if not specified.
* @param sizeThreshold The threshold, in bytes, below which items will be
* retained in memory and above which they will be
* stored as a file.
* @param repository The data repository, which is the directory in
* which files will be created, should the item size
* exceed the threshold.
*
* @deprecated 1.1 Use <code>DiskFileItem</code> instead.
*/
@Deprecated
public DefaultFileItem(String fieldName, String contentType,
boolean isFormField, String fileName, int sizeThreshold,
File repository) {
super(fieldName, contentType, isFormField, fileName, sizeThreshold,
repository);
}

}
Original file line number Diff line number Diff line change
@@ -0,0 +1,105 @@
/*
* Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership.
* The ASF licenses this file to You under the Apache License, Version 2.0
* (the "License"); you may not use this file except in compliance with
* the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package jakarta.fileupload;

import jakarta.fileupload.disk.DiskFileItemFactory;

import java.io.File;

/**
* <p>The default {@link jakarta.fileupload.FileItemFactory}
* implementation. This implementation creates
* {@link jakarta.fileupload.FileItem} instances which keep their
* content either in memory, for smaller items, or in a temporary file on disk,
* for larger items. The size threshold, above which content will be stored on
* disk, is configurable, as is the directory in which temporary files will be
* created.</p>
*
* <p>If not otherwise configured, the default configuration values are as
* follows:
* <ul>
* <li>Size threshold is 10KB.</li>
* <li>Repository is the system default temp directory, as returned by
* <code>System.getProperty("java.io.tmpdir")</code>.</li>
* </ul>
*
* @deprecated 1.1 Use <code>DiskFileItemFactory</code> instead.
*/
@Deprecated
public class DefaultFileItemFactory extends DiskFileItemFactory {

// ----------------------------------------------------------- Constructors

/**
* Constructs an unconfigured instance of this class. The resulting factory
* may be configured by calling the appropriate setter methods.
*
* @deprecated 1.1 Use <code>DiskFileItemFactory</code> instead.
*/
@Deprecated
public DefaultFileItemFactory() {
super();
}

/**
* Constructs a preconfigured instance of this class.
*
* @param sizeThreshold The threshold, in bytes, below which items will be
* retained in memory and above which they will be
* stored as a file.
* @param repository The data repository, which is the directory in
* which files will be created, should the item size
* exceed the threshold.
*
* @deprecated 1.1 Use <code>DiskFileItemFactory</code> instead.
*/
@Deprecated
public DefaultFileItemFactory(int sizeThreshold, File repository) {
super(sizeThreshold, repository);
}

// --------------------------------------------------------- Public Methods

/**
* Create a new {@link jakarta.fileupload.DefaultFileItem}
* instance from the supplied parameters and the local factory
* configuration.
*
* @param fieldName The name of the form field.
* @param contentType The content type of the form field.
* @param isFormField <code>true</code> if this is a plain form field;
* <code>false</code> otherwise.
* @param fileName The name of the uploaded file, if any, as supplied
* by the browser or other client.
*
* @return The newly created file item.
*
* @deprecated 1.1 Use <code>DiskFileItemFactory</code> instead.
*/
@Override
@Deprecated
public FileItem createItem(
String fieldName,
String contentType,
boolean isFormField,
String fileName
) {
return new DefaultFileItem(fieldName, contentType,
isFormField, fileName, getSizeThreshold(), getRepository());
}

}
Loading

0 comments on commit c265fc3

Please sign in to comment.