一、服务的提供者。
1、Spring脚手架创建工程。
填写项目信息：
添加web依赖：
添加MyBatis依赖：
填写项目位置：
生成的项目结构：
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 https://maven.apache.org/xsd/maven-4.0.0.xsd"> <modelVersion>4.0.0</modelVersion> <parent> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-parent</artifactId> <version>2.7.5</version> <relativePath/> <!-- lookup parent from repository --> </parent> <groupId>com.db.demo</groupId> <artifactId>user-service-demo</artifactId> <version>0.0.1-SNAPSHOT</version> <name>user-service-demo</name> <description>Demo project for Spring Boot</description> <properties> <java.version>1.8</java.version> </properties> <dependencies> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-jdbc</artifactId> </dependency> <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>2.2.2</version> </dependency> <dependency> <groupId>com.mysql</groupId> <artifactId>mysql-connector-j</artifactId> <scope>runtime</scope> </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> </plugin> </plugins> </build> </project>
因为要使用通用的mapper，所以需要手动加入通用mapper的依赖：
<dependency> <groupId>tk.mybatis</groupId> <artifactId>mapper-spring-boot-starter</artifactId> <version>2.0.2</version> </dependency>
2、编写代码。
2.1、创建一个Controller类，添加一个对外查询的接口：
@RestController @RequestMapping("user") public class UserController { @Autowired public UserService userService; @GetMapping("/{id}") public User queryUserById(@PathVariable("id") Long id){ return this.userService.queryUserById(id); } }
2.2、创建service
@Service public class UserService { @Autowired public UserMapper userMapper; public User queryUserById(Long id){ return this.userMapper.selectByPrimaryKey(id); } }
3.3、创建Mapper接口
@Mapper public interface UserMapper extends tk.mybatis.mapper.common.Mapper<User> { }
3.4、实体类。
@Table(name = "tb_user") public class User implements Serializable { private static final long serialVersionUID = 1L; @Id @GeneratedValue(strategy = GenerationType.IDENTITY) private Long id; // 用户名 private String userName; // 性别 private String sex; // 出生日期 private Date birthday; // 地址 private String address; // 。。。省略getters和setters }
3.5、配置文件：这里用的是yml属性文件。
server:
port: 8081
spring:
application:
name: item-service
datasource:
url: jdbc:mysql://localhost:3306/springboot
username: root
password: 123456
hikari:
maximum-pool-size: 30
minimum-idle: 10
3.6、项目结构：
3.7、启动并测试。启动项目，访问接口 http://localhost:8081/user/1
二、服务的调用者。
1、创建方法与上面一样，需要注意的是这里调用的是user-service的功能，所以不需要mybatis相关依赖了。
2、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.db.demo</groupId> <artifactId>user-consumer-demo</artifactId> <version>0.0.1-SNAPSHOT</version> <packaging>jar</packaging> <name>user-consumer-demo</name> <description>Demo project for Spring Boot</description> <parent> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-parent</artifactId> <version>2.0.1.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> </properties> <dependencies> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> <!-- 添加OkHttp支持 --> <dependency> <groupId>com.squareup.okhttp3</groupId> <artifactId>okhttp</artifactId> <version>3.9.0</version> </dependency> </dependencies> <build> <plugins> <plugin> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-maven-plugin</artifactId> </plugin> </plugins> </build> </project>
3、编写代码。
3.1、在启动类中注册RestTemplate模板对象，向该模板对象中注入OkHttp客户端的工厂对象。
@SpringBootApplication public class ComsumerDemoApplication { @Bean public RestTemplate getRestTemplate(){ // 这次我们使用了OkHttp客户端,只需要注入工厂即可 return new RestTemplate(new OkHttp3ClientHttpRequestFactory()); } public static void main(String[] args) { SpringApplication.run(ComsumerDemoApplication.class, args); } }
3.2、编写UserDao，注意，这里不是调用mapper查数据库，而是通过RestTemplate远程查询user-service-demo中的接口：
@Component public class UserDao { @Autowired public RestTemplate restTemplate; public User queryUserById(Long id){ String url = "http://localhost:8081/user/" +id; return this.restTemplate.getForObject(url, User.class); } }
3.3、编写UserService，循坏查询UserDao信息。
@Service public class UserService { @Autowired public UserDao userDao; public List<User> queryUserByIds(List<Long> ids){ List<User> user = new ArrayList<>(); for (Long id : ids) { user.add(this.userDao.queryUserById(id)); } return user; } }
3.4、编写controller。
@Controller @RequestMapping("consume") public class UserController { @Autowired public UserService userService; @GetMapping public List<User> comsume(@RequestParam("ids") List<Long> ids){ return this.userService.queryUserByIds(ids); } }
3.5、启动测试 ，因为没有配置端口，所以默认是8080，访问 http://localhost:8080/consume?ids=1,2
原文地址：http://www.cnblogs.com/sfwu/p/16868811.html
1. 本站所有资源来源于用户上传和网络，如有侵权请邮件联系站长！
2. 分享目的仅供大家学习和交流，请务用于商业用途!
3. 如果你也有好源码或者教程，可以到用户中心发布，分享有积分奖励和额外收入！
4. 本站提供的源码、模板、插件等等其他资源，都不包含技术服务请大家谅解！
5. 如有链接无法下载、失效或广告，请联系管理员处理！
6. 本站资源售价只是赞助，收取费用仅维持本站的日常运营所需！
7. 如遇到加密压缩包，默认解压密码为"gltf",如遇到无法解压的请联系管理员！
8. 因为资源和程序源码均为可复制品，所以不支持任何理由的退款兑现，请斟酌后支付下载
声明：如果标题没有注明"已测试"或者"测试可用"等字样的资源源码均未经过站长测试.特别注意没有标注的源码不保证任何可用性
