✨ Introducing new features. Hystrix

Author: crossoverJie

pom.xml

@@ -95,6 +95,12 @@
             <version>1.1.40</version>
         </dependency>
 
+        <dependency>
+            <groupId>com.netflix.hystrix</groupId>
+            <artifactId>hystrix-core</artifactId>
+            <version>1.5.2</version>
+        </dependency>
+
     </dependencies>
 
     <build>

src/main/java/com/crossoverjie/hystrix/CommandOrder.java

@@ -0,0 +1,57 @@
+package com.crossoverjie.hystrix;
+
+import com.netflix.hystrix.*;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.util.concurrent.TimeUnit;
+
+/**
+ * Function:订单服务
+ *
+ * @author crossoverJie
+ *         Date: 2018/7/28 16:43
+ * @since JDK 1.8
+ */
+public class CommandOrder extends HystrixCommand<String> {
+
+    private final static Logger LOGGER = LoggerFactory.getLogger(CommandOrder.class);
+
+    private String orderName;
+
+    public CommandOrder(String orderName) {
+
+
+        super(Setter.withGroupKey(
+                //服务分组
+                HystrixCommandGroupKey.Factory.asKey("OrderGroup"))
+                //线程分组
+                .andThreadPoolKey(HystrixThreadPoolKey.Factory.asKey("OrderPool"))
+
+                //线程池配置
+                .andThreadPoolPropertiesDefaults(HystrixThreadPoolProperties.Setter()
+                        .withCoreSize(10)
+                        .withKeepAliveTimeMinutes(5)
+                        .withMaxQueueSize(10)
+                        .withQueueSizeRejectionThreshold(10000))
+
+                .andCommandPropertiesDefaults(
+                        HystrixCommandProperties.Setter()
+                                .withExecutionIsolationStrategy(HystrixCommandProperties.ExecutionIsolationStrategy.THREAD))
+        )
+        ;
+        this.orderName = orderName;
+    }
+
+
+    @Override
+    public String run() throws Exception {
+
+        LOGGER.info("orderName=[{}]", orderName);
+
+        TimeUnit.MILLISECONDS.sleep(100);
+        return "OrderName=" + orderName;
+    }
+
+
+}

src/main/java/com/crossoverjie/hystrix/CommandTest.java

@@ -0,0 +1,40 @@
+package com.crossoverjie.hystrix;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.util.concurrent.Future;
+import java.util.concurrent.TimeUnit;
+
+/**
+ * Function: 线程隔离测试
+ *
+ * @author crossoverJie
+ *         Date: 2018/7/28 16:58
+ * @since JDK 1.8
+ */
+public class CommandTest {
+
+    private final static Logger LOGGER = LoggerFactory.getLogger(CommandTest.class);
+
+
+    public static void main(String[] args) throws Exception {
+        CommandOrder commandPhone = new CommandOrder("手机");
+        CommandOrder command = new CommandOrder("电视");
+
+
+        //阻塞方式执行
+        String execute = commandPhone.execute();
+        LOGGER.info("execute=[{}]", execute);
+
+        //异步非阻塞方式
+        Future<String> queue = command.queue();
+        String value = queue.get(200, TimeUnit.MILLISECONDS);
+        LOGGER.info("value=[{}]", value);
+
+
+        CommandUser commandUser = new CommandUser("张三");
+        String name = commandUser.execute();
+        LOGGER.info("name=[{}]", name);
+    }
+}

src/main/java/com/crossoverjie/hystrix/CommandUser.java

@@ -0,0 +1,58 @@
+package com.crossoverjie.hystrix;
+
+import com.netflix.hystrix.*;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.util.concurrent.TimeUnit;
+
+/**
+ * Function:用户服务
+ *
+ * @author crossoverJie
+ *         Date: 2018/7/28 16:43
+ * @since JDK 1.8
+ */
+public class CommandUser extends HystrixCommand<String> {
+
+    private final static Logger LOGGER = LoggerFactory.getLogger(CommandUser.class);
+
+    private String userName;
+
+    public CommandUser(String userName) {
+
+
+        super(Setter.withGroupKey(
+                //服务分组
+                HystrixCommandGroupKey.Factory.asKey("UserGroup"))
+                //线程分组
+                .andThreadPoolKey(HystrixThreadPoolKey.Factory.asKey("UserPool"))
+
+                //线程池配置
+                .andThreadPoolPropertiesDefaults(HystrixThreadPoolProperties.Setter()
+                        .withCoreSize(10)
+                        .withKeepAliveTimeMinutes(5)
+                        .withMaxQueueSize(10)
+                        .withQueueSizeRejectionThreshold(10000))
+
+                //线程池隔离
+                .andCommandPropertiesDefaults(
+                        HystrixCommandProperties.Setter()
+                                .withExecutionIsolationStrategy(HystrixCommandProperties.ExecutionIsolationStrategy.THREAD))
+        )
+        ;
+        this.userName = userName;
+    }
+
+
+    @Override
+    public String run() throws Exception {
+
+        LOGGER.info("userName=[{}]", userName);
+
+        TimeUnit.MILLISECONDS.sleep(100);
+        return "userName=" + userName;
+    }
+
+
+}