上QQ阅读APP看书,第一时间看更新
3.3 编写服务提供者
3.3.1 创建项目注册到Eureka
注册中心已经创建并且启动好了,接下来我们实现将一个服务提供者eureka-client-user-service注册到Eureka中,并提供一个接口给其他服务调用。
首先还是创建一个Maven项目,然后在pom.xml中增加相关依赖,如代码清单3-3所示。
代码清单3-3 服务提供者Maven配置
<! -- Spring Boot --> <parent> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-parent</artifactId> <version>2.0.6.RELEASE</version> <relativePath /> </parent> <dependencies> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> <! -- eureka --> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId> </dependency> </dependencies> <! -- Spring Cloud --> <dependencyManagement> <dependencies> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-dependencies</artifactId> <version>Finchley.SR2</version> <type>pom</type> <scope>import</scope> </dependency> </dependencies> </dependencyManagement>
创建一个启动类App,代码如代码清单3-4所示。
代码清单3-4 服务提供者启动类
@SpringBootApplication @EnableDiscoveryClient public class App { public static void main(String[] args) { SpringApplication.run(App.class, args); } }
启动类的方法与之前没有多大区别,只是注解换成@EnableDiscoveryClient,表示当前服务是一个Eureka的客户端。
接下来在src/main/resources下面创建一个application.properties属性文件,增加下面的配置:
spring.application.name= eureka-client-user-service server.port=8081 eureka.client.serviceUrl.defaultZone=http://localhost:8761/eureka/ # 采用IP注册 eureka.instance.preferIpAddress=true # 定义实例ID格式 eureka.instance.instance-id=${spring.application.name}:${spring.cloud.client.ip- address}:${server.port}
eureka.client.serviceUrl.defaultZone的地址就是我们之前启动的Eureka服务的地址,在启动的时候需要将自身的信息注册到Eureka中去。
执行App启动服务,我们可以看到控制台中有输出注册信息的日志:
DiscoveryClient_EUREKA-CLIENT-USER-SERVICE/eureka-client-user- service:192.168.31.245:8081- registration status: 204
我们可以进一步检查服务是否注册成功。回到之前打开的Eureka的Web控制台,刷新页面,就可以看到新注册的服务信息了,如图3-2所示。
图3-2 Eureka中注册的实例信息
3.3.2 编写提供接口
创建一个Controller,提供一个接口给其他服务查询,如代码清单3-5所示。
代码清单3-5 服务提供者接口
@RestController public class UserController { @GetMapping("/user/hello") public String hello() { return “hello”; } }
重启服务,访问http://localhost:8081/user/hello,如果能看到我们返回的Hello字符串,就证明接口提供成功了。