Gradle代码  

1. 'com.netflix.hystrix:hystrix-core:1.3.8',

Java代码  

1. public class AddressHystrixCommand extends HystrixCommand<Address> {
2. private Logger logger = LoggerFactory.getLogger(AddressHystrixCommand.class);
3. private String customerId;
4. public AddressHystrixCommand(String customerId) {
5. super(HystrixCommandGroupKey.Factory.asKey("Address"));
6. this.customerId = customerId;
7. }
8. @Override
9. public Address run() throws Exception {
10. logger.info("Get address for customer {}", customerId);
11. String response = Request.Get("http://localhost:9090/customer/" + customerId + "/address")
12. .connectTimeout(1000)
13. .socketTimeout(1000)
14. .execute()
15. .returnContent()
16. .asString();
17. return new ObjectMapper().readValue(response, Address.class);
18. }
19. }
20. public class ContactHystrixCommand extends HystrixCommand<Contact> {
21. private Logger logger = LoggerFactory.getLogger(ContactHystrixCommand.class);
22. private String customerId;
23. public ContactHystrixCommand(String customerId) {
24. super(HystrixCommandGroupKey.Factory.asKey("Contact"));
25. this.customerId = customerId;
26. }
27. @Override
28. public Contact run() throws Exception {
29. logger.info("Get contact for customer {}", customerId);
30. String response = Request.Get("http://localhost:9090/customer/" + customerId + "/contact")
31. .connectTimeout(1000)
32. .socketTimeout(1000)
33. .execute()
34. .returnContent()
35. .asString();
36. return new ObjectMapper().readValue(response, Contact.class);
37. }
38. }

Java代码  

1. customer.setContact(new ContactHystrixCommand(customerId).execute());
2. customer.setAddress(new AddressHystrixCommand(customerId).execute());

Java代码  

1. public class EchoCommand extends HystrixCommand<String> {
2. private String input;
3. protected EchoCommand(String input) {
4. super(Setter.withGroupKey(HystrixCommandGroupKey.Factory.asKey("EchoGroup"))
5. .andCommandKey(HystrixCommandKey.Factory.asKey("Echo"))
6. .andThreadPoolKey(HystrixThreadPoolKey.Factory.asKey("EchoThreadPool"))
7. .andCommandPropertiesDefaults(HystrixCommandProperties.Setter()
8. .withExecutionIsolationStrategy(HystrixCommandProperties.ExecutionIsolationStrategy.THREAD))
9. .andThreadPoolPropertiesDefaults(HystrixThreadPoolProperties.Setter()
10. .withCoreSize(10))
11. );
12. this.input = input;
13. }
14. @Override
15. protected String run() throws Exception {
16. return "Echo: " + input;
17. }
18. }

http://ningandjiao.iteye.com/blog/2171185