2.1服务注册
2.1.1引入依赖
<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-consul-discovery</artifactId>
</dependency>
2.1.2编写配置文件
server:port: 80
spring:application:name: cloud-consumer-servicecloud:consul:host: localhostport: 8500discovery:service-name: ${spring.application.name}
2.1.3 启动类增加注解
@SpringBootApplication
@EnableDiscoveryClient // 服务注册
@RefreshScope
public class Main8001 {public static void main(String[] args) {SpringApplication.run(Main8001.class,args);}
}
2.1.4启动服务,查看服务是否正常
2.2服务使用
2.2.1引入依赖
<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-consul-discovery</artifactId>
</dependency>
2.2.2 调用服务
我们这里基于RestTemplate
来调用服务
private static final String PRE_SERVER = "http://cloud-payment-service";
完整Controller
@RestController
@RequestMapping("/consumer/pay")
@Tag(name = "订单模块", description = "订单相关接口")
public class ConsumerController {@Resourceprivate RestTemplate restTemplate;private static final String PRE_SERVER = "http://cloud-payment-service";@Operation(summary = "新增支付订单信息")@PostMappingpublic ResponseResult saveOrder(@RequestBody PayDTO payDTO){return restTemplate.postForObject(PRE_SERVER+"/pay",payDTO,ResponseResult.class);}@GetMapping("/{id}")@Operation(summary = "根据ID查询订单信息")public ResponseResult getOrderById(@PathVariable Integer id){return restTemplate.getForObject(PRE_SERVER + "/pay/" + id, ResponseResult.class, id);}@DeleteMapping("/{id}")@Operation(summary = "删除订单信息")public ResponseResult deleteOrderById(@PathVariable Integer id){restTemplate.delete(PRE_SERVER+"/pay/" +id);return ResponseResult.success();}@PutMapping@Operation(summary = "更新订单信息")public ResponseResult updateOrderById(@RequestBody PayDTO payDTO){restTemplate.put(PRE_SERVER + "/pay", payDTO);return ResponseResult.success();}
}
2.2.3 增加配置文件
@Configuration
public class RestConfig {@Bean@LoadBalanced // 负载均衡一定要添加public RestTemplate restTemplate(){return new RestTemplate();}
}