redkale.convert.tiny默认值由true改成false
This commit is contained in:
@@ -130,7 +130,7 @@
|
|||||||
System.setProperty("redkale.net.transport.poolmaxconns", "100");
|
System.setProperty("redkale.net.transport.poolmaxconns", "100");
|
||||||
System.setProperty("redkale.net.transport.pinginterval", "30");
|
System.setProperty("redkale.net.transport.pinginterval", "30");
|
||||||
System.setProperty("redkale.net.transport.checkinterval", "30");
|
System.setProperty("redkale.net.transport.checkinterval", "30");
|
||||||
System.setProperty("redkale.convert.tiny", "true");
|
System.setProperty("redkale.convert.tiny", "false");
|
||||||
System.setProperty("redkale.convert.pool.size", "128");
|
System.setProperty("redkale.convert.pool.size", "128");
|
||||||
System.setProperty("redkale.convert.writer.buffer.defsize", "4096");
|
System.setProperty("redkale.convert.writer.buffer.defsize", "4096");
|
||||||
|
|
||||||
|
|||||||
@@ -665,7 +665,7 @@ public final class Application {
|
|||||||
System.setProperty("redkale.net.transport.poolmaxconns", "100");
|
System.setProperty("redkale.net.transport.poolmaxconns", "100");
|
||||||
System.setProperty("redkale.net.transport.pinginterval", "30");
|
System.setProperty("redkale.net.transport.pinginterval", "30");
|
||||||
System.setProperty("redkale.net.transport.checkinterval", "30");
|
System.setProperty("redkale.net.transport.checkinterval", "30");
|
||||||
System.setProperty("redkale.convert.tiny", "true");
|
System.setProperty("redkale.convert.tiny", "false");
|
||||||
System.setProperty("redkale.convert.pool.size", "128");
|
System.setProperty("redkale.convert.pool.size", "128");
|
||||||
System.setProperty("redkale.convert.writer.buffer.defsize", "4096");
|
System.setProperty("redkale.convert.writer.buffer.defsize", "4096");
|
||||||
|
|
||||||
|
|||||||
@@ -42,7 +42,7 @@ public abstract class ConvertFactory<R extends Reader, W extends Writer> {
|
|||||||
|
|
||||||
protected Convert<R, W> convert;
|
protected Convert<R, W> convert;
|
||||||
|
|
||||||
protected boolean tiny; //String类型值为"",Boolean类型值为false时是否需要输出, 默认为true
|
protected boolean tiny; //String类型值为"",Boolean类型值为false时是否需要输出, 默认为false
|
||||||
|
|
||||||
private final Encodeable<W, ?> anyEncoder = new AnyEncoder(this);
|
private final Encodeable<W, ?> anyEncoder = new AnyEncoder(this);
|
||||||
|
|
||||||
|
|||||||
@@ -24,7 +24,7 @@ import org.redkale.util.*;
|
|||||||
@SuppressWarnings("unchecked")
|
@SuppressWarnings("unchecked")
|
||||||
public final class BsonFactory extends ConvertFactory<BsonReader, BsonWriter> {
|
public final class BsonFactory extends ConvertFactory<BsonReader, BsonWriter> {
|
||||||
|
|
||||||
private static final BsonFactory instance = new BsonFactory(null, getSystemPropertyBoolean("redkale.convert.bson.tiny", "redkale.convert.tiny", true));
|
private static final BsonFactory instance = new BsonFactory(null, getSystemPropertyBoolean("redkale.convert.bson.tiny", "redkale.convert.tiny", false));
|
||||||
|
|
||||||
static final Decodeable objectDecoder = instance.loadDecoder(Object.class);
|
static final Decodeable objectDecoder = instance.loadDecoder(Object.class);
|
||||||
|
|
||||||
@@ -73,7 +73,7 @@ public final class BsonFactory extends ConvertFactory<BsonReader, BsonWriter> {
|
|||||||
}
|
}
|
||||||
|
|
||||||
public static BsonFactory create() {
|
public static BsonFactory create() {
|
||||||
return new BsonFactory(null, getSystemPropertyBoolean("redkale.convert.bson.tiny", "redkale.convert.tiny", true));
|
return new BsonFactory(null, getSystemPropertyBoolean("redkale.convert.bson.tiny", "redkale.convert.tiny", false));
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
|
|||||||
@@ -24,7 +24,7 @@ import org.redkale.util.*;
|
|||||||
@SuppressWarnings("unchecked")
|
@SuppressWarnings("unchecked")
|
||||||
public final class JsonFactory extends ConvertFactory<JsonReader, JsonWriter> {
|
public final class JsonFactory extends ConvertFactory<JsonReader, JsonWriter> {
|
||||||
|
|
||||||
private static final JsonFactory instance = new JsonFactory(null, getSystemPropertyBoolean("redkale.convert.json.tiny", "redkale.convert.tiny", true));
|
private static final JsonFactory instance = new JsonFactory(null, getSystemPropertyBoolean("redkale.convert.json.tiny", "redkale.convert.tiny", false));
|
||||||
|
|
||||||
static {
|
static {
|
||||||
instance.register(Serializable.class, instance.loadEncoder(Object.class));
|
instance.register(Serializable.class, instance.loadEncoder(Object.class));
|
||||||
@@ -65,7 +65,7 @@ public final class JsonFactory extends ConvertFactory<JsonReader, JsonWriter> {
|
|||||||
}
|
}
|
||||||
|
|
||||||
public static JsonFactory create() {
|
public static JsonFactory create() {
|
||||||
return new JsonFactory(null, getSystemPropertyBoolean("redkale.convert.json.tiny", "redkale.convert.tiny", true));
|
return new JsonFactory(null, getSystemPropertyBoolean("redkale.convert.json.tiny", "redkale.convert.tiny", false));
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
|
|||||||
@@ -10,7 +10,9 @@ import javax.annotation.Priority;
|
|||||||
import org.redkale.util.*;
|
import org.redkale.util.*;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 协议拦截器类
|
* 协议拦截器类, 类似JavaEE中的javax.servlet.Filter <br>
|
||||||
|
* javax.servlet.Filter方法doFilter是同步操作,此Filter.doFilter则是异步操作,方法return前需要调用Response.nextEvent()方可执行下一个Filter <br>
|
||||||
|
* 通过给Filter标记注解@Priority来确定执行的顺序, Priority.value值越大越先执行
|
||||||
*
|
*
|
||||||
* <p>
|
* <p>
|
||||||
* 详情见: https://redkale.org
|
* 详情见: https://redkale.org
|
||||||
|
|||||||
@@ -244,6 +244,14 @@ public final class Utility {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
public static <T> CompletableFuture<T> orTimeout(CompletableFuture future, Duration timeout) {
|
||||||
|
return future.orTimeout(timeout.toMillis(), TimeUnit.MILLISECONDS);
|
||||||
|
}
|
||||||
|
|
||||||
|
public static <T> CompletableFuture<T> completeOnTimeout(CompletableFuture future, T value, Duration timeout) {
|
||||||
|
return future.completeOnTimeout(value, timeout.toMillis(), TimeUnit.MILLISECONDS);
|
||||||
|
}
|
||||||
|
|
||||||
public static <T> CompletableFuture<T> orTimeout(CompletableFuture future, long timeout, TimeUnit unit) {
|
public static <T> CompletableFuture<T> orTimeout(CompletableFuture future, long timeout, TimeUnit unit) {
|
||||||
return future.orTimeout(timeout, unit);
|
return future.orTimeout(timeout, unit);
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user