Hystrix研究-demo01

 

1、创建工程

2、引入Hystrix依赖

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <parent>
        <artifactId>youfanshop</artifactId>
        <groupId>com.youfan</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <artifactId>hystrixTest</artifactId>

    <dependencies>
        <dependency>
            <groupId>com.netflix.hystrix</groupId>
            <artifactId>hystrix-core</artifactId>
            <version>1.5.12</version>
        </dependency>
    </dependencies>


    <!-- *库：引入hystrix等-->
    <repository>
        <id>nexus</id>
        <name>local private nexus</name>
        <url>http://search.maven.org</url>
        <releases>
            <enabled>true</enabled>
        </releases>
        <snapshots>
            <enabled>false</enabled>
        </snapshots>
    </repository>

</project>

3、Hystrix例子

import java.util.concurrent.Future;
import java.util.concurrent.TimeUnit;

import com.netflix.hystrix.HystrixCommand;
import com.netflix.hystrix.HystrixCommandGroupKey;
/**
 * 入门
*
 */
public class CommandHelloWorld extends HystrixCommand<String> {
	
	private final String name;

	protected CommandHelloWorld(String name) {
		//最少配置:指定命令组名
		super(HystrixCommandGroupKey.Factory.asKey("ExampleGroup"));
		this.name = name;
	}
	
	@Override
	protected String run() throws Exception {
		//a real example would do work like a network call here
		//依赖逻辑封装在run()方法中
		return "Hello " + name + "! thread: " + Thread.currentThread().getName();
	}
	
	
	public static void main(String[] args) throws Exception{
		/**
		 * 每个Command对象只能调用一次,不可以重复调用
		 * 重复调用对应的异常信息：This instance can only be executed once.
		 * Please instantiate a new instance
		 */
		CommandHelloWorld commandHelloWorld = new CommandHelloWorld("Synchronous-hystrix");
		//使用execute()同步调用代码,效果等同于:commandHelloWorld.queue().get();
		String s = commandHelloWorld.execute();
		System.out.println(" 同步 ====== " + s);
		
		//异步调用,可以*控制获取结果的时机
		commandHelloWorld = new CommandHelloWorld("Asynchronous-hystrix");
		Future<String> future = commandHelloWorld.queue();
		//get()操作不能超过command定义的超时时间,默认为1秒
		s = future.get(100, TimeUnit.MILLISECONDS);
		System.out.println(" 异步 ====== " + s);
		
		
		System.out.println(" 主函数 ===== " + Thread.currentThread().getName());
		/**
		 * 注意：
		 * 异步调用使用 command.queue()get(timeout, TimeUnit.MILLISECONDS);
		 * 同步调用使用command.execute() 等同于 command.queue().get();
		 */
	}

}

说明：

    1）定义一个类，继承HystrixCommand<String>；

    2）使用execute()同步调用代码,效果等同于:commandHelloWorld.queue().get()；

    3）异步调用,可以*控制获取结果的时机；

    4）get()操作不能超过command定义的超时时间,默认为1秒；

 

 

4、结果输出

 同步 ====== Hello Synchronous-hystrix! thread: hystrix-ExampleGroup-1
 异步 ====== Hello Asynchronous-hystrix! thread: hystrix-ExampleGroup-2
 主函数 ===== main