《Spring Cloud实战》示例更新

Author: dyc87112

README.md

@@ -30,6 +30,7 @@
 ### 《Spring Cloud源码分析》系列博文
 
 - [Spring Cloud源码分析（一）Eureka](http://blog.didispace.com/springcloud-sourcecode-eureka/)
+- [Spring Cloud源码分析（二）Ribbon](http://blog.didispace.com/springcloud-sourcecode-ribbon/)
 
 ### 《Spring Cloud实战》配套示例
 

spring_cloud_in_action/api-gateway-consul/pom.xml

@@ -0,0 +1,61 @@
+<?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">
+	<modelVersion>4.0.0</modelVersion>
+
+	<groupId>com.didispace</groupId>
+	<artifactId>api-gateway-consul</artifactId>
+	<version>1.0.0</version>
+	<packaging>jar</packaging>
+
+	<name>api-gateway-consul</name>
+	<description>Spring Cloud project</description>
+
+	<parent>
+		<groupId>org.springframework.boot</groupId>
+		<artifactId>spring-boot-starter-parent</artifactId>
+		<version>1.3.7.RELEASE</version>
+		<relativePath/> <!-- lookup parent from repository -->
+	</parent>
+
+	<properties>
+		<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+		<java.version>1.8</java.version>
+	</properties>
+
+	<dependencies>
+
+		<dependency>
+			<groupId>org.springframework.cloud</groupId>
+			<artifactId>spring-cloud-starter-zuul</artifactId>
+		</dependency>
+
+		<dependency>
+			<groupId>org.springframework.cloud</groupId>
+			<artifactId>spring-cloud-starter-consul-all</artifactId>
+		</dependency>
+
+	</dependencies>
+
+	<dependencyManagement>
+		<dependencies>
+			<dependency>
+				<groupId>org.springframework.cloud</groupId>
+				<artifactId>spring-cloud-dependencies</artifactId>
+				<version>Brixton.SR5</version>
+				<type>pom</type>
+				<scope>import</scope>
+			</dependency>
+		</dependencies>
+	</dependencyManagement>
+	
+	<build>
+		<plugins>
+			<plugin>
+				<groupId>org.springframework.boot</groupId>
+				<artifactId>spring-boot-maven-plugin</artifactId>
+			</plugin>
+		</plugins>
+	</build>
+
+</project>

spring_cloud_in_action/api-gateway-consul/src/main/java/com/didispace/Application.java

@@ -0,0 +1,22 @@
+package com.didispace;
+
+import com.didispace.filter.AccessFilter;
+import org.springframework.boot.builder.SpringApplicationBuilder;
+import org.springframework.cloud.client.SpringCloudApplication;
+import org.springframework.cloud.netflix.zuul.EnableZuulProxy;
+import org.springframework.context.annotation.Bean;
+
+@EnableZuulProxy
+@SpringCloudApplication
+public class Application {
+
+	public static void main(String[] args) {
+		new SpringApplicationBuilder(Application.class).web(true).run(args);
+	}
+
+//	@Bean
+//	public AccessFilter accessFilter() {
+//		return new AccessFilter();
+//	}
+
+}

spring_cloud_in_action/api-gateway-consul/src/main/java/com/didispace/filter/AccessFilter.java

@@ -0,0 +1,49 @@
+package com.didispace.filter;
+
+import com.netflix.loadbalancer.IPing;
+import com.netflix.zuul.ZuulFilter;
+import com.netflix.zuul.context.RequestContext;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.context.annotation.Bean;
+
+import javax.servlet.http.HttpServletRequest;
+
+public class AccessFilter extends ZuulFilter  {
+
+    private static Logger log = LoggerFactory.getLogger(AccessFilter.class);
+
+    @Override
+    public String filterType() {
+        return "pre";
+    }
+
+    @Override
+    public int filterOrder() {
+        return 0;
+    }
+
+    @Override
+    public boolean shouldFilter() {
+        return true;
+    }
+
+    @Override
+    public Object run() {
+        RequestContext ctx = RequestContext.getCurrentContext();
+        HttpServletRequest request = ctx.getRequest();
+
+        log.info(String.format("%s request to %s", request.getMethod(), request.getRequestURL().toString()));
+
+        Object accessToken = request.getParameter("accessToken");
+        if(accessToken == null) {
+            log.warn("access token is empty");
+            ctx.setSendZuulResponse(false);
+            ctx.setResponseStatusCode(401);
+            return null;
+        }
+        log.info("access token ok");
+        return null;
+    }
+
+}

spring_cloud_in_action/api-gateway-consul/src/main/resources/application.properties

@@ -0,0 +1,13 @@
+spring.application.name=api-gateway-consul
+server.port=5555
+
+# routes to serviceId
+zuul.routes.api-a.path=/consul/**
+zuul.routes.api-a.serviceId=consul-client-1
+
+# routes to url
+zuul.routes.api-a-url.path=/api-a-url/**
+zuul.routes.api-a-url.url=http://localhost:8080/
+
+spring.cloud.consul.host=localhost
+spring.cloud.consul.port=8500

spring_cloud_in_action/api-gateway/pom.xml

@@ -34,7 +34,6 @@
 			<groupId>org.springframework.cloud</groupId>
 			<artifactId>spring-cloud-starter-eureka</artifactId>
 		</dependency>
-
 	</dependencies>
 
 	<dependencyManagement>

spring_cloud_in_action/api-gateway/src/main/java/com/didispace/Application.java

@@ -4,6 +4,7 @@
 import org.springframework.boot.builder.SpringApplicationBuilder;
 import org.springframework.cloud.client.SpringCloudApplication;
 import org.springframework.cloud.netflix.zuul.EnableZuulProxy;
+import org.springframework.cloud.netflix.zuul.filters.discovery.PatternServiceRouteMapper;
 import org.springframework.context.annotation.Bean;
 
 @EnableZuulProxy
@@ -19,4 +20,11 @@ public AccessFilter accessFilter() {
 		return new AccessFilter();
 	}
 
+	@Bean
+	public PatternServiceRouteMapper serviceRouteMapper() {
+		return new PatternServiceRouteMapper(
+				"(?<name>^.+)-(?<version>v.+$)",
+				"${version}/${name}");
+	}
+
 }

spring_cloud_in_action/api-gateway/src/main/java/com/didispace/HelloController.java

@@ -0,0 +1,15 @@
+package com.didispace;
+
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+
+@RestController
+public class HelloController {
+
+    @RequestMapping("/local/hello")
+    public String hello() {
+        return "Hello World Local";
+    }
+
+}

spring_cloud_in_action/api-gateway/src/main/java/com/didispace/filter/AccessFilter.java

@@ -31,7 +31,7 @@ public Object run() {
         RequestContext ctx = RequestContext.getCurrentContext();
         HttpServletRequest request = ctx.getRequest();
 
-        log.info(String.format("%s request to %s", request.getMethod(), request.getRequestURL().toString()));
+        log.info("send {} request to {}", request.getMethod(), request.getRequestURL().toString());
 
         Object accessToken = request.getParameter("accessToken");
         if(accessToken == null) {

spring_cloud_in_action/api-gateway/src/main/java/com/didispace/filter/ErrorFilter.java

@@ -0,0 +1,44 @@
+package com.didispace.filter;
+
+import com.netflix.zuul.ZuulFilter;
+import com.netflix.zuul.context.RequestContext;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.stereotype.Component;
+
+import javax.servlet.http.HttpServletResponse;
+
+/**
+ * 捕获为处理的异常统一做一些处理，让`SendErrorFilter`可以正确的返回异常信息
+ */
+//@Component
+public class ErrorFilter extends ZuulFilter {
+
+    Logger log = LoggerFactory.getLogger(ErrorFilter.class);
+
+    @Override
+    public String filterType() {
+        return "error";
+    }
+
+    @Override
+    public int filterOrder() {
+        return 10;
+    }
+
+    @Override
+    public boolean shouldFilter() {
+        return true;
+    }
+
+    @Override
+    public Object run() {
+        RequestContext ctx = RequestContext.getCurrentContext();
+        Throwable throwable = RequestContext.getCurrentContext().getThrowable();
+        log.error("this is a ErrorFilter : {}", throwable.getCause().getMessage());
+        ctx.set("error.status_code", HttpServletResponse.SC_INTERNAL_SERVER_ERROR);
+        ctx.set("error.exception", throwable.getCause());
+        return null;
+    }
+
+}

spring_cloud_in_action/api-gateway/src/main/java/com/didispace/filter/ThrowExceptionFilter.java

@@ -0,0 +1,49 @@
+package com.didispace.filter;
+
+import com.netflix.zuul.ZuulFilter;
+import com.netflix.zuul.context.RequestContext;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.stereotype.Component;
+
+import javax.servlet.http.HttpServletResponse;
+
+@Component
+public class ThrowExceptionFilter extends ZuulFilter  {
+
+    private static Logger log = LoggerFactory.getLogger(ThrowExceptionFilter.class);
+
+    @Override
+    public String filterType() {
+        return "pre";
+    }
+
+    @Override
+    public int filterOrder() {
+        return 0;
+    }
+
+    @Override
+    public boolean shouldFilter() {
+        return true;
+    }
+
+    @Override
+    public Object run() {
+        log.info("This is a pre filter, it will throw a RuntimeException");
+        RequestContext ctx = RequestContext.getCurrentContext();
+        try {
+            doSomething();
+        } catch (Exception e) {
+            ctx.set("error.status_code", HttpServletResponse.SC_INTERNAL_SERVER_ERROR);
+            ctx.set("error.exception", e);
+//            ctx.set("error.message", "有一些错误发生");
+        }
+        return null;
+    }
+
+    private void doSomething() {
+        throw new RuntimeException("Exist some errors...");
+    }
+
+}

spring_cloud_in_action/api-gateway/src/main/resources/application.properties

@@ -1,15 +1,75 @@
 spring.application.name=api-gateway
 server.port=5555
 
+# eureka
+eureka.client.serviceUrl.defaultZone=http://localhost:1111/eureka/
+
+# routes to url
+zuul.routes.api-a-url.path=/api-a-url/**
+zuul.routes.api-a-url.url=http://localhost:8001/
+
+# ribbon with out eureka
+#zuul.routes.api-d.path=/ddd/**
+#zuul.routes.api-d.serviceId=hello
+#ribbon.eureka.enabled=false
+#hello.ribbon.listOfServers=http://localhost:8001/,http://localhost:8002/
+
 # routes to serviceId
-zuul.routes.api-a.path=/api-a/**
+zuul.routes.api-a.path=/api/a/**
 zuul.routes.api-a.serviceId=hello-service
 
 zuul.routes.api-b.path=/api-b/**
-zuul.routes.api-b.serviceId=feign-consumer
+zuul.routes.api-b.serviceId=hello-service
+#zuul.routes.api-b.strip-prefix=true
 
-# routes to url
-zuul.routes.api-a-url.path=/api-a-url/**
-zuul.routes.api-a-url.url=http://localhost:8080/
+zuul.routes.api-c.path=/ddd/**
+zuul.routes.api-c.serviceId=hello-service
+
+#zuul.routes.api-d.path=/ddd/hello
+#zuul.routes.api-d.serviceId=hello-service2
+
+# routes to serviceId£¬'hello-service' is service-name, value is path
+#zuul.routes.hello-service=/eee/**
+
+# routes to local forward
+zuul.routes.api-b-url.path=/api-b-url/**
+zuul.routes.api-b-url.url=forward:/local
+
+# route connection
+zuul.host.max-per-route-connections=20
+zuul.host.max-total-connections=200
+
+# grobal prefix
+#zuul.prefix=/api
+
+# grobal strip prefix, default is true(but it has some bugs, when routes path contains zuul.prefix's value)
+#zuul.strip-prefix=false
+
+# router strip prefix
+#zuul.routes.api-b.strip-prefix=false
+
+# Set of service names not to consider for proxying automatically.
+# By default all services in the discovery client will be proxied.
+# For example, set zuul.ignored-services=*, then only routes configed by zuul.routes.* will be proxied.
+# And default service proxy will disabled.
+#zuul.ignored-services=*
+
+# ignored path;
+# o.s.c.n.z.f.pre.PreDecorationFilter      : No route found for uri: /xxx/yyy/zzz
+#zuul.ignored-patterns=/**/hello/**
+
+# timeout setting
+#ribbon.ConnectTimeout=3000
+#ribbon.ReadTimeout=1000
+
+# fileupload setting
+#hystrix.command.default.execution.isolation.thread.timeoutInMilliseconds=60000
+#ribbon.ConnectTimeout=3000
+#ribbon.ReadTimeout=60000
+
+# Disable Zuul Filters
+# zuul.<SimpleClassName>.<filterType>.disable=true
+zuul.AccessFilter.pre.disable=true
 
-eureka.client.serviceUrl.defaultZone=http://localhost:1111/eureka/
+# ZuulServlet path
+#zuul.servlet-path=/zuul