design pattern

src/main/java/com/wangzaiplus/test/config/JedisConfig.java

@@ -6,7 +6,7 @@
 import redis.clients.jedis.JedisPool;
 import redis.clients.jedis.JedisPoolConfig;
 
-@Configuration
+//@Configuration
 public class JedisConfig {
 
     @Value("${spring.redis.host}")

src/main/java/com/wangzaiplus/test/config/RabbitConfig.java

@@ -14,7 +14,7 @@
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
 
-@Configuration
+//@Configuration
 @Slf4j
 public class RabbitConfig {
 

src/main/java/com/wangzaiplus/test/config/RedissonConfig.java

@@ -7,7 +7,7 @@
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
 
-@Configuration
+//@Configuration
 public class RedissonConfig {
 
     @Value("${spring.redis.host}")

src/main/java/com/wangzaiplus/test/controller/RedissonController.java

@@ -12,7 +12,7 @@
 @RequestMapping("/redisson")
 public class RedissonController {
 
-    @Autowired
+    @Autowired(required = false)
     private RedissonClient redissonClient;
 
     @RequestMapping("testRedisson")

src/main/java/com/wangzaiplus/test/controller/SearchController.java

@@ -0,0 +1,24 @@
+package com.wangzaiplus.test.controller;
+
+import com.google.common.collect.Lists;
+import com.wangzaiplus.test.pojo.User;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.util.List;
+
+@RestController
+@RequestMapping("/search")
+public class SearchController {
+
+    @GetMapping("users")
+    public List<User> users() {
+        User user = new User(1, "beigua", "beigua888");
+        User user2 = new User(2, "beigua2", "beigua888");
+        User user3 = new User(3, "beigua3", "beigua888");
+
+        return Lists.newArrayList(user, user2, user3);
+    }
+
+}

src/main/java/com/wangzaiplus/test/controller/ViewController.java

@@ -0,0 +1,14 @@
+package com.wangzaiplus.test.controller;
+
+import org.springframework.stereotype.Controller;
+import org.springframework.web.bind.annotation.GetMapping;
+
+@Controller
+public class ViewController {
+
+    @GetMapping("home")
+    public String index() {
+        return "index";
+    }
+
+}

src/main/java/com/wangzaiplus/test/designpattern/factory/ALiPay.java

@@ -0,0 +1,11 @@
+package com.wangzaiplus.test.designpattern.factory;
+
+public class ALiPay implements IPay{
+
+    @Override
+    public boolean pay() {
+        // 支付相关逻辑...
+        return true;
+    }
+
+}

src/main/java/com/wangzaiplus/test/designpattern/factory/IPay.java

@@ -0,0 +1,7 @@
+package com.wangzaiplus.test.designpattern.factory;
+
+public interface IPay {
+
+    boolean pay();
+
+}

src/main/java/com/wangzaiplus/test/designpattern/factory/PayTypeEnum.java

@@ -0,0 +1,28 @@
+package com.wangzaiplus.test.designpattern.factory;
+
+/**
+ * 支付方式
+ */
+public enum PayTypeEnum {
+
+    ALI_PAY("1", "支付宝支付"),
+    WE_CHAT_PAY("2", "微信支付"),
+    UNION_PAY("3", "银联支付"),
+    ;
+
+    private String code;
+    private String msg;
+
+    PayTypeEnum(String code, String msg) {
+        this.code = code;
+        this.msg = msg;
+    }
+
+    public String getCode() {
+        return code;
+    }
+
+    public String getMsg() {
+        return msg;
+    }
+}

src/main/java/com/wangzaiplus/test/designpattern/factory/UnionPay.java

@@ -0,0 +1,11 @@
+package com.wangzaiplus.test.designpattern.factory;
+
+public class UnionPay implements IPay{
+
+    @Override
+    public boolean pay() {
+        // 支付相关逻辑...
+        return true;
+    }
+
+}

src/main/java/com/wangzaiplus/test/designpattern/factory/WeChatPay.java

@@ -0,0 +1,11 @@
+package com.wangzaiplus.test.designpattern.factory;
+
+public class WeChatPay implements IPay{
+
+    @Override
+    public boolean pay() {
+        // 支付相关逻辑...
+        return true;
+    }
+
+}

src/main/java/com/wangzaiplus/test/designpattern/factory/factorymethod/AFactory.java

@@ -0,0 +1,12 @@
+package com.wangzaiplus.test.designpattern.factory.factorymethod;
+
+import com.wangzaiplus.test.designpattern.factory.IPay;
+
+public class AFactory implements FactoryMethod {
+
+    @Override
+    public IPay createPay(String payType) {
+        return null;
+    }
+
+}

src/main/java/com/wangzaiplus/test/designpattern/factory/factorymethod/BFactory.java

@@ -0,0 +1,12 @@
+package com.wangzaiplus.test.designpattern.factory.factorymethod;
+
+import com.wangzaiplus.test.designpattern.factory.IPay;
+
+public class BFactory implements FactoryMethod {
+
+    @Override
+    public IPay createPay(String payType) {
+        return null;
+    }
+
+}

src/main/java/com/wangzaiplus/test/designpattern/factory/factorymethod/FactoryMethod.java

@@ -0,0 +1,9 @@
+package com.wangzaiplus.test.designpattern.factory.factorymethod;
+
+import com.wangzaiplus.test.designpattern.factory.IPay;
+
+public interface FactoryMethod {
+
+    IPay createPay(String payType);
+
+}

src/main/java/com/wangzaiplus/test/designpattern/factory/factorymethod/PayService.java

@@ -0,0 +1,13 @@
+package com.wangzaiplus.test.designpattern.factory.factorymethod;
+
+import com.wangzaiplus.test.designpattern.factory.IPay;
+
+public class PayService {
+
+    public void pay(String payType) {
+        FactoryMethod aFactory = new AFactory();
+        IPay pay = aFactory.createPay(payType);
+
+    }
+
+}

src/main/java/com/wangzaiplus/test/designpattern/factory/simplefactory/PayFactory.java

@@ -0,0 +1,23 @@
+package com.wangzaiplus.test.designpattern.factory.simplefactory;
+
+import com.wangzaiplus.test.designpattern.factory.*;
+
+public class PayFactory {
+
+    public static IPay createPay(String payType) {
+        if (PayTypeEnum.ALI_PAY.getCode().equals(payType)) {
+            return new ALiPay();
+        }
+
+        if (PayTypeEnum.WE_CHAT_PAY.getCode().equals(payType)) {
+            return new WeChatPay();
+        }
+
+        if (PayTypeEnum.UNION_PAY.getCode().equals(payType)) {
+            return new UnionPay();
+        }
+
+        return null;
+    }
+
+}

src/main/java/com/wangzaiplus/test/designpattern/factory/simplefactory/PayService.java

@@ -0,0 +1,31 @@
+package com.wangzaiplus.test.designpattern.factory.simplefactory;
+
+import com.wangzaiplus.test.designpattern.factory.IPay;
+import com.wangzaiplus.test.exception.ServiceException;
+import org.apache.commons.lang3.StringUtils;
+
+public class PayService {
+
+    public void pay(String payType) {
+        if (StringUtils.isBlank(payType)) {
+            throw new ServiceException("支付方式异常");
+        }
+
+        boolean isPaySuccess = isPaySuccess(payType);
+        if (isPaySuccess) {
+            // 巴拉巴拉
+        } else {
+            // 巴拉巴拉
+        }
+    }
+
+    private boolean isPaySuccess(String payType) {
+        IPay iPay = PayFactory.createPay(payType);
+        if (null == iPay) {
+            throw new ServiceException("支付方式异常");
+        }
+
+        return iPay.pay();
+    }
+
+}

src/main/java/com/wangzaiplus/test/designpattern/strategy/AliPayStrategy.java

@@ -0,0 +1,13 @@
+package com.wangzaiplus.test.designpattern.strategy;
+
+import org.springframework.stereotype.Component;
+
+@Component
+public class AliPayStrategy implements PayStrategy {
+
+    @Override
+    public void pay(String userId) {
+        System.out.println("AliPayStrategy userId: " + userId);
+    }
+
+}

src/main/java/com/wangzaiplus/test/designpattern/strategy/Main.java

@@ -0,0 +1,12 @@
+package com.wangzaiplus.test.designpattern.strategy;
+
+import com.wangzaiplus.test.designpattern.factory.PayTypeEnum;
+
+public class Main {
+
+    public static void main(String[] args) {
+        PayContext payContext = new PayContext();
+        payContext.pay("3", "aaa");
+    }
+
+}

src/main/java/com/wangzaiplus/test/designpattern/strategy/PayContext.java

@@ -0,0 +1,33 @@
+package com.wangzaiplus.test.designpattern.strategy;
+
+import com.wangzaiplus.test.designpattern.factory.PayTypeEnum;
+import com.wangzaiplus.test.exception.ServiceException;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import java.util.Map;
+import java.util.concurrent.ConcurrentHashMap;
+
+//@Component
+public class PayContext {
+
+//    @Autowired
+//    private Map<String, PayStrategy> map;
+
+    private static Map<String, PayStrategy> map2 = new ConcurrentHashMap<>();
+    static {
+        map2.put(PayTypeEnum.ALI_PAY.getCode(), new AliPayStrategy());
+        map2.put(PayTypeEnum.WE_CHAT_PAY.getCode(), new WxPayStrategy());
+        map2.put(PayTypeEnum.UNION_PAY.getCode(), new UnionPayStrategy());
+    }
+
+    public void pay(String payType, String userId) {
+        PayStrategy payStrategy = map2.get(payType);
+        if (null == payStrategy) {
+            throw new ServiceException("payType: " + payType + " not supported");
+        }
+
+        payStrategy.pay(userId);
+    }
+
+}

src/main/java/com/wangzaiplus/test/designpattern/strategy/PayStrategy.java

@@ -0,0 +1,7 @@
+package com.wangzaiplus.test.designpattern.strategy;
+
+public interface PayStrategy {
+
+    void pay(String userId);
+
+}

src/main/java/com/wangzaiplus/test/designpattern/strategy/UnionPayStrategy.java

@@ -0,0 +1,10 @@
+package com.wangzaiplus.test.designpattern.strategy;
+
+public class UnionPayStrategy implements PayStrategy {
+
+    @Override
+    public void pay(String userId) {
+        System.out.println("UnionPayStrategy userId: " + userId);
+    }
+
+}

src/main/java/com/wangzaiplus/test/designpattern/strategy/WxPayStrategy.java

@@ -0,0 +1,10 @@
+package com.wangzaiplus.test.designpattern.strategy;
+
+public class WxPayStrategy implements PayStrategy {
+
+    @Override
+    public void pay(String userId) {
+        System.out.println("WxPayStrategy userId: " + userId);
+    }
+
+}

src/main/java/com/wangzaiplus/test/mq/consumer/SimpleMailConsumer.java

@@ -17,7 +17,7 @@
 
 import java.io.IOException;
 
-@Component
+//@Component
 @Slf4j
 public class SimpleMailConsumer {
 

src/main/java/com/wangzaiplus/test/mq/listener/LoginLogListener.java

@@ -13,7 +13,7 @@
 
 import java.io.IOException;
 
-@Component
+//@Component
 public class LoginLogListener {
 
     @Autowired

src/main/java/com/wangzaiplus/test/mq/listener/MailListener.java

@@ -13,7 +13,7 @@
 
 import java.io.IOException;
 
-@Component
+//@Component
 public class MailListener {
 
     @Autowired

src/main/java/com/wangzaiplus/test/task/ResendMsg.java

@@ -13,7 +13,7 @@
 
 import java.util.List;
 
-@Component
+//@Component
 @Slf4j
 public class ResendMsg {
 

src/main/java/com/wangzaiplus/test/util/JedisUtil.java

@@ -10,7 +10,7 @@
 @Slf4j
 public class JedisUtil {
 
-    @Autowired
+    @Autowired(required = false)
     private JedisPool jedisPool;
 
     private Jedis getJedis() {