Merge remote-tracking branch 'origin/5.0.0-dev' into 5.0.0-dev

Author: ujued

tx-client/src/main/java/com/codingapi/tx/client/spi/message/txc/TxcTransactionCleanService.java

@@ -28,9 +28,6 @@ public TxcTransactionCleanService(TxcService txcService) {
         this.txcService = txcService;
     }
 
-    @Autowired
-    private TxLogger txLogger;
-
     @Override
     public void clear(String groupId, int state, String unitId, String unitType) throws TransactionClearException {
         try {

tx-manager/src/main/java/com/codingapi/tx/manager/db/redis/RedisSetManagerStorage.java

@@ -0,0 +1,59 @@
+package com.codingapi.tx.manager.db.redis;
+
+import com.codingapi.tx.manager.config.TxManagerConfig;
+import com.codingapi.tx.manager.db.ManagerStorage;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.data.redis.core.RedisTemplate;
+
+import javax.annotation.PostConstruct;
+import javax.annotation.PreDestroy;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Objects;
+
+/**
+ * Manager信息改用Set 暂未使用
+ *
+ * @author meetzy
+ * @date 2019-01-14 11:09
+ */
+@Slf4j
+public class RedisSetManagerStorage implements ManagerStorage {
+    
+    private static final String REDIS_PREFIX = "tx.manager.list";
+    
+    @Autowired
+    private RedisTemplate<String, String> redisTemplate;
+    
+    @Autowired
+    private TxManagerConfig managerConfig;
+    
+    @Value("${server.port}")
+    private int port;
+    
+    @Override
+    public List<String> addressList() {
+        return new ArrayList<>(Objects.requireNonNull(redisTemplate.opsForSet().members(REDIS_PREFIX)));
+    }
+    
+    @Override
+    public void remove(String address) {
+        redisTemplate.opsForSet().remove(REDIS_PREFIX, address);
+    }
+    
+    @PostConstruct
+    public void init() {
+        String address = managerConfig.getHost() + ":" + port;
+        redisTemplate.opsForSet().add(REDIS_PREFIX, address);
+        log.info("manager add redis finish.");
+    }
+    
+    @PreDestroy
+    public void destroy() {
+        String address = managerConfig.getHost() + ":" + port;
+        remove(address);
+        log.info("manager remove redis.");
+    }
+}