feat:redis序列化报错

易文鹏
1 parent fa30f0e2
Showing 4 changed files with 49 additions and 75 deletions
src/main/java/com/huaheng/framework/config/RedisConfig.java
src/main/java/com/huaheng/framework/redis/serializer/SerializeUtils.java
src/main/java/com/huaheng/mobile/receipt/MobileBatchReceiptController.java
src/main/java/com/huaheng/pc/inventory/inventoryTransaction/domain/vo/InventoryRankVO.java
@@ -16,6 +16,7 @@ import org.springframework.context.annotation.Configuration;
 import org.springframework.context.annotation.Scope;
 import org.springframework.data.redis.cache.RedisCacheConfiguration;
 import org.springframework.data.redis.cache.RedisCacheManager;
+import org.springframework.data.redis.connection.RedisConnectionFactory;
 import org.springframework.data.redis.connection.RedisPassword;
 import org.springframework.data.redis.connection.RedisStandaloneConfiguration;
 import org.springframework.data.redis.connection.lettuce.LettuceClientConfiguration;
@@ -32,8 +33,7 @@ import java.time.Duration;
  
 @Configuration
 @EnableCaching // 开启缓存支持
-public class RedisConfig extends CachingConfigurerSupport
-{
+public class RedisConfig extends CachingConfigurerSupport {
     @Value("${redis.database}")
     private int database;
  
@@ -70,35 +70,31 @@ public class RedisConfig extends CachingConfigurerSupport
      * 在没有指定缓存Key的情况下，key生成策略
      */
     @Bean
-    public KeyGenerator keyGenerator()
-    {
-        return new KeyGenerator()
-        {
+    public KeyGenerator keyGenerator() {
+        return new KeyGenerator() {
             @Override
-            public Object generate(Object target, Method method, Object... params)
-            {
+            public Object generate(Object target, Method method, Object... params) {
                 StringBuffer sb = new StringBuffer();
                 sb.append(target.getClass().getName());
                 sb.append(method.getName());
-                for (Object obj : params)
-                {
+                for (Object obj : params) {
                     sb.append(obj.toString());
                 }
                 return sb.toString();
             }
         };
     }
+    
  
     // 缓存管理器 使用Lettuce，和jedis有很大不同LettuceConnectionFactory lettuceConnectionFactory
     @Bean
-    public CacheManager cacheManager()
-    {
+    public CacheManager cacheManager() {
         // 关键点，spring cache的注解使用的序列化都从这来，没有这个配置的话使用的jdk自己的序列化，实际上不影响使用，只是打印出来不适合人眼识别
         RedisCacheConfiguration redisCacheConfiguration = RedisCacheConfiguration.defaultCacheConfig()
                 .serializeKeysWith(RedisSerializationContext.SerializationPair.fromSerializer(keySerializer()))// key序列化方式
                 .serializeValuesWith(RedisSerializationContext.SerializationPair.fromSerializer(getValueSerializer()))// value序列化方式
                 .disableCachingNullValues().entryTtl(timeToLive).disableCachingNullValues();
-        ;// 缓存过期时间
+        // 缓存过期时间
  
         RedisCacheManager.RedisCacheManagerBuilder builder = RedisCacheManager.RedisCacheManagerBuilder
                 .fromConnectionFactory(lettuceConnectionFactory())// 默认有锁 等待锁时间为0
@@ -110,8 +106,7 @@ public class RedisConfig extends CachingConfigurerSupport
      * RedisTemplate配置 使用自定义redisTemplate的时候 重新定义序列化方式 LettuceConnectionFactory lettuceConnectionFactory
      */
     @Bean
-    public RedisTemplate<String, Object> redisTemplate()
-    {
+    public RedisTemplate<String, Object> redisTemplate() {
         // 配置redisTemplate
         RedisTemplate<String, Object> redisTemplate = new RedisTemplate<String, Object>();
         redisTemplate.setConnectionFactory(lettuceConnectionFactory());
@@ -131,8 +126,7 @@ public class RedisConfig extends CachingConfigurerSupport
      * shiroRedisTemplate配置 使用自定义shiroRedisTemplate的时候 重新定义序列化方式 LettuceConnectionFactory lettuceConnectionFactory
      */
     @Bean
-    public RedisTemplate<String, Object> shiroRedisTemplate()
-    {
+    public RedisTemplate<String, Object> shiroRedisTemplate() {
         // 配置redisTemplate
         RedisTemplate<String, Object> shiroRedisTemplate = new RedisTemplate<String, Object>();
         shiroRedisTemplate.setConnectionFactory(lettuceConnectionFactory());
@@ -148,16 +142,13 @@ public class RedisConfig extends CachingConfigurerSupport
         return shiroRedisTemplate;
     }
  
-    private RedisSerializer<String> keySerializer()
-    {
+    private RedisSerializer<String> keySerializer() {
         return new StringRedisSerializer();
     }
  
-    private RedisSerializer<Object> getValueSerializer()
-    {
+    private RedisSerializer<Object> getValueSerializer() {
         // 设置序列化
-        Jackson2JsonRedisSerializer<Object> jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer<Object>(
-                Object.class);
+        Jackson2JsonRedisSerializer<Object> jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer<Object>(Object.class);
         ObjectMapper om = new ObjectMapper();
         om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
         om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
@@ -167,43 +158,27 @@ public class RedisConfig extends CachingConfigurerSupport
  
     // 单机版配置连接参数
     @Bean
-    public RedisStandaloneConfiguration redisStandaloneConfiguration()
-    {
+    public RedisStandaloneConfiguration redisStandaloneConfiguration() {
         RedisStandaloneConfiguration redisStandaloneConfiguration = new RedisStandaloneConfiguration();
         redisStandaloneConfiguration.setDatabase(database);
         redisStandaloneConfiguration.setHostName(host);
         redisStandaloneConfiguration.setPort(port);
         redisStandaloneConfiguration.setPassword(RedisPassword.of(password));
-
-        // 集群版配置
-        // RedisClusterConfiguration redisClusterConfiguration = new RedisClusterConfiguration();
-        // String[] serverArray = clusterNodes.split(",");
-        // Set<RedisNode> nodes = new HashSet<RedisNode>();
-        // for (String ipPort : serverArray) {
-        // String[] ipAndPort = ipPort.split(":");
-        // nodes.add(new RedisNode(ipAndPort[0].trim(), Integer.valueOf(ipAndPort[1])));
-        // }
-        // redisClusterConfiguration.setPassword(RedisPassword.of(password));
-        // redisClusterConfiguration.setClusterNodes(nodes);
-        // redisClusterConfiguration.setMaxRedirects(maxRedirects);
-
         return redisStandaloneConfiguration;
     }
  
     /**
      * 配置LettuceClientConfiguration 包括线程池配置和安全项配置 genericObjectPoolConfig common-pool2线程池GenericObjectPoolConfig
      * genericObjectPoolConfig
-     * 
+     *
      * @return lettuceClientConfiguration
      */
     @Bean
-    public LettuceClientConfiguration lettuceClientConfiguration()
-    {
+    public LettuceClientConfiguration lettuceClientConfiguration() {
         LettuceClientConfiguration lettuceClientConfiguration = LettucePoolingClientConfiguration.builder()
                 .commandTimeout(Duration.ofMillis(timeout)).shutdownTimeout(Duration.ofMillis(200))
                 .poolConfig(genericObjectPoolConfig()).build();
-        if (ssl)
-        {
+        if (ssl) {
             lettuceClientConfiguration.isUseSsl();
         }
         return lettuceClientConfiguration;
@@ -211,8 +186,7 @@ public class RedisConfig extends CachingConfigurerSupport
  
     // 设置连接工厂
     @Bean
-    public LettuceConnectionFactory lettuceConnectionFactory()
-    {
+    public LettuceConnectionFactory lettuceConnectionFactory() {
         return new LettuceConnectionFactory(redisStandaloneConfiguration(), lettuceClientConfiguration());
     }
  
@@ -223,8 +197,7 @@ public class RedisConfig extends CachingConfigurerSupport
     @ConfigurationProperties(prefix = "redis.lettuce.pool")
     @Scope(value = "prototype")
     @SuppressWarnings("rawtypes")
-    public GenericObjectPoolConfig genericObjectPoolConfig()
-    {
+    public GenericObjectPoolConfig genericObjectPoolConfig() {
         return new GenericObjectPoolConfig();
     }
 }
@@ -7,37 +7,31 @@ import org.springframework.data.redis.serializer.SerializationException;
  
 import java.io.*;
  
-public class SerializeUtils<T> implements RedisSerializer<T>
-{
+public class SerializeUtils<T> implements RedisSerializer<T> {
     private static Logger logger = LoggerFactory.getLogger(SerializeUtils.class);
  
-    public static boolean isEmpty(byte[] data)
-    {
+    public static boolean isEmpty(byte[] data) {
         return (data == null || data.length == 0);
     }
  
     /**
      * 序列化
-     * 
+     *
      * @param t
      * @return
      * @throws SerializationException
      */
     @Override
-    public byte[] serialize(T t) throws SerializationException
-    {
+    public byte[] serialize(T t) throws SerializationException {
         byte[] result = null;
  
-        if (t == null)
-        {
+        if (t == null) {
             return new byte[0];
         }
         try (ByteArrayOutputStream byteStream = new ByteArrayOutputStream(128);
-                ObjectOutputStream objectOutputStream = new ObjectOutputStream(byteStream))
-        {
+             ObjectOutputStream objectOutputStream = new ObjectOutputStream(byteStream)) {
  
-            if (!(t instanceof Serializable))
-            {
+            if (!(t instanceof Serializable)) {
                 throw new IllegalArgumentException(
                         SerializeUtils.class.getSimpleName() + " requires a Serializable payload "
                                 + "but received an object of type [" + t.getClass().getName() + "]");
@@ -46,9 +40,7 @@ public class SerializeUtils&lt;T&gt; implements RedisSerializer&lt;T&gt;
             objectOutputStream.writeObject(t);
             objectOutputStream.flush();
             result = byteStream.toByteArray();
-        }
-        catch (Exception ex)
-        {
+        } catch (Exception ex) {
             logger.error("Failed to serialize", ex);
         }
         return result;
@@ -56,28 +48,23 @@ public class SerializeUtils&lt;T&gt; implements RedisSerializer&lt;T&gt;
  
     /**
      * 反序列化
-     * 
+     *
      * @param bytes
      * @return
      * @throws SerializationException
      */
     @SuppressWarnings("unchecked")
     @Override
-    public T deserialize(byte[] bytes) throws SerializationException
-    {
+    public T deserialize(byte[] bytes) throws SerializationException {
         T result = null;
-        if (isEmpty(bytes))
-        {
+        if (isEmpty(bytes)) {
             return null;
         }
         ObjectInputStream objectInputStream;
-        try
-        {
+        try {
             objectInputStream = new ObjectInputStream(new ByteArrayInputStream(bytes));
             result = (T) objectInputStream.readObject();
-        }
-        catch (Exception e)
-        {
+        } catch (Exception e) {
             logger.error("Failed to deserialize", e);
         }
         return result;
@@ -538,7 +538,7 @@ public class MobileBatchReceiptController {
  
     @PostMapping("/callBox")
     @ApiOperation("移动端呼叫料盒")
-    @ApiLogger(apiName = "wcs调用wms分配库位", from = "WCS")
+    @ApiLogger(apiName = "PDA呼叫料盒", from = "WCS")
     @Log(title = "移动端呼叫料盒", action = BusinessType.OTHER)
     @Transactional(rollbackFor = Exception.class)
     public AjaxResult callBox(@RequestBody @ApiParam(value = "物料号") Map<String, String> param) {
@@ -9,14 +9,28 @@ import java.math.BigDecimal;
 @Data
 @Builder
 public class InventoryRankVO implements Serializable {
+    // 空构造函数
+    public InventoryRankVO() {
+    }
+
+    // 带参数的构造函数
+    public InventoryRankVO(String materialCode, Integer inQty, Integer outQty, String materialName, String materialSpec, String materialUnit, BigDecimal taskQty) {
+        this.materialCode = materialCode;
+        this.inQty = inQty;
+        this.outQty = outQty;
+        this.materialName = materialName;
+        this.materialSpec = materialSpec;
+        this.materialUnit = materialUnit;
+        this.taskQty = taskQty;
+    }
  
     private static final long serialVersionUID = 2903643973589589715L;
  
     private String materialCode;
     private Integer inQty;
     private Integer outQty;
-    private BigDecimal taskQty;
     private String materialName;
     private String materialSpec;
     private String materialUnit;
+    private BigDecimal taskQty;
 }