springcloud(2)-資料微服務註冊
阿新 • • 發佈:2020-11-13
1.在專案springcloud下,新建微服務product-data-service
2.修改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.zhangdemo</groupId> <artifactId>springcloud</artifactId> <version>0.0.1-SNAPSHOT</version> </parent> <artifactId>productDataservice</artifactId> <dependencies> <!--客戶端--> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId> </dependency> <!--web端,提供控制層--> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> </dependencies> </project>
3.新建Product
package com.zhangdemo.pojo; public class Product { private int id; private String name; private int price; public int getId() { return id; } public void setId(int id) { this.id = id; } public String getName() { return name; } public void setName(String name) { this.name = name; } public int getPrice() { return price; } public void setPrice(int price) { this.price = price; } public Product() { } public Product(int id, String name, int price) { super(); this.id = id; this.name = name; this.price = price; } }
4.新建ProductService
package com.zhangdemo.service; import java.util.ArrayList; import java.util.List; import com.zhangdemo.pojo.Product; import org.springframework.beans.factory.annotation.Value; import org.springframework.stereotype.Service; @Service public class ProductService { @Value("${server.port}") String port; public List<Product> listProducts(){ List<Product> ps = new ArrayList<>(); ps.add(new Product(1,"product a from port:"+port, 50)); ps.add(new Product(2,"product b from port:"+port, 150)); ps.add(new Product(3,"product c from port:"+port, 250)); return ps; } }
5.新建ProductController
package com.zhangdemo.web;
import java.util.List;
import com.zhangdemo.pojo.Product;
import com.zhangdemo.service.ProductService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
@RestController
public class ProductController {
@Autowired
ProductService productService;
@RequestMapping("/products")
public Object products() {
List<Product> ps = productService.listProducts();
return ps;
}
}
6.修改App為ProductDataServiceApplication,並修改成以下內容
@SpringBootApplication
@EnableEurekaClient
public class ProductDataServiceApplication {
public static void main(String[] args) {
int port = 0;
int defaultPort = 8001;
Future<Integer> future = ThreadUtil.execAsync(() ->{
int p = 0;
System.out.println("請於5秒鐘內輸入埠號, 推薦 8001 、 8002 或者 8003,超過5秒將預設使用 " + defaultPort);
Scanner scanner = new Scanner(System.in);
while(true) {
String strPort = scanner.nextLine();
if(!NumberUtil.isInteger(strPort)) {
System.err.println("只能是數字");
continue;
}
else {
p = Convert.toInt(strPort);
scanner.close();
break;
}
}
return p;
});
try{
port=future.get(5, TimeUnit.SECONDS);
}
catch (InterruptedException | ExecutionException | TimeoutException e){
port = defaultPort;
}
if(!NetUtil.isUsableLocalPort(port)) {
System.err.printf("埠%d被佔用了,無法啟動%n", port );
System.exit(1);
}
new SpringApplicationBuilder(ProductDataServiceApplication.class).properties("server.port=" + port).run(args);
}
}
7.在main目錄下建立resources資料夾,並在resources資料夾下建立application.yml且寫入如下內容
# server:
# port: 因為會啟動多個 product-data-service, 所以埠號由使用者自動設定,推薦 8001,8002,8003
# 微服務名稱
spring:
application:
name: product-data-service
#註冊地址
eureka:
client:
serviceUrl:
defaultZone: http://localhost:8761/eureka/
8.輸入http://localhost:8001/products,進行校驗