天天看點

SpringCloud六、Rest微服務案例部門服務消費者。

①建立microservicecloud-consumer-dept-80部門微服務消費者Module。建立microservicecloud-consumer-dept-80。

SpringCloud六、Rest微服務案例部門服務消費者。
SpringCloud六、Rest微服務案例部門服務消費者。
SpringCloud六、Rest微服務案例部門服務消費者。
SpringCloud六、Rest微服務案例部門服務消費者。

②更改pom檔案。

pom.xml檔案的内容是:

<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>

  <parent>
   <groupId>com.lss.springcloud</groupId>
   <artifactId>microservicecloud</artifactId>
   <version>0.0.1-SNAPSHOT</version>
  </parent>

  <artifactId>microservicecloud-consumer-dept-80</artifactId>
  <description>部門微服務消費者</description>

  <dependencies>
   <dependency><!-- 自己定義的api -->
     <groupId>com.lss.springcloud</groupId>
     <artifactId>microservicecloud-api</artifactId>
     <version>${project.version}</version>
   </dependency> 
   <dependency>
     <groupId>org.springframework.boot</groupId>
     <artifactId>spring-boot-starter-web</artifactId>
   </dependency>
   <!-- 修改後立即生效,熱部署 -->
   <dependency>
     <groupId>org.springframework</groupId>
     <artifactId>springloaded</artifactId>
   </dependency>
   <dependency>
     <groupId>org.springframework.boot</groupId>
     <artifactId>spring-boot-devtools</artifactId>
   </dependency>   
  </dependencies>


</project>

           

然後更新。

SpringCloud六、Rest微服務案例部門服務消費者。
SpringCloud六、Rest微服務案例部門服務消費者。

③建立yml檔案。

SpringCloud六、Rest微服務案例部門服務消費者。
SpringCloud六、Rest微服務案例部門服務消費者。

application.yml的内容是:

server:
  port: 80
           

④建立包com.lss.springcloud.cfgbeans,包下建立ConfigBean類,該類的編寫(類似spring裡面的applicationContext.xml寫入的注入Bean)。

SpringCloud六、Rest微服務案例部門服務消費者。
SpringCloud六、Rest微服務案例部門服務消費者。

在上面的包中,建立一個注解版的配置類。

SpringCloud六、Rest微服務案例部門服務消費者。
SpringCloud六、Rest微服務案例部門服務消費者。

ConfigBean.java的内容是:

package com.lss.springcloud.cfgbeans;

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.client.RestTemplate;


//boot 優化了spring架構,spring架構用的配置檔案是 applicationContext.xml
//而在springboot裡面,已經沒有applicationContext.xml這個檔案了。
//隻有加了@Configuration的注解版類。
@Configuration
public class ConfigBean{

	@Bean
	public RestTemplate getRestTemplate() {
		return new RestTemplate();
	}
}
//在spring架構裡面的applicationContext.xml檔案裡面,一定會寫:
//<bean id="userService"  class="com.lss.tmall.UserServiceImpl">  </bean>
//那麼在springboot裡面沒有applicationContext.xml檔案,則在@Configuration類裡面寫:
/*
 * @Bean
 * public UserService getUserService(){
 * 	return new UserServiceImpl();
 * }
 */
           

⑤建立包com.lss.springcloud.controller,在包下建立DeptController_Consumer類,部門微服務消費者REST。

SpringCloud六、Rest微服務案例部門服務消費者。
SpringCloud六、Rest微服務案例部門服務消費者。
SpringCloud六、Rest微服務案例部門服務消費者。
SpringCloud六、Rest微服務案例部門服務消費者。

一般的結構是,如在服務提供者裡面的結構是:dao資料層,service接口層,service實作層,和controller層。

但是在服務消費者裡面的結構,沒有服務層,即沒有service接口層,和service實作層。隻有controller層。

什麼是RestTemplate?

RestTemplate提供了多種便捷通路遠端Http服務的方法, 

是一種簡單便捷的通路restful服務模闆類,是Spring提供的用于通路Rest服務的用戶端模闆工具集。注意:是用戶端!

 官網及使用:

https://docs.spring.io/spring-framework/docs/4.3.7.RELEASE/javadoc-api/org/springframework/web/client/RestTemplate.html

使用:

使用restTemplate通路restful接口非常的簡單粗暴無腦。

(url, requestMap, ResponseBean.class)這三個參數分别代表 

REST請求位址、請求參數、HTTP響應轉換被轉換成的對象類型。

SpringCloud六、Rest微服務案例部門服務消費者。

DeptController_Consumer.java的内容是:

package com.lss.springcloud.controller;

import java.util.List;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;

import com.lss.springcloud.entities.Dept;

@RestController
public class DeptController_Consumer {

	private static final String REST_URL_PREFIX = "http://localhost:8001";
	
	@Autowired
	private RestTemplate restTemplate;
	
/*
使用:
使用restTemplate通路restful接口非常的簡單粗暴無腦。
(url, requestMap, ResponseBean.class)這三個參數分别代表 
REST請求位址、請求參數、HTTP響應轉換被轉換成的對象類型。
*/
	@RequestMapping(value="/consumer/dept/add")
	public boolean add(Dept dept) {
		return restTemplate.postForObject(REST_URL_PREFIX+"/dept/add", 
				dept, Boolean.class);
	}
	
	@RequestMapping(value="/consumer/dept/get/{id}")
	public Dept get(@PathVariable("id")  Long id) {
		return restTemplate.getForObject(REST_URL_PREFIX+"/dept/get/"+id, 
				Dept.class);
	}
	
	@SuppressWarnings("unchecked")
	@RequestMapping(value="/consumer/dept/list")
	public List<Dept> list() {
		return restTemplate.getForObject(REST_URL_PREFIX+"/dept/list",
				List.class);
	}
	
	
}
           

⑥寫DeptConsumer80_App主啟動類。

SpringCloud六、Rest微服務案例部門服務消費者。
SpringCloud六、Rest微服務案例部門服務消費者。

DeptConsumer80_App.java的内容是:

SpringCloud六、Rest微服務案例部門服務消費者。
package com.lss.springcloud;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication
public class DeptConsumer80_App {

	public static void main(String[] args) {
		SpringApplication.run(DeptConsumer80_App.class, args);
	}

}
           

然後将服務提供者maven clean ,maven  clean表示将jar包更新,然後maven install ,安裝更新(clean)後的jar包。

同理,将服務消費者maven clean ,maven  clean表示将jar包更新,然後maven install ,安裝更新(clean)後的jar包。

然後分别run as,spring boot app。先run as服務提供者,後run as服務消費者。

然後測試:

http://localhost/consumer/dept/get/2

http://localhost/consumer/dept/list

http://localhost/consumer/dept/add?dname=AI

不用寫80端口,因為不寫就代表端口是80。

然後發現:http://localhost/consumer/dept/add?dname=AI

不能插入内容。插入後,值是null。

SpringCloud六、Rest微服務案例部門服務消費者。

更改以下兩處内容:

SpringCloud六、Rest微服務案例部門服務消費者。

DeptMapper.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.lss.springcloud.dao.DeptDao">
 
   <resultMap id="BaseResultMap" type="com.lss.springcloud.entities.Dept" >
    <id column="deptno" property="deptno" jdbcType="BIGINT" />
    <result column="dname" property="dname" jdbcType="VARCHAR" />
    <result column="db_source" property="db_source" jdbcType="VARCHAR" />
  </resultMap>
  

 <select id="findById" resultMap="BaseResultMap" parameterType="Long">
   select deptno,dname,db_source from dept where deptno=#{deptno}; 
  </select>
  <select id="findAll" resultMap="BaseResultMap">
   select deptno,dname,db_source from dept; 
  </select>
  <insert id="addDept" parameterType="com.lss.springcloud.entities.Dept">
	INSERT INTO dept (dname,db_source)  VALUES  (#{dname,jdbcType=VARCHAR},DATABASE());
  </insert>
  
</mapper>
 
           

第二個要更改的地方是:

需要增加@RequestBody!!!之前就是因為沒有加@RequestBody才導緻insert不進去内容。

SpringCloud六、Rest微服務案例部門服務消費者。

DeptController.java的内容是:

package com.lss.springcloud.controller;


import java.util.List;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RestController;

import com.lss.springcloud.entities.Dept;
import com.lss.springcloud.service.DeptService;

@RestController
public class DeptController {

	@Autowired
	private DeptService service;
	
	@RequestMapping(value = "/dept/add",method = RequestMethod.POST)
	public boolean add(@RequestBody Dept dept) {
		return service.add(dept);
	}
	
	@RequestMapping(value = "/dept/get/{id}" , method = RequestMethod.GET)
	public Dept get(@PathVariable("id") Long id) {
		return service.get(id);
	}
	
	@RequestMapping(value = "/dept/list" , method = RequestMethod.GET)
	public List<Dept> list() {
		return service.list();
	}
}