注册服务并测试接口
我們編寫了一個(gè)Provider,我們在Eureka的注冊中心當(dāng)中,去進(jìn)行一個(gè)Provider服務(wù)的注冊,其實(shí)我們現(xiàn)在這個(gè)項(xiàng)目,可以直接去運(yùn)行了,我們這里再加一個(gè)logback的日志配置文件,然后回來我們來運(yùn)行我們的這個(gè)Provider,然后我們觀察控制臺,啟動沒有問題,他在監(jiān)聽9090端口,然后我們打開Eureka的管理界面,刷新,然后我們看下面,在服務(wù)注冊列表呢,服務(wù)注冊列表顯示信息這兒,除了有集群當(dāng)中的兩個(gè)節(jié)點(diǎn)以外,是不是多了這么一個(gè)注冊信息,eureka-provider,是不是就是我們服務(wù)的這個(gè)name,就是我們已經(jīng)將服務(wù)注冊到了我們的Eureka服務(wù)注冊當(dāng)中,然后我們再看一下另外一個(gè)節(jié)點(diǎn)當(dāng)中10.40.8.152:8761nohup java -jar springcloud-eureka-server-ha-0.0.1-SNAPSHOT.jar --spring.profiles.active=eureka1 &之所以兩個(gè)節(jié)點(diǎn)能夠注冊的原因是,我們加了兩個(gè)節(jié)點(diǎn)的地址,如果你只加了一個(gè)的話,那么只會在一個(gè)節(jié)點(diǎn)上有注冊信息,那么我們接下來簡單的寫一個(gè)接口,然后我們?nèi)フ{(diào)用一下,比較簡單的代碼了,我這里添加一個(gè)Controller,我們起個(gè)名叫UserController,我們先把這個(gè)停掉,因?yàn)槲覀冞€要測試服務(wù)注冊完能不能測試,然后我在這里再去創(chuàng)建一個(gè)class,比如我叫User,然后我們給User添加幾個(gè)屬性,比如有int類型的userId,String類型的userName,再來一個(gè)int類型的userage,然后我們生成get/set方法,然后我們再去生成構(gòu)造方法,生成一個(gè)有參的,然后再去生成一個(gè)無參的,這樣我們一個(gè)實(shí)體類就寫完了,然后回到我們的接口當(dāng)中,加一個(gè)@RestController,我們要以JSON格式的返回,字符串返回,然后我們加一個(gè)@RequestMapping,將URL傳入到接口上,比如我們叫user,我們來一個(gè)list吧@RequestMapping("/user")
public List<User> getUsers(){List<User> list = new ArrayList<>();list.add(new User(1,"zhangsan",20));list.add(new User(2,"lisi",22));list.add(new User(3,"wangwu",20));return list;
}然后在這里我去創(chuàng)建一個(gè)List,這樣我們服務(wù)的一個(gè)接口就定義好了,然后我們接下來再把服務(wù)啟動,注冊到我們的注冊中心當(dāng)中,我們可以去訪問一下localhost:9090/user[{userid: 1,username: "zhangsan",userage: 20},{userid: 2,username: "lisi",userage: 22},{userid: 3,username: "wangwu",userage: 20}
]我們可以看到這個(gè)信息拿到了,這就代表我們的服務(wù)是可用的,我們調(diào)用接口是沒有問題的,所以我們首先是將Provider注冊到高可用的注冊中心當(dāng)中,然后我們再去訪問這個(gè)服務(wù),我們主要是以服務(wù)的提供方Provider為主,我們先把代碼整理到筆記當(dāng)中,編寫服務(wù)接口,第一個(gè)是創(chuàng)建接口,然后我們創(chuàng)建了一個(gè)POJO
<?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.learn.cloud</groupId><artifactId>springcloud-eureka-provider</artifactId><version>0.0.1-SNAPSHOT</version><packaging>jar</packaging><parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>1.5.12.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> <dependencyManagement><dependencies><dependency> <groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-dependencies</artifactId><version>Dalston.SR1</version><type>pom</type><scope>import</scope></dependency></dependencies></dependencyManagement><dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-eureka</artifactId></dependency><!-- <dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-security</artifactId></dependency> --></dependencies><!-- 這個(gè)插件,可以將應(yīng)用打包成一個(gè)可執(zhí)行的jar包 --><build><plugins><plugin><groupId>org.springframework.boot</groupId><artifactId>spring-boot-maven-plugin</artifactId></plugin></plugins></build></project>
server.port=9090
eureka.client.serviceUrl.defaultZone=http://10.40.8.152:8761/eureka,http://10.40.8.152:8762/eureka
spring.application.name=springcloud-eureka-provider
eureka.instance.prefer-ip-address=true
eureka.instance.instance-id=${spring.application.name}:${spring.cloud.client.ipAddress}:${spring.application.instance_id:${server.port}}
<?xml version="1.0" encoding="UTF-8" ?><configuration>
<!--定義日志文件的存儲地址 勿在 LogBack 的配置中使用相對路徑--> <property name="LOG_HOME" value="${catalina.base}/logs/" /> <!-- 控制臺輸出 --> <appender name="Stdout" class="ch.qos.logback.core.ConsoleAppender"><!-- 日志輸出編碼 --> <layout class="ch.qos.logback.classic.PatternLayout"> <!--格式化輸出：%d表示日期，%thread表示線程名，%-5level：級別從左顯示5個(gè)字符寬度%msg：日志消息，%n是換行符--> <pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{50} - %msg%n </pattern> </layout> </appender> <!-- 按照每天生成日志文件 --> <appender name="RollingFile" class="ch.qos.logback.core.rolling.RollingFileAppender"> <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy"><!--日志文件輸出的文件名--><FileNamePattern>${LOG_HOME}/server.%d{yyyy-MM-dd}.log</FileNamePattern> <MaxHistory>30</MaxHistory></rollingPolicy> <layout class="ch.qos.logback.classic.PatternLayout"> <!--格式化輸出：%d表示日期，%thread表示線程名，%-5level：級別從左顯示5個(gè)字符寬度%msg：日志消息，%n是換行符--> <pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{50} - %msg%n </pattern> </layout> <!--日志文件最大的大小--><triggeringPolicy class="ch.qos.logback.core.rolling.SizeBasedTriggeringPolicy"><MaxFileSize>10MB</MaxFileSize></triggeringPolicy></appender> <!-- 日志輸出級別 --><root level="DEBUG"> <appender-ref ref="Stdout" /> <appender-ref ref="RollingFile" /> </root> <!--日志異步到數(shù)據(jù)庫 -->
<!-- <appender name="DB" class="ch.qos.logback.classic.db.DBAppender">日志異步到數(shù)據(jù)庫 <connectionSource class="ch.qos.logback.core.db.DriverManagerConnectionSource">連接池 <dataSource class="com.mchange.v2.c3p0.ComboPooledDataSource"><driverClass>com.mysql.jdbc.Driver</driverClass><url>jdbc:mysql://127.0.0.1:3306/databaseName</url><user>root</user><password>root</password></dataSource></connectionSource></appender> --></configuration>
package com.learn.pojo;public class User {private int userid;private String username;private int userage;public int getUserid() {return userid;}public void setUserid(int userid) {this.userid = userid;}public String getUsername() {return username;}public void setUsername(String username) {this.username = username;}public int getUserage() {return userage;}public void setUserage(int userage) {this.userage = userage;}public User(int userid, String username, int userage) {super();this.userid = userid;this.username = username;this.userage = userage;}public User() {super();// TODO Auto-generated constructor stub}}
package com.learn.controller;import java.util.ArrayList;
import java.util.List;import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;import com.learn.pojo.User;@RestController
public class UserController {@RequestMapping("/user")public List<User> getUsers(){List<User> list = new ArrayList<>();list.add(new User(1,"zhangsan",20));list.add(new User(2,"lisi",22));list.add(new User(3,"wangwu",20));return list;}
}
package com.learn;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;@EnableEurekaClient
@SpringBootApplication
public class EurekaProviderApplication {public static void main(String[] args) {SpringApplication.run(EurekaProviderApplication.class, args);}
}
?
總結(jié)
- 上一篇： 创建provider服务
- 下一篇： 创建consumer服务