1.生产者(没有什么特殊性)
pom.xml
<?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.example</groupId> <artifactId>cloud-provider</artifactId> <version>0.0.1-SNAPSHOT</version> <packaging>jar</packaging> <name>cloud-provider</name> <description>Demo project for Spring Boot</description> <parent> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-parent</artifactId> <version>2.0.6.RELEASE</version> <relativePath/> <!-- lookup parent from repository --> </parent> <properties> <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding> <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding> <java.version>1.8</java.version> <spring-cloud.version>Finchley.SR2</spring-cloud.version> </properties> <dependencies> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> <dependency> <groupId>org.mybatis.spring.boot</groupId> <artifactId>mybatis-spring-boot-starter</artifactId> <version>1.3.2</version> </dependency> <!--Service Discovery with Zookeeper--> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-zookeeper-discovery</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-devtools</artifactId> <scope>runtime</scope> </dependency> <dependency> <groupId>mysql</groupId> <artifactId>mysql-connector-java</artifactId> </dependency> <dependency> <groupId>org.projectlombok</groupId> <artifactId>lombok</artifactId> <optional>true</optional> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-test</artifactId> <scope>test</scope> </dependency> </dependencies> <dependencyManagement> <dependencies> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-dependencies</artifactId> <version>${spring-cloud.version}</version> <type>pom</type> <scope>import</scope> </dependency> </dependencies> </dependencyManagement> <build> <plugins> <plugin> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-maven-plugin</artifactId> <configuration> <fork>true</fork> </configuration> </plugin> </plugins> </build></project>
application.yml
spring: datasource: driver-class-name: com.mysql.jdbc.Driver url: jdbc:mysql:///testdb?useSSL=true username: root password: 123 cloud: zookeeper: connect-string: 192.168.3.201:2181 application: name: providermybatis: configuration: map-underscore-to-camel-case: true mapper-locations: classpath:mapper/*Mapper.xmllogging: level: com.example.cloudprovider.mapper: debug
实体类
package com.example.cloudprovider.domain;import lombok.Getter;import lombok.Setter;import java.util.Date;@Setter@Getterpublic class UserInfo { private Integer userId; private String userName; private int userAge; private Date userBirth;}
Mapper
package com.example.cloudprovider.mapper;import com.example.cloudprovider.domain.UserInfo;public interface UserInfoMapper { UserInfo getUser(Integer userId);}
Mapper.xml
<?xml version="1.0" encoding="UTF-8" ?><!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd"><mapper namespace="com.example.cloudprovider.mapper.UserInfoMapper"> <select id="getUser" resultType="com.example.cloudprovider.domain.UserInfo"> select user_id, user_name, user_age, user_birth from t_user where user_id = #{userId} </select></mapper>
Service接口
package com.example.cloudprovider.service;import com.example.cloudprovider.domain.UserInfo;public interface UserService { UserInfo getUser(Integer userId);}
Service实现
package com.example.cloudprovider.service.impl;import com.example.cloudprovider.domain.UserInfo;import com.example.cloudprovider.mapper.UserInfoMapper;import com.example.cloudprovider.service.UserService;import org.springframework.stereotype.Service;import javax.annotation.Resource;@Servicepublic class UserServiceImpl implements UserService { @Resource private UserInfoMapper userMapper; @Override public UserInfo getUser(Integer userId) { return userMapper.getUser(userId); }}
Controller
package com.example.cloudprovider.controller;import com.example.cloudprovider.domain.UserInfo;import com.example.cloudprovider.service.UserService;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.web.bind.annotation.GetMapping;import org.springframework.web.bind.annotation.PathVariable;import org.springframework.web.bind.annotation.RestController;@RestControllerpublic class UserInfoController { @Autowired private UserService userService; @GetMapping("user/{id}") public UserInfo getUser(@PathVariable("id") Integer userId) { return userService.getUser(userId); }}
服务发布类
package com.example.cloudprovider;import org.mybatis.spring.annotation.MapperScan;import org.springframework.boot.SpringApplication;import org.springframework.boot.autoconfigure.SpringBootApplication;@SpringBootApplication@MapperScan("com.example.cloudprovider.mapper") //扫描Mapper类 注入到Spring容器中public class CloudProviderApplication { public static void main(String[] args) { SpringApplication.run(CloudProviderApplication.class, args); }}
2.消费者(引入feign框架)
pom.xml
<?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.example</groupId> <artifactId>cloud-consumer</artifactId> <version>0.0.1-SNAPSHOT</version> <packaging>jar</packaging> <name>cloud-consumer</name> <description>Demo project for Spring Boot</description> <parent> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-parent</artifactId> <version>2.0.6.RELEASE</version> <relativePath/> <!-- lookup parent from repository --> </parent> <properties> <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding> <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding> <java.version>1.8</java.version> <spring-cloud.version>Finchley.SR2</spring-cloud.version> </properties> <dependencyManagement> <dependencies> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-dependencies</artifactId> <version>${spring-cloud.version}</version> <type>pom</type> <scope>import</scope> </dependency> </dependencies> </dependencyManagement> <dependencies> <!-- 引入feign依赖 --> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-openfeign</artifactId> </dependency> <!--Service Discovery with Zookeeper--> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-zookeeper-discovery</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-devtools</artifactId> <scope>runtime</scope> </dependency> <dependency> <groupId>org.projectlombok</groupId> <artifactId>lombok</artifactId> <optional>true</optional> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-test</artifactId> <scope>test</scope> </dependency> </dependencies> <build> <plugins> <plugin> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-maven-plugin</artifactId> <configuration> <fork>true</fork> </configuration> </plugin> </plugins> </build></project>
application.yml
spring: cloud: zookeeper: connect-string: 192.168.3.201:2181 discovery: register: false #不会注册到zk中provider: # 服务名称 ribbon: # 负载均衡实现依靠ribbon # 负载策略 NFLoadBalancerRuleClassName: com.netflix.loadbalancer.RandomRule #随机策略 其他策略百度
实体类
package com.example.cloudconsumer.vo;import lombok.Getter;import lombok.Setter;import java.util.Date;@Getter@Setterpublic class UserVO { private Integer userId; private String userName; private Date userBirth;}
RestTemplate配置类
package com.example.cloudconsumer.config;import org.springframework.boot.SpringBootConfiguration;import org.springframework.cloud.client.loadbalancer.LoadBalanced;import org.springframework.context.annotation.Bean;import org.springframework.web.client.RestTemplate;@SpringBootConfigurationpublic class RestTemplateConfiguration { @Bean @LoadBalanced // Ribbon 负载均衡 public RestTemplate restTemplate() { return new RestTemplate(); }}
Controller
package com.example.cloudconsumer.controller;import com.example.cloudconsumer.vo.UserVO;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.web.bind.annotation.GetMapping;import org.springframework.web.bind.annotation.PathVariable;import org.springframework.web.bind.annotation.RestController;import org.springframework.web.client.RestTemplate;@RestControllerpublic class UserWarpController { @Autowired private RestTemplate restTemplate; // 调用只有一个或者多个服务实例API的情况下 @GetMapping("warp/user/{userId}") public UserVO getUserData(@PathVariable("userId") Integer userId) { return restTemplate.getForObject("http://provider/user/"+userId, UserVO.class); }}
使用框架的Controller
package com.example.cloudconsumer.controller;import com.example.cloudconsumer.client.UserClient;import com.example.cloudconsumer.vo.UserVO;import org.springframework.web.bind.annotation.GetMapping;import org.springframework.web.bind.annotation.PathVariable;import org.springframework.web.bind.annotation.RestController;import javax.annotation.Resource;@RestControllerpublic class UserFeignController { @Resource private UserClient userClient; // 调用只有一个或者多个服务实例API的情况下 @GetMapping("feign/user/{userId}") public UserVO getUserData(@PathVariable("userId") Integer userId) { return userClient.getUserData(userId); }}
feign调用客户端
package com.example.cloudconsumer.client;import com.example.cloudconsumer.vo.UserVO;import org.springframework.cloud.openfeign.FeignClient;import org.springframework.web.bind.annotation.GetMapping;import org.springframework.web.bind.annotation.PathVariable;/** * @FeignClient(name = "provider") * name为调用服务端的spring.application.name的值 */@FeignClient(name = "provider")public interface UserClient { @GetMapping("user/{id}") public UserVO getUserData(@PathVariable("id") Integer userId);}
服务启动类:
package com.example.cloudconsumer;import org.springframework.boot.SpringApplication;import org.springframework.boot.autoconfigure.SpringBootApplication;import org.springframework.cloud.client.discovery.EnableDiscoveryClient;import org.springframework.cloud.openfeign.EnableFeignClients;@SpringBootApplication@EnableDiscoveryClient //可以发现ZK的服务@EnableFeignClients //可以发现feign的服务public class CloudConsumerApplication { public static void main(String[] args) { SpringApplication.run(CloudConsumerApplication.class, args); }}
总结起来,feign框架可以理解成路由,对url进行再次包装后供给客户端调用,可以在这个路由上进行一系列限制操作,增强安全性。
评论前必须登录!
立即登录