課程的edgeService依賴於課程服務的dubbo服務,對外提供的restAPI,跟用戶的EdgeService有點類似,只是一個調用的是thrift,一個調用的是dubbo,比較特殊的是課程的EdgeService需要用戶登錄後纔可以訪問,如果沒有登錄的話,需要跳轉到登錄系統纔可以訪問。源碼:https://github.com/limingios/msA-docker
<?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>org.springframework.boot</groupId> <artifactId>spring-boot-starter-parent</artifactId> <version>1.5.3.RELEASE</version> </parent> <modelVersion>4.0.0</modelVersion>
<groupId>com.idig8</groupId> <artifactId>course-edge-service</artifactId> <version>1.0-SNAPSHOT</version>
<dependencies> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> <dependency> <groupId>commons-lang</groupId> <artifactId>commons-lang</artifactId> <version>2.6</version> </dependency> <dependency> <groupId>io.dubbo.springboot</groupId> <artifactId>spring-boot-starter-dubbo</artifactId> <version>1.0.0</version> </dependency> <dependency> <groupId>com.idig8</groupId> <artifactId>course-dubbo-service-api</artifactId> <version>1.0-SNAPSHOT</version> </dependency> <dependency> <groupId>com.idig8</groupId> <artifactId>user-edge-service-client</artifactId> <version>1.0-SNAPSHOT</version> </dependency>
</dependencies>
</project>
package com.idig8.course.controller;
import com.alibaba.dubbo.config.annotation.Reference; import com.idig8.course.dto.CourseDTO; import com.idig8.course.service.ICourseService; import com.idig8.thrift.user.dto.UserDTO; import org.springframework.stereotype.Controller; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RequestMethod; import org.springframework.web.bind.annotation.ResponseBody;
import javax.servlet.http.HttpServletRequest; import java.util.List;
/** * Created by Michael on 2017/11/4. */ @Controller @RequestMapping("/course") public class CourseController {
@Reference private ICourseService courseService;
@RequestMapping(value = "/courseList", method = RequestMethod.GET) @ResponseBody public List<CourseDTO> courseList(HttpServletRequest request) {
UserDTO user = (UserDTO)request.getAttribute("user"); System.out.println(user.toString());
return courseService.courseList(); } }
package com.idig8.course.filter;
import com.idig8.thrift.user.dto.UserDTO; import com.idig8.user.client.LoginFilter; import org.springframework.beans.factory.annotation.Value; import org.springframework.stereotype.Component;
import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse;
/** * Created by liming. */ @Component public class CourseFilter extends LoginFilter {
@Value("${user.edge.service.addr}") private String userEdgeServiceAddr;
@Override protected String userEdgeServiceAddr() { return userEdgeServiceAddr; }
@Override protected void login(HttpServletRequest request, HttpServletResponse response, UserDTO userDTO) {
request.setAttribute("user", userDTO); } }
package com.idig8.course;
import com.idig8.course.filter.CourseFilter; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.boot.web.servlet.FilterRegistrationBean; import org.springframework.context.annotation.Bean;
import java.util.ArrayList; import java.util.List;
/** * Created by liming */ @SpringBootApplication public class ServiceApplication {
public static void main(String args[]) { SpringApplication.run(ServiceApplication.class, args); }
@Bean public FilterRegistrationBean filterRegistrationBean(CourseFilter courseFilter ) { FilterRegistrationBean filterRegistrationBean = new FilterRegistrationBean(); filterRegistrationBean.setFilter(courseFilter);
List<String> urlPatterns = new ArrayList<String>(); urlPatterns.add("/*"); filterRegistrationBean.setUrlPatterns(urlPatterns); return filterRegistrationBean; } }
server.port=8081
#dubbo config spring.dubbo.application.name=course-service spring.dubbo.registry.address=zookeeper://47.98.183.16:2181 spring.dubbo.scan=com.idig8.course
user.edge.service.addr=127.0.0.1:8082
PS:微服務跟之前說的一樣就是互相通過RPC的方式進行通信,之間有自己的資料庫,只是RPC暴露介面的方式來獲取其他的微服務之間的數據。