因?yàn)橐芯糠植际绞聞?wù) 所以搭建一個(gè)簡(jiǎn)單的SpringCloud的項(xiàng)目 來(lái)進(jìn)行事務(wù)相關(guān)的測(cè)試 中間出現(xiàn)了一些小問(wèn)題 在這里記錄一下創(chuàng)建項(xiàng)目的整個(gè)過(guò)程
- 創(chuàng)建EurekServer
創(chuàng)建一個(gè)springboot項(xiàng)目 并引入依賴webeurekserverhystrix-dashboard,'security'
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-hystrix-dashboard</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-security</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-security</artifactId>
</dependency>
修改配置文件 更改端口號(hào) 以及配置security
server:
port: 8761
spring:
application:
name: registry
security:
user:
name: zhou
password: 12345678
eureka:
client:
register-with-eureka: false
fetch-registry: false
serviceUrl:
defaultZone: http://zhou:12345678@localhost:${server.port}/eureka/
然后修改啟動(dòng)類(lèi)
@SpringBootApplication
@EnableEurekaServer
@EnableHystrixDashboard
public class RegistryApplication {
public static void main(String[] args) {
SpringApplication.run(RegistryApplication.class, args);
}
}
然后建立一個(gè)zuul的網(wǎng)關(guān) 引入pom文件
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-zuul</artifactId>
</dependency>
對(duì)yml文件進(jìn)行配置 修改端口號(hào) 增加application name
server:
port: 8888
spring:
application:
name: proxy
eureka:
client:
serviceUrl:
defaultZone: http://zhou:12345678@localhost:8761/eureka
然后寫(xiě)一個(gè)user的項(xiàng)目來(lái)進(jìn)行測(cè)試 使用的是h2和jpa
建立domain類(lèi)
@Entity(name = "customer")
public class Customer {
@Id
@GeneratedValue
private Long userId;
private String password;
private String userName;
public Long getUserId() {
return userId;
}
public void setUserId(Long userId) {
this.userId = userId;
}
public String getPassword() {
return password;
}
public void setPassword(String password) {
this.password = password;
}
public String getUserName() {
return userName;
}
public void setUserName(String userName) {
this.userName = userName;
}
}
建立CustomerRepositry 因?yàn)榫褪且粋€(gè)測(cè)試 所以只是繼承了JpaRepository
public interface CustomerRepositry extends JpaRepository<Customer,Long> {
}
service
@Service
public class CustomerService {
@Resource
private CustomerRepositry customerRepositry;
//根據(jù)id 查詢用戶
public Optional<Customer> getCustomerById(Long id){
return customerRepositry.findById(id);
}
//查詢用戶信息
public List<Customer> getAllCustomer(){
return customerRepositry.findAll();
}
//保存用戶信息
public void save(Customer customer){
customerRepositry.save(customer);
}
}
controller
@RestController
@RequestMapping("/user/test")
public class CustomerController {
@Resource
private CustomerService customerService;
@Resource
private OrderClient orderClient;
@PostConstruct
public void init(){
Customer customer = new Customer();
customer.setUserId(1L);
customer.setUserName("KrisWu");
customer.setPassword("123456");
customerService.save(customer);
}
@RequestMapping("getCustomer")
public List<Customer> getCustomer(){
return customerService.getAllCustomer();
}
@RequestMapping("getOrder")
@HystrixCommand
public Map getOrder(){
Optional<Customer> customer = customerService.getCustomerById(1L);
String orderDetail = orderClient.getMyOrder(1L);
Map map = new HashMap();
map.put("customer",customer);
map.put("orderDetail",orderDetail);
return map;
}
啟動(dòng)項(xiàng)目 出現(xiàn)了報(bào)錯(cuò)
ERROR 11612 --- [tbeatExecutor-0] com.netflix.discovery.DiscoveryClient : *****:***** - was unable to send heartbeat!
這個(gè)錯(cuò)誤是在2.0以上會(huì)出現(xiàn)的。是因?yàn)閟ecurity默認(rèn)啟用了csrf檢驗(yàn)，要在eurekaServer端配置security的csrf檢驗(yàn)為false求厕。
所以在repostory中新建一個(gè)config文件
@EnableWebSecurity
public class WebSecurityConfig extends WebSecurityConfigurerAdapter {
@Override
protected void configure(HttpSecurity http) throws Exception {
http.csrf().disable();
super.configure(http);
}
}
然后通過(guò)proxy的地址來(lái)訪問(wèn)user的項(xiàng)目
訪問(wèn)地址(http://localhost:8888/user/user/test/getCustomer)
然后發(fā)現(xiàn)可以顯示增加的用戶信息
通過(guò)zuul訪問(wèn)
然后再新建一個(gè)order的項(xiàng)目 想要達(dá)到的想過(guò)是可以在user的項(xiàng)目中 直接調(diào)用order中的方法 這里和user基本上是差不多的 就不貼代碼了
重要的地方是在user的項(xiàng)目中 新建一個(gè)類(lèi)OrderClient
@FeignClient(value = "order",path = "/order/test")
public interface OrderClient {
@GetMapping("/{id}")
String getMyOrder(@PathVariable(name = "id")Long id);
}
主要就是通過(guò)這個(gè)類(lèi)進(jìn)行連接
然后啟動(dòng)項(xiàng)目 進(jìn)行測(cè)試
image.png
image.png
