并发连接数调优

This commit is contained in:
三丙
2024-12-09 10:47:11 +08:00
parent 7dc5b0ea25
commit 5cd8c0a08e
3 changed files with 4 additions and 4 deletions

View File

@@ -6,7 +6,7 @@
echo "Starting Server ..."
export JAVA_APP_OPTS="-XX:+UseContainerSupport -XX:InitialRAMPercentage=10 -XX:MaxRAMPercentage=70 \
export JAVA_APP_OPTS="-XX:+UseContainerSupport -XX:InitialRAMPercentage=50 -XX:MaxRAMPercentage=90 \
-Xlog:gc*,heap*,age*,safepoint=debug:file=/home/sanbing/logs/gc/gc.log:time,uptime,level,tags:filecount=10,filesize=10M \
-XX:+HeapDumpOnOutOfMemoryError \
-XX:HeapDumpPath=/home/sanbing/logs/heapdump/ \

View File

@@ -75,9 +75,9 @@ class PileMapperIT extends AbstractTestBase {
}
@Test
void generate100KPiles() {
void generate1MPiles() {
AtomicInteger number = new AtomicInteger(1);
for (int i = 0; i < 100; i++) {
for (int i = 0; i < 1000; i++) {
List<Pile> piles = new ArrayList<>();
for (int j = 0; j < 1000; j++, number.incrementAndGet()) {
Pile pile = Pile.builder()

View File

@@ -245,7 +245,7 @@ public class DownlinkGrpcClient {
@Override
public void onError(Throwable t) {
log.warn("[{}] Grpc 客户端异常 {}", hostAndPort, t.getMessage());
log.warn("[{}] Grpc 客户端异常 {}", hostAndPort, t.getMessage(), t);
ExecutorService executorService = msgHandleExecutorMap.get(hostAndPort);
if (executorService != null) {