import com.netflix.hystrix.HystrixCommand;
import com.netflix.hystrix.HystrixCommandGroupKey;
import io.jboot.Jboot;
import org.junit.Test;

import static org.junit.Assert.assertEquals;

public class HystrixTest {
 /**
 * 查看监控数据,通过docker来运行hystrix-dashboard
 * docker run --rm -ti -p 7979:7979 kennedyoliveira/hystrix-dashboard
 *
 * 然后访问:http://127.0.0.1:7979/hystrix-dashboard 并填写观测的url
 *
 * @param args
 */
 public static void main(String[] args) {
 Jboot.setBootArg("jboot.hystrix.url", "/hystrix.stream");
 Jboot.run(args);


 while (true) {
 try {
 String hello = new CommandHelloWorld1("World").execute();
 }catch (Throwable ex){}
 }


// while (true){
// String helloString = new HystrixTest().getHello();
// System.out.println(helloString);
// }

 }



 public String getHello(){
 return "hello";
 }




 @Test
 public void testHello() {
 CommandHelloWorld cmd = new CommandHelloWorld("World");
 System.out.println(cmd.execute());

 assertEquals("Hello World!", new CommandHelloWorld("World").execute());
 assertEquals("Hello Bob!", new CommandHelloWorld("Bob").execute());
 }


 public static class CommandHelloWorld extends HystrixCommand<String> {

 private final String name;

 public CommandHelloWorld(String name) {
 super(HystrixCommandGroupKey.Factory.asKey("ExampleGroup"));
 this.name = name;
 }

 @Override
 protected String run() {
 // a real example would do work like a network call here


 return "Hello " + name + "!";
 }
 }

 public static class CommandHelloWorld1 extends HystrixCommand<String> {

 private final String name;

 public CommandHelloWorld1(String name) {
 super(HystrixCommandGroupKey.Factory.asKey("ExampleGroup"));
 this.name = name;
 }

 @Override
 protected String run() {
 // a real example would do work like a network call here
 try {
 Thread.sleep((int) (Math.random() * 10) + 2);
 } catch (InterruptedException e) {
 // do nothing
 }

 /* fail 20% of the time to show how fallback works */
 if (Math.random() > 0.80) {
 throw new RuntimeException("random failure processing UserAccount network response");
 }

 /* latency spike 20% of the time so timeouts can be triggered occasionally */
 if (Math.random() > 0.80) {
 // random latency spike
 try {
 Thread.sleep((int) (Math.random() * 300) + 25);
 } catch (InterruptedException e) {
 // do nothing
 }
 }


 return "Hello " + name + "!";
 }

 }
}