init

Author: SoftwareKing

.gitignore

@@ -1,22 +1,86 @@
-# Compiled class file
-*.class
+# mac
+*.DS_Store
+# Output Directory
+bin/
+target/
+tmp/
 
-# Log file
-*.log
+# C pre-compile
+*.gch
+*.pch
+
+# C compile
+*.a
+*.o
+*.ko
+*.la
+*.lo
+*.obj
+*.elf
+*.so
+*.so.*
+*.dylib
+*.exe
+*.lib
+*.dll
+*.out
+*.app
+*.hex
 
-# BlueJ files
-*.ctxt
+# Debug files
+*.dSYM/
 
-# Mobile Tools for Java (J2ME)
-.mtj.tmp/
+# Java
+*.class
 
-# Package Files #
+# Java Package Files
 *.jar
 *.war
 *.ear
-*.zip
-*.tar.gz
-*.rar
 
 # virtual machine crash logs, see http://www.java.com/en/download/help/error_hotspot.xml
 hs_err_pid*
+
+# Zip Files
+*.rar
+*.zip
+*.7z
+*.tar
+*.gz
+
+# Ant
+#build/
+
+# Compiled Python
+__pycache__/
+*.py[cod]
+*py.class
+
+# Eclipse
+.settings/
+.classpath
+.project
+
+
+# IntelliJ, based on http://devnet.jetbrains.net/docs/DOC-1186
+.idea/
+*.iml
+
+
+# logs and trace
+*.log
+*.trace
+*.dat
+
+# vi swap
+*.swp
+
+# Backup Files
+*.bak
+*.old
+
+# SVN metadata
+.svn/
+
+logs/
+

LICENSE

@@ -1,2 +1,26 @@
-# spring-cloud-code
-《重新定义Spring Cloud实战》实体书对应源码
+基于Spring Cloud的F版:
+http://cloud.spring.io/spring-cloud-static/Finchley.RELEASE/single/spring-cloud.html
+
+## 1.工程规范
+
+* xxx-zuul-server  Zuul Server
+* xxx-eureka-server  Eureka Server
+* xxx-config-server   Spring Cloud Config Server
+* xxx-service-provider 服务提供者
+* xxx-service-consumer 服务消费者
+* xxx-config-client  
+
+## 2.包名规范
+ * 基础包名:cn.springcloud.book
+ * `<url>http://maven.apache.org</url>`统一修改为`<url>http://springcloud.cn</url>`
+
+## 3.开发者
+* 许进(http://xujin.org)
+* 钟尊发(http://zhongzunfa.com)
+* 叶志远(http://blog.csdn.net/rickiyeat)
+* 方志鹏(http://blog.csdn.net/forezp)
+* 谭朝红
+
+
+
+

README.md

@@ -0,0 +1,35 @@
+<?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>
+    	<groupId>cn.springcloud.book</groupId>
+        <artifactId>ch10-1</artifactId>
+        <version>0.0.1-SNAPSHOT</version>
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+    <name>ch10-1-common</name>
+    <artifactId>ch10-1-common</artifactId>
+
+    <dependencies>
+		<dependency>
+            <groupId>org.springframework.cloud</groupId>
+            <artifactId>spring-cloud-starter-openfeign</artifactId>
+        </dependency>
+        <dependency>
+		    <groupId>com.alibaba</groupId>
+		    <artifactId>fastjson</artifactId>
+		    <version>1.2.4</version>
+		</dependency>
+    </dependencies>
+
+    <build>
+        <plugins>
+            <plugin>
+                <groupId>org.springframework.boot</groupId>
+                <artifactId>spring-boot-maven-plugin</artifactId>
+            </plugin>
+        </plugins>
+    </build>
+
+</project>

ch10-1/ch10-1-common/pom.xml

@@ -0,0 +1,63 @@
+package cn.springcloud.book.common.config;
+
+import feign.Feign;
+
+import javax.annotation.PostConstruct;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnClass;
+import org.springframework.cloud.client.loadbalancer.LoadBalanced;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.web.client.RestTemplate;
+import org.springframework.web.servlet.config.annotation.EnableWebMvc;
+import org.springframework.web.servlet.config.annotation.InterceptorRegistry;
+import org.springframework.web.servlet.config.annotation.WebMvcConfigurerAdapter;
+import org.springframework.web.servlet.mvc.Controller;
+
+import com.netflix.hystrix.strategy.HystrixPlugins;
+import com.netflix.hystrix.strategy.concurrency.HystrixConcurrencyStrategy;
+
+import cn.springcloud.book.common.context.SpringCloudHystrixConcurrencyStrategy;
+import cn.springcloud.book.common.intercepter.FeignUserContextInterceptor;
+import cn.springcloud.book.common.intercepter.RestTemplateUserContextInterceptor;
+import cn.springcloud.book.common.intercepter.UserContextInterceptor;
+
+@Configuration
+@EnableWebMvc
+public class CommonConfiguration extends WebMvcConfigurerAdapter{
+	/**
+	 * 请求拦截器
+	 */
+	@Override
+    public void addInterceptors(InterceptorRegistry registry) {
+        registry.addInterceptor(new UserContextInterceptor());
+    }
+	
+    /**
+     * 创建Feign请求拦截器，在发送请求前设置认证的用户上下文信息
+     */
+    @Bean
+    @ConditionalOnClass(Feign.class)
+    public FeignUserContextInterceptor feignTokenInterceptor() {
+        return new FeignUserContextInterceptor();
+    }
+
+    /**
+     * RestTemplate拦截器
+     * @return
+     */
+    @LoadBalanced
+    @Bean
+    public RestTemplate restTemplate() {
+        RestTemplate restTemplate = new RestTemplate();
+        restTemplate.getInterceptors().add(new RestTemplateUserContextInterceptor());
+        return restTemplate;
+    }
+    
+    @Bean
+	public SpringCloudHystrixConcurrencyStrategy springCloudHystrixConcurrencyStrategy() {
+		return new SpringCloudHystrixConcurrencyStrategy();
+	}
+   
+}

ch10-1/ch10-1-common/src/main/java/cn/springcloud/book/common/config/CommonConfiguration.java

@@ -0,0 +1,30 @@
+package cn.springcloud.book.common.context;
+import java.util.concurrent.Callable;
+
+import org.springframework.web.context.request.RequestAttributes;
+import org.springframework.web.context.request.RequestContextHolder;
+
+public class HystrixThreadCallable<S> implements Callable<S>{
+	 private final RequestAttributes requestAttributes;  
+	 private final Callable<S> delegate;
+	 private String params;
+	  
+     public HystrixThreadCallable(Callable<S> callable, RequestAttributes requestAttributes,String params) {  
+         this.delegate = callable; 
+         this.requestAttributes = requestAttributes;  
+         this.params = params;
+     }
+
+     @Override  
+     public S call() throws Exception {  
+         try {
+             RequestContextHolder.setRequestAttributes(requestAttributes);
+             HystrixThreadLocal.threadLocal.set(params);
+             return delegate.call();  
+         } finally {
+             RequestContextHolder.resetRequestAttributes();
+             HystrixThreadLocal.threadLocal.remove();
+         }  
+     }  
+       
+}

ch10-1/ch10-1-common/src/main/java/cn/springcloud/book/common/context/HystrixThreadCallable.java

@@ -0,0 +1,5 @@
+package cn.springcloud.book.common.context;
+
+public class HystrixThreadLocal {
+    public static ThreadLocal<String> threadLocal = new ThreadLocal<>();
+}

ch10-1/ch10-1-common/src/main/java/cn/springcloud/book/common/context/HystrixThreadLocal.java

@@ -0,0 +1,86 @@
+package cn.springcloud.book.common.context;
+
+import java.util.concurrent.BlockingQueue;
+import java.util.concurrent.Callable;
+import java.util.concurrent.ThreadPoolExecutor;
+import java.util.concurrent.TimeUnit;
+
+import org.springframework.web.context.request.RequestContextHolder;
+
+import com.netflix.hystrix.HystrixThreadPoolKey;
+import com.netflix.hystrix.HystrixThreadPoolProperties;
+import com.netflix.hystrix.strategy.HystrixPlugins;
+import com.netflix.hystrix.strategy.concurrency.HystrixConcurrencyStrategy;
+import com.netflix.hystrix.strategy.concurrency.HystrixRequestVariable;
+import com.netflix.hystrix.strategy.concurrency.HystrixRequestVariableLifecycle;
+import com.netflix.hystrix.strategy.eventnotifier.HystrixEventNotifier;
+import com.netflix.hystrix.strategy.executionhook.HystrixCommandExecutionHook;
+import com.netflix.hystrix.strategy.metrics.HystrixMetricsPublisher;
+import com.netflix.hystrix.strategy.properties.HystrixPropertiesStrategy;
+import com.netflix.hystrix.strategy.properties.HystrixProperty;
+
+public class SpringCloudHystrixConcurrencyStrategy extends HystrixConcurrencyStrategy {
+    private HystrixConcurrencyStrategy delegateHystrixConcurrencyStrategy;
+    
+    @Override
+    public <T> Callable<T> wrapCallable(Callable<T> callable) {
+        return new HystrixThreadCallable<>(callable, RequestContextHolder.getRequestAttributes(),HystrixThreadLocal.threadLocal.get());
+    }
+    
+    public SpringCloudHystrixConcurrencyStrategy() {
+    	init();
+    }
+    
+    private void init() {
+   	 try {
+            this.delegateHystrixConcurrencyStrategy = HystrixPlugins.getInstance().getConcurrencyStrategy();
+            if (this.delegateHystrixConcurrencyStrategy instanceof SpringCloudHystrixConcurrencyStrategy) {
+                return;
+            }
+
+            HystrixCommandExecutionHook commandExecutionHook = HystrixPlugins.getInstance().getCommandExecutionHook();
+            HystrixEventNotifier eventNotifier = HystrixPlugins.getInstance().getEventNotifier();
+            HystrixMetricsPublisher metricsPublisher = HystrixPlugins.getInstance().getMetricsPublisher();
+            HystrixPropertiesStrategy propertiesStrategy = HystrixPlugins.getInstance().getPropertiesStrategy();
+
+            HystrixPlugins.reset();
+            HystrixPlugins.getInstance().registerConcurrencyStrategy(this);
+            HystrixPlugins.getInstance().registerCommandExecutionHook(commandExecutionHook);
+            HystrixPlugins.getInstance().registerEventNotifier(eventNotifier);
+            HystrixPlugins.getInstance().registerMetricsPublisher(metricsPublisher);
+            HystrixPlugins.getInstance().registerPropertiesStrategy(propertiesStrategy);
+        }
+        catch (Exception e) {
+            throw e;
+        }
+   }
+    
+    
+    @Override
+	public ThreadPoolExecutor getThreadPool(HystrixThreadPoolKey threadPoolKey,
+			HystrixProperty<Integer> corePoolSize,
+			HystrixProperty<Integer> maximumPoolSize,
+			HystrixProperty<Integer> keepAliveTime, TimeUnit unit,
+			BlockingQueue<Runnable> workQueue) {
+		return this.delegateHystrixConcurrencyStrategy.getThreadPool(threadPoolKey, corePoolSize, maximumPoolSize,
+				keepAliveTime, unit, workQueue);
+	}
+
+	@Override
+	public ThreadPoolExecutor getThreadPool(HystrixThreadPoolKey threadPoolKey,
+			HystrixThreadPoolProperties threadPoolProperties) {
+		return this.delegateHystrixConcurrencyStrategy.getThreadPool(threadPoolKey, threadPoolProperties);
+	}
+
+	@Override
+	public BlockingQueue<Runnable> getBlockingQueue(int maxQueueSize) {
+		return this.delegateHystrixConcurrencyStrategy.getBlockingQueue(maxQueueSize);
+	}
+
+	@Override
+	public <T> HystrixRequestVariable<T> getRequestVariable(
+			HystrixRequestVariableLifecycle<T> rv) {
+		return this.delegateHystrixConcurrencyStrategy.getRequestVariable(rv);
+	}
+
+}