diff --git a/jsowell-admin/src/main/resources/application-pre.yml b/jsowell-admin/src/main/resources/application-pre.yml index 2e040b713..c22d5842a 100644 --- a/jsowell-admin/src/main/resources/application-pre.yml +++ b/jsowell-admin/src/main/resources/application-pre.yml @@ -102,7 +102,7 @@ logging: # 基础URL前缀 baseurl: - prefix: http://121.40.174.65:8080 + prefix: https://apitest.jsowellcloud.com # Minio配置 minio: diff --git a/jsowell-netty/src/main/java/com/jsowell/netty/server/electricbicycles/ElectricBicyclesServerHandler.java b/jsowell-netty/src/main/java/com/jsowell/netty/server/electricbicycles/ElectricBicyclesServerHandler.java index 82957fb76..65e0aef56 100644 --- a/jsowell-netty/src/main/java/com/jsowell/netty/server/electricbicycles/ElectricBicyclesServerHandler.java +++ b/jsowell-netty/src/main/java/com/jsowell/netty/server/electricbicycles/ElectricBicyclesServerHandler.java @@ -3,16 +3,26 @@ package com.jsowell.netty.server.electricbicycles; import com.alibaba.fastjson2.JSON; import com.jsowell.netty.service.electricbicycles.EBikeBusinessService; import com.jsowell.pile.domain.ebike.AbsEBikeMessage; -import io.netty.channel.*; +import io.netty.channel.Channel; +import io.netty.channel.ChannelHandler; +import io.netty.channel.ChannelHandlerContext; +import io.netty.channel.SimpleChannelInboundHandler; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; +import java.util.Map; +import java.util.concurrent.ConcurrentHashMap; +import java.util.concurrent.CountDownLatch; +import java.util.concurrent.TimeUnit; + @ChannelHandler.Sharable @Slf4j @Component public class ElectricBicyclesServerHandler extends SimpleChannelInboundHandler { + private final Map responseFutureMap = new ConcurrentHashMap<>(); + @Autowired private EBikeBusinessService eBikeService; @@ -21,4 +31,44 @@ public class ElectricBicyclesServerHandler extends SimpleChannelInboundHandler