當(dāng)前位置：
首頁 >
专有云传统HSF升级Pandora Boot开发
發(fā)布時間：2024/9/3
42
豆豆
生活随笔
收集整理的這篇文章主要介紹了
专有云传统HSF升级Pandora Boot开发
小編覺得挺不錯的,現(xiàn)在分享給大家,幫大家做個參考.
簡介：專有云傳統(tǒng)HSF升級Pandora Boot開發(fā)
JDK基礎(chǔ)運行環(huán)境：正確安裝JDK 7+，正確配置JAVA_HOME環(huán)境變量。 MAVEN環(huán)境及構(gòu)建HSF MAVEN工程：添加打war包與HSF開發(fā)編譯依賴。 開發(fā)IDE：推薦Eclipse或IDEA。 Eclipse配置：Tomcat4e插件+Pandora配置。 IDEA：配置AliTomcat+Pandora。 輕量級配置中心：HSF服務(wù)的發(fā)布與訂閱。 JDK基礎(chǔ)運行環(huán)境：正確安裝JDK 7+，正確配置JAVA_HOME環(huán)境變量。 MAVEN環(huán)境及構(gòu)建Pandora Boot MAVEN工程：添加打FatJar包與Pandora Boot開發(fā)編譯依賴。 開發(fā)IDE：推薦Eclipse或IDEA。 Eclipse配置：啟動Pandora Boot應(yīng)用主函數(shù)自動加載Pandora容器。 IDEA配置：啟動Pandora Boot應(yīng)用主函數(shù)自動加載Pandora容器。 輕量級注冊及配置中心：Pandora Boot應(yīng)用的注冊、發(fā)現(xiàn)及配置管理。 服務(wù)接口：HSF的服務(wù)基于接口實現(xiàn)，接口需在服務(wù)設(shè)計時預(yù)先定義設(shè)計好，生產(chǎn)者將實現(xiàn)該接口以提供具體的實現(xiàn)來提供服務(wù)，消費者也是基于此接口作為服務(wù)去訂閱。 服務(wù)生產(chǎn)者：生產(chǎn)者將實現(xiàn)之前定義的服務(wù)接口以提供具體實現(xiàn)，除了代碼實現(xiàn)的工作之外，由于HSF是基于Spring框架來實現(xiàn)的，所以還需要再定義服務(wù)發(fā)布的XML文件。 服務(wù)消費者：消費者基于接口使用服務(wù)，具體調(diào)用時需要做兩個步驟 Pandora Boot 的配置文件使用注解@HSFConsumer定義好一個 Bean。 在使用的時候從 Spring 的 context 中將 Bean 取出。
無縫兼容：HSF與Spring無縫兼容，標準用法使用Spring的xml配置。 標準schema：提供hsf:provider，hsf:consumer兩個標準的xml格式。 代碼無侵入：使用xml方式開發(fā)時，代碼不需要感知HSF框架，而且POM中只需要引入edas-sdk。 框架與WAR包分離：最終輸入的war，不需要包含HSF框架，HSF框架依賴AliTomcat+Pandora方式提供。 構(gòu)建maven工程，創(chuàng)建完maven工程后，在pom.xml文件中定義添加edas-sdk和spring的依賴。 <dependencies>
<!-- 添加 servlet 的依賴 -->
<dependency>
<groupId>javax.servlet</groupId>
<artifactId>servlet-api</artifactId>
<version>2.5</version>
<scope>provided</scope>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring</artifactId>
<version>2.5.6</version>
<type>jar</type>
<scope>compile</scope>
</dependency>
<!-- 添加 edas-sdk 的依賴 -->
<dependency>
<groupId>com.alibaba.edas</groupId>
<artifactId>edas-sdk</artifactId>
<version>1.5.4</version>
</dependency>
</dependencies>在pom.xml文件中添加HSF應(yīng)用的maven打包插件。 <build>
<finalName>itemcenter</finalName>
<plugins>
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-compiler-plugin</artifactId>
<version>3.1</version>
<configuration>
<source>1.6</source>
<target>1.6</target>
</configuration>
</plugin>
</plugins>
</build>編寫HSF提供者服務(wù)除構(gòu)建HSF maven工程外，服務(wù)提供者需要在pom.xml文件中引入公共模塊工程的依賴。 <dependency>
<groupId>com.edas.demo</groupId>
<artifactId>edasdemo-api</artifactId>
<version>0.0.1-SNAPSHOT</version>
</dependency>服務(wù)提供者實現(xiàn)接口提供具體的服務(wù)，然后發(fā)布對應(yīng)的服務(wù)。 package com.edas.demo;
public class SayhelloImpl implements Sayhello {
public String sayHello() {
System.out.println("INFO:執(zhí)行一次Hello");
return "Hello!";
}
public String sayHello(String name) {
return "你好"+name;
}
}在hsf-provider-beans.xml中Spring配置HSF服務(wù)。 <?xml version="1.0" encoding="UTF-8"?>
<beans xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:hsf="http://www.taobao.com/hsf"
xmlns="http://www.springframework.org/schema/beans"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans-2.5.xsd
http://www.taobao.com/hsf
http://www.taobao.com/hsf/hsf.xsd" default-autowire="byName">
<bean id="sayHello" class="com.edas.demo.SayhelloImpl" />
<!-- 提供一個服務(wù)示例 -->
<hsf:provider id="sayHelloProvider" interface="com.edas.demo.Sayhello"
ref="sayHello" version="1.0.0">
</hsf:provider>
</beans>編寫消費者服務(wù)除構(gòu)建HSF maven工程外，服務(wù)消費者需要在pom.xml文件中引入公共模塊工程的依賴。 <dependency>
<groupId>com.edas.demo</groupId>
<artifactId>edasdemo-api</artifactId>
<version>0.0.1-SNAPSHOT</version>
</dependency>在hsf-consumer-beans.xml中Spring配置HSF服務(wù)。 <?xml version="1.0" encoding="UTF-8"?>
<beans xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:hsf="http://www.taobao.com/hsf"
xmlns="http://www.springframework.org/schema/beans"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans-2.5.xsd
http://www.taobao.com/hsf
http://www.taobao.com/hsf/hsf.xsd" default-autowire="byName">
<!-- 消費一個服務(wù)示例 -->
<hsf:consumer id="sayHello" interface="com.edas.demo.Sayhello"
version="1.0.0">
</hsf:consumer>
</beans>編寫服務(wù)消費者基于接口調(diào)用服務(wù)提供者的代碼SayhelloServlet。 public class SayhelloServlet extends HttpServlet {
private static final long serialVersionUID = 1L;
public SayhelloServlet() {
super();
}
/**
* @see HttpServlet#doGet(HttpServletRequest request, HttpServletResponse response)
*/
protected void doGet(HttpServletRequest request, HttpServletResponse response)
throws ServletException, IOException {
ApplicationContext ctx = WebApplicationContextUtils.getWebApplicationContext(sce.getServletContext());
// 根據(jù) Spring 配置中的 Bean ID "item" 獲取訂閱到的服務(wù)
final Sayhello sayHello = (Sayhello) ctx.getBean("sayHello");
Thread thread = new Thread( new Runnable() {
@Override
public void run() {
while ( true ) {
try {
Thread.sleep(500l);
System.out.println(sayHello.sayHello());
System.out.println(sayHello.sayHello("tom"));
} catch ( Throwable e ) {
e.printStackTrace();
}
}
}
});
thread.start();
}
protected void doPost(HttpServletRequest request, HttpServletResponse response)
throws ServletException, IOException {
doGet(request, response);
}
}
傳遞自定義上下文開發(fā)示例 ，在構(gòu)建的Maven項目中導(dǎo)入下面依賴。 <dependency>
<groupId>com.taobao.hsf</groupId>
<artifactId>hsf-feature-context</artifactId>
</dependency>客戶端發(fā)起調(diào)用前，設(shè)置上下文。 RPCContext rpcContext = RPCContext.getClientContext();
rpcContext.putAttachment("tetantId", "123");
orderService.queryOrder(1L);服務(wù)端業(yè)務(wù)方法內(nèi)，獲取上下文。 RPCContext rpcContext = RPCContext.getServerContext();
String myContext = (String)rpcContext.getAttachment("tetantId");
服務(wù)接口：Pandora Boot 的服務(wù)基于接口實現(xiàn)，接口需在服務(wù)設(shè)計時預(yù)先定義設(shè)計好，生產(chǎn)者將實現(xiàn)該接口以提供具體的實現(xiàn)來提供服務(wù)，消費者也是基于此接口作為服務(wù)去訂閱。 服務(wù)生產(chǎn)者：生產(chǎn)者將實現(xiàn)之前定義的服務(wù)接口以提供具體實現(xiàn)，除了代碼實現(xiàn)的工作之外，所以還需要再定義服務(wù)發(fā)布的注解@HSFProvider配置標識為服務(wù)提供者。 服務(wù)消費者：消費者基于接口使用服務(wù)，具體調(diào)用時需要做兩個步驟： Spring 的配置文件使用標簽定義好一個Bean。 在使用的時候從Spring的context中將Bean取出。 構(gòu)建maven工程，創(chuàng)建完maven工程后，在pom.xml文件中配置EDAS的私服庫地址和插件私服庫地址。 <repositories>
<repository>
<id>central</id>
<url>http://repo1.maven.org/maven2</url>
<releases>
<enabled>true</enabled>
</releases>
<snapshots>
<enabled>true</enabled>
</snapshots>
</repository>
<repository>
<id>edas-oss-central</id>
<name>taobao mirror central</name>
<url>http://edas-public.oss-example.aliyuncs.com/repository</url>
<snapshots>
<enabled>true</enabled>
</snapshots>
<releases>
<enabled>true</enabled>
</releases>
</repository>
</repositories>
<pluginRepositories>
<pluginRepository>
<id>central</id>
<url>http://repo1.maven.org/maven2</url>
<releases>
<enabled>true</enabled>
</releases>
<snapshots>
<enabled>true</enabled>
</snapshots>
</pluginRepository>
<pluginRepository>
<id>edas-oss-plugin-central</id>
<url>http://edas-public.oss-example.aliyuncs.com/repository</url>
<snapshots>
<enabled>true</enabled>
</snapshots>
<releases>
<enabled>true</enabled>
</releases>
</pluginRepository>
</pluginRepositories>構(gòu)建maven工程，創(chuàng)建完maven工程后，在pom.xml文件中定義添加pandora boot和spring boot依賴的版本。 <properties>
<spring-boot.version>2.1.6.RELEASE</spring-boot.version>
<pandora-boot.version>2019-06-stable</pandora-boot.version>
</properties>
<dependencyManagement>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-dependencies</artifactId>
<version>${spring-boot.version}</version>
<type>pom</type>
<scope>import</scope>
</dependency>
<dependency>
<groupId>com.taobao.pandora</groupId>
<artifactId>pandora-boot-starter-bom</artifactId>
<version>${pandora-boot.version}</version>
<type>pom</type>
<scope>import</scope>
</dependency>
</dependencyManagement>在pom.xml添加pandora boot 和spring boot開發(fā)的依賴。 <dependencies>
<dependency>
<groupId>com.alibaba.boot</groupId>
<artifactId>pandora-hsf-spring-boot-starter</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>org.slf4j</groupId>
<artifactId>jcl-over-slf4j</artifactId>
</dependency>
<dependency>
<groupId>com.taobao.pandora</groupId>
<artifactId>pandora-boot-test</artifactId>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-actuator</artifactId>
</dependency>
<!-- Use Swagger UI for REST API test -->
<dependency>
<groupId>io.springfox</groupId>
<artifactId>springfox-swagger-ui</artifactId>
<version>2.6.1</version>
</dependency>
<dependency>
<groupId>io.springfox</groupId>
<artifactId>springfox-swagger2</artifactId>
<version>2.6.1</version>
</dependency>
</dependencies>在pom.xml文件中添加pandora boot應(yīng)用的maven打包插件。 <build>
<plugins>
<plugin>
<groupId>com.taobao.pandora</groupId>
<artifactId>pandora-boot-maven-plugin</artifactId>
<version>2.1.11.8</version>
<executions>
<execution>
<phase>package</phase>
<goals>
<goal>repackage</goal>
</goals>
</execution>
</executions>
</plugin>
</plugins>
</build>在工程目錄resources下的application.properties文件中配置應(yīng)用名和監(jiān)聽端口號。 spring.application.name=hsf-provider
server.port=8082
spring.hsf.version=1.0.0
spring.hsf.timeout=1000添加服務(wù)啟動的main函數(shù)入口。 @SpringBootApplication
public class HSFProviderApplication {
public static void main(String[] args) {
// 啟動 Pandora Boot 用于加載 Pandora 容器
PandoraBootstrap.run(args);
SpringApplication.run(HSFProviderApplication.class, args);
// 標記服務(wù)啟動完成,并設(shè)置線程 wait。防止用戶業(yè)務(wù)代碼運行完畢退出后，導(dǎo)致容器退出。
PandoraBootstrap.markStartupAndWait();
}
}對于服務(wù)提供者，其創(chuàng)建過程與以上構(gòu)建Pandora Boot maven工程步驟一致外，需要定義服務(wù)接口EchoService提供給消費者訂閱。 public interface EchoService {
String echo(String string);
String echoFuture(String str);
String echoCallback(String str);
String echoHSFMix(int id);
String echoMQConsumer(String str);
}創(chuàng)建服務(wù)提供者的具體實現(xiàn)類EchoServiceImpl，并通過注解方式發(fā)布服務(wù)。 @HSFProvider(serviceInterface = EchoService.class, serviceGroup = "HSF", serviceVersion = "1.0.0")
public class EchoServiceImpl implements EchoService {
@Autowired
private EchoDao echoDao;
@Autowired
private SimpleMQConsumer simpleMQConsumer;
@Autowired
private SimpleMQProduce simpleMQProduce;
public String echo(String str) {
return "hello --" + str;
}
public String echoFuture(String str) {
return "welcome --" + str;
}
public String echoCallback(String str) {
return "welcome --" + str;
}
public String echoHSFMix(int id) {
//寫消息
simpleMQProduce.sendMsg(id+"");
return echoDao.findById(id).getUserName();
}
public String echoMQConsumer(String str) {
//訂閱消息
simpleMQConsumer.receive();
return str;
}
}對于服務(wù)消費者，其創(chuàng)建過程與以上構(gòu)建Pandora Boot maven工程步驟一致，添加服務(wù)提供者定義的接口復(fù)制到消費者服務(wù)工程。 public interface EchoService {
String echo(String string);
String echoFuture(String str);
String echoCallback(String str);
String echoHSFMix(int id);
String echoMQConsumer(String str);
}添加消費者服務(wù)配置類及業(yè)務(wù)邏輯代碼。 消費者服務(wù)配置類：
@Configuration
public class HsfConfig {
//通過注解的方式將服務(wù)消費者的實例注入到Spring的Context中,同步調(diào)用
@HSFConsumer(clientTimeout = 3000, serviceVersion = "1.0.0")
private EchoService echoService;
}
消費者服務(wù)實現(xiàn)調(diào)用HSF服務(wù)提供者：
@RestController
@RequestMapping(value = "/poc")
@Api(description = "HSF-POC功能測試接口")
public class ConsumerController {
@Autowired
private EchoService echoService;
@NacosValue(value = "${useLocalCache:false}", autoRefreshed = true)
private String useLocalCache;
@ApiOperation(value = "獲取服務(wù)者返回信息 A->C")
@RequestMapping(value = "/hsf-echo", method = RequestMethod.GET)
public String echo(@RequestParam("str") String str) {
return echoService.echo(str) + "\r\n";
}
@ApiOperation(value = "通過ID查詢數(shù)據(jù)庫獲取返回信息、RocketMQ寫信息 A->C")
@RequestMapping(value = "/hsf-echo-mix", method = RequestMethod.GET)
public String echoHSFMix(@RequestParam("id") int id) {
return echoService.echoHSFMix(id) + "\r\n";
}
@ApiOperation(value = "RocketMQ訂閱消息 A->C")
@RequestMapping(value = "/hsf-echo-mq", method = RequestMethod.GET)
public String echoMQConsumer(@RequestParam("str") String str) {
return echoService.echoMQConsumer(str) + "\r\n";
}
@ApiOperation(value = "獲取版本信息")
@RequestMapping(value = "/echo-version", method = RequestMethod.GET)
public String echoVersion() {
return "This is pandora boot version 2" + "\r\n";
}
}對于服務(wù)提供者，其創(chuàng)建過程與以上構(gòu)建Pandora Boot maven工程步驟一致外，需要定義服務(wù)接口EchoService提供給消費者訂閱，在EchoService添加Future異步調(diào)用的接口及實現(xiàn)類。 public interface EchoService {
String echoFuture(String str);
}
接口實現(xiàn)類：
@HSFProvider(serviceInterface = EchoService.class, serviceGroup = "HSF", serviceVersion =
"1.0.0")
public class EchoServiceImpl implements EchoService {
public String echoFuture(String str) {
return "welcome --" + str;
}
}對于服務(wù)消費者，其創(chuàng)建過程與以上構(gòu)建Pandora Boot maven工程步驟一致外，編寫Future異步調(diào)用代碼。 在配置類通過注解配置HSF接口方法為異步調(diào)用：
//Future異步調(diào)用
@HSFConsumer(serviceGroup = "HSF", serviceVersion = "1.0.0", futureMethods = "echoFuture")
private EchoService echoService;
編寫對外暴露請求的Future異步調(diào)用代碼：
@RequestMapping(value = "/hsf-echo-future", method = RequestMethod.GET)
public String echoFuture(@RequestParam("str") String str) {
String resp = echoService.echoFuture(str) + "\r\n";
System.out.println(resp);
//及時在當(dāng)前調(diào)用上下文中，獲取 future 對象；因為該對象是放在ThreadLocal中，同一線程中后續(xù)調(diào)用會覆蓋future對象，所以要及時取出。
HSFFuture hsfFuture = HSFResponseFuture.getFuture();
//這里才真正地獲取結(jié)果，如果調(diào)用還未完成，將阻塞等待結(jié)果，5000ms是等待結(jié)果的最大時間
try {
System.out.println(hsfFuture.getResponse(5000));
} catch (Throwable throwable) {
throwable.printStackTrace();
}
return resp;
}對于服務(wù)提供者，其創(chuàng)建過程與以上構(gòu)建Pandora Boot maven一致外，需要定義服務(wù)接口EchoService提供給消費者訂閱，在EchoService添加Callback異步調(diào)用的接口及實現(xiàn)類。 public interface EchoService {
String echoFuture(String str);
}
接口實現(xiàn)類：
@HSFProvider(serviceInterface = EchoService.class, serviceGroup = "HSF", serviceVersion = "1.0.0")
public class EchoServiceImpl implements EchoService {
public String echoFuture(String str) {
return "welcome --" + str;
}
}對于服務(wù)消費者，其創(chuàng)建過程與以上構(gòu)建Pandora Boot maven步驟一致外，編寫Future異步調(diào)用代碼。 注解配置HSF接口方法為callback調(diào)用：
@AsyncOn(interfaceName = EchoService.class, methodName = "echoCallback")
public class CallbackHandler implements HSFResponseCallback {
public void onAppException(Throwable t) {
t.printStackTrace();
}
public void onAppResponse(Object result) {
//取 callback 調(diào)用時設(shè)置的上下文
Object context = CallbackInvocationContext.getContext();
System.out.println(result.toString());
System.out.println(context);
}
public void onHSFException(HSFException e) {
e.printStackTrace();
}
}
編寫對外暴露請求的Callback異步調(diào)用代碼：
@RequestMapping(value = "/hsf-echo-callback", method = RequestMethod.GET)
public String echoCallback(@RequestParam("str") String str) {
String resp = echoService.echoCallback(str) + "\r\n";
System.out.println(resp);
return resp;
}首先在Maven項目pom.xml文件中添加依賴Starter： <dependency>
<groupId>com.alibaba.boot</groupId>
<artifactId>pandora-hsf-spring-boot-starter</artifactId>
</dependency>通常一個HSF Consumer需要在多個地方使用，但并不需要在每次使用的地方都用@HSFConsumer來標記。只需要寫一個統(tǒng)一個Config類，然后在其它需要使用的地方，直接@Autowired注入即可上述例子中的API配置等同于如下注解配置： @HSFConsumer(clientTimeout = 1000, methodSpecials =
@HSFConsumer.ConsumerMethodSpecial(methodName = "queryOrder", clientTimeout = "100"))
private OderService orderService;首先在Maven項目pom.xml文件中添加依賴Starter： <dependency>
<groupId>com.alibaba.boot</groupId>
<artifactId>pandora-hsf-spring-boot-starter</artifactId>
</dependency>服務(wù)端注解配置HSF服務(wù)超時設(shè)置： @HSFProvider(serviceInterface = OrderService.class, clientTimeout = 3000)
public class OrderServiceImpl implements OrderService {
@Autowired
private OrderDAO orderDAO;
@Override
public OrderModel queryOrder(Long id) {
return orderDAO.queryOrder(id);
}
}首先在Maven項目pom.xml文件中添加依賴Starter。 <dependency>
<groupId>com.alibaba.boot</groupId>
<artifactId>pandora-hsf-spring-boot-starter</artifactId>
</dependency>將@HSFProvider配置到實現(xiàn)的類型上，上述例子中的API配置等同于如下注解配置。 @HSFProvider(serviceInterface = OrderService.class, corePoolSize = 50, maxPoolSize = 200)
public class OrderServiceImpl implements OrderService {
@Autowired
private OrderDAO orderDAO;
@Override
public OrderModel queryOrder(Long id) {
return orderDAO.queryOrder(id);
}
}
本次最佳實踐，分析傳統(tǒng)HSF應(yīng)用的劣勢及升級至Pandora Boot開發(fā)的優(yōu)勢。將結(jié)合HSF代碼和Pandora Boot代碼進行詳解傳統(tǒng)HSF應(yīng)用如何升級至Pandora Boot開發(fā)。
背景信息
HSF開發(fā)應(yīng)用的劣勢在于HSF要使用指定的Ali-Tomcat容器，還需要在Ali-Tomcat等容器中加入sar包擴展，對用戶運行環(huán)境的侵入性大。而HSF開發(fā)的應(yīng)用程序最終以WAR包的形式運行，不符合微服務(wù)設(shè)計的輕量應(yīng)用理念。并且開發(fā)過程注入Bean需要編寫較多的xml文件配置。
而Pandora Boot開發(fā)應(yīng)用的優(yōu)勢就在于依賴容器Pandora，不需要Ali-Tomcat。而且Pandora Boot開發(fā)也兼容了完整的HSF功能，同時與Spring Boot無縫集成。所以使用Pandora Boot的同時也可以引入Spring Boot提供開箱即用的依賴模板。快速、敏捷的開發(fā)Spring框架的應(yīng)用程序，享受開發(fā)的便利。
Pandora Boot開發(fā)的應(yīng)用最終以FatJar包的形式運行，并且Pandora環(huán)境也可以直接在IDE中啟動，開發(fā)調(diào)試等效率將得到極大的提高。而Pandora Boot注入Bean通過注解的方式，也減少了繁雜的xml配置文件編寫，提高開發(fā)效率。
因為在傳統(tǒng)客戶中有HSF應(yīng)用升級至Pandora Boot開發(fā)的需求，所以針對客戶的需要，本次最佳實踐將詳細描述傳統(tǒng)HSF應(yīng)用和PandoraBoot應(yīng)用的開發(fā)，使單體微服務(wù)應(yīng)用的敏捷開發(fā)及拓展性有所提高。
HSF環(huán)境介紹及準備
產(chǎn)品組件
- Ali-Tomcat是EDAS中的服務(wù)運行依賴的一個容器，支持Servlet 3.0規(guī)范，支持WebSocket。包含服務(wù)的發(fā)布、訂閱、調(diào)用鏈追蹤等一系列的核心功能。
- Pandora是一個輕量級的隔離容器-taobao-hsf.sar，它用來隔離Webapp和中間件的依賴，也用來隔離中間件之間的依賴，并實現(xiàn)部署與應(yīng)用分離。
- 輕量級配置中心（Diamond）是淘寶內(nèi)部廣泛使用的配置中心，提供持久化管理和動態(tài)配置推送服務(wù)。應(yīng)用方發(fā)布的配置會通過持久化存儲保存，與發(fā)布者的生命周期無關(guān)。
- 動態(tài)配置推送是Diamond的核心功能，在淘寶內(nèi)部有很多應(yīng)用場景，如數(shù)據(jù)庫動態(tài)切換和擴容，業(yè)務(wù)系統(tǒng)開關(guān)配置運行時變更等。
- 輕量級注冊中心（ConfigServer）：主要用于非持久數(shù)據(jù)的發(fā)布和訂閱、數(shù)據(jù)的生命周期和TCP連接生命周期綁定、產(chǎn)品架構(gòu)基于發(fā)布訂閱模型和去中心無master設(shè)計，保證了系統(tǒng)的可擴展性、高可用。在集團內(nèi)部主要場景為分布式消息系統(tǒng)Notify、分布式RPC框架HSF提供地址發(fā)現(xiàn)服務(wù)。
基本結(jié)構(gòu)
HSF結(jié)構(gòu)分為6個部分，共同組合在一起可以提供全功能的分布式服務(wù)，分別是：
- 服務(wù)消費方：消費服務(wù)提供方提供的服務(wù)，服務(wù)消費者通過地址注冊中心訂閱服務(wù)，根據(jù)訂閱到的地址信息發(fā)起調(diào)用，地址注冊中心作為旁路不參與調(diào)用。
- 服務(wù)提供方： 在服務(wù)框架中真正提供服務(wù)功能實現(xiàn)的應(yīng)用實例，為了保障服務(wù)提供的高可用性，一般均是集群部署，同時將地址信息發(fā)布到地址注冊中心。
- 地址注冊中心：接受服務(wù)提供方發(fā)布的地址，當(dāng)服務(wù)消費方根據(jù)服務(wù)進行訂閱時，會將地址信息推送給服務(wù)消費方，注冊中心就是服務(wù)信息的中介，提供服務(wù)發(fā)現(xiàn)的能力
- 持久化配置中心：持久化的配置中心用于存儲 HSF 服務(wù)的各種治理規(guī)則，HSF 客戶端在啟動的過程中會向持久化配置中心訂閱各種服務(wù)治理規(guī)則，如路由規(guī)則、歸組規(guī)則、權(quán)重規(guī)則等，從而根據(jù)規(guī)則對調(diào)用過程的選址邏輯進行干預(yù)。
- 元數(shù)據(jù)存儲中心：元數(shù)據(jù)是指 HSF 服務(wù)對應(yīng)的方法列表以及參數(shù)結(jié)構(gòu)等信息，元數(shù)據(jù)不會對 HSF 的調(diào)用過程產(chǎn)生影響，因此元數(shù)據(jù)存儲中心也并不是必須的。但考慮到服務(wù)運維的便捷性，HSF客戶端在啟動時會將元數(shù)據(jù)上報到元數(shù)據(jù)存儲中心，以便提供給服務(wù)運維使用
- HSF運維平臺（HSF控制臺）：HSF 控制臺通過打通地址注冊中心 ConfigServer、持久化配置中心 Diamond、元數(shù)據(jù)存儲中心Redis，為用戶提供了一些列服務(wù)運維功能，包括服務(wù)查詢、服務(wù)治理規(guī)則管理、服務(wù)測試、服務(wù) Mock、單機運維等，旨在提高 HSF 服務(wù)研發(fā)的效率、運維的便捷性。
環(huán)境準備流程步驟
在進行開發(fā)前，需要準備以下基本內(nèi)容：
Pandora Boot環(huán)境介紹及準備
產(chǎn)品組件
- Pandora：一個輕量級的隔離容器-taobao-hsf.sar，它用來隔離Webapp和中間件的依賴，也用來隔離中間件之間的依賴，也實現(xiàn)部署與應(yīng)用分離。
- 輕量級配置及注冊中心：對于開發(fā)者可以在本地使用輕量級配置及注冊中心實現(xiàn)應(yīng)用的注冊、發(fā)現(xiàn)與配置管理，完成應(yīng)用的開發(fā)和測試。本地開發(fā)完應(yīng)用托管到EDAS服務(wù)上，EDAS內(nèi)置注冊及配置中心，因此注冊及配置功能仍然可以正常使用。
基本結(jié)構(gòu)
HSF結(jié)構(gòu)分為6個部分，共同組合在一起可以提供全功能的分布式服務(wù)，分別是：
- 服務(wù)消費方：消費服務(wù)提供方提供的服務(wù)，服務(wù)消費者通過地址注冊中心訂閱服務(wù)，根據(jù)訂閱到的地址信息發(fā)起調(diào)用，地址注冊中心作為旁路不參與調(diào)用。
- 服務(wù)提供方： 在服務(wù)框架中真正提供服務(wù)功能實現(xiàn)的應(yīng)用實例，為了保障服務(wù)提供的高可用性，一般均是集群部署，同時將地址信息發(fā)布到地址注冊中心。
- 地址注冊中心：接受服務(wù)提供方發(fā)布的地址，當(dāng)服務(wù)消費方根據(jù)服務(wù)進行訂閱時，會將地址信息推送給服務(wù)消費方，注冊中心就是服務(wù)信息的中介，提供服務(wù)發(fā)現(xiàn)的能力
- 持久化配置中心：持久化的配置中心用于存儲 HSF 服務(wù)的各種治理規(guī)則，HSF 客戶端在啟動的過程中會向持久化配置中心訂閱各種服務(wù)治理規(guī)則，如路由規(guī)則、歸組規(guī)則、權(quán)重規(guī)則等，從而根據(jù)規(guī)則對調(diào)用過程的選址邏輯進行干預(yù)。
- 元數(shù)據(jù)存儲中心：元數(shù)據(jù)是指 HSF 服務(wù)對應(yīng)的方法列表以及參數(shù)結(jié)構(gòu)等信息，元數(shù)據(jù)不會對 HSF 的調(diào)用過程產(chǎn)生影響，因此元數(shù)據(jù)存儲中心也并不是必須的。但考慮到服務(wù)運維的便捷性，HSF客戶端在啟動時會將元數(shù)據(jù)上報到元數(shù)據(jù)存儲中心，以便提供給服務(wù)運維使用
- HSF運維平臺（HSF控制臺）：HSF 控制臺通過打通地址注冊中心 ConfigServer、持久化配置中心 Diamond、元數(shù)據(jù)存儲中心Redis，為用戶提供了一些列服務(wù)運維功能，包括服務(wù)查詢、服務(wù)治理規(guī)則管理、服務(wù)測試、服務(wù) Mock、單機運維等，旨在提高 HSF 服務(wù)研發(fā)的效率、運維的便捷性。
環(huán)境準備流程步驟
在進行開發(fā)前，需要準備一下基本內(nèi)容：
HSF開發(fā)流程及流程圖
開發(fā)流程節(jié)點：
圖 1.?流程圖
開發(fā)HSF應(yīng)用
背景信息
您需要按以下步驟構(gòu)建HSF maven工程：
定義服務(wù)接口
HSF服務(wù)基于接口實現(xiàn)調(diào)用，定義好接口Sayhello后，生產(chǎn)者將使用該接口實現(xiàn)具體的服務(wù)，消費者也基于此接口訂閱服務(wù)，所以一般會將接口定義在一個工程中，它會打成一個jar包，發(fā)布到maven倉庫中。下面是公共模塊edasdemo-api接口定義代碼：
package com.edas.demo; public interface Sayhello { public String sayHello(); public String sayHello(String name); }編寫HSF服務(wù)提供者
編寫HSF服務(wù)消費者
開發(fā)HSF異步調(diào)用
異步調(diào)用
對于客戶端來說，并不是所有的HSF服務(wù)都需要同步等待服務(wù)端返回結(jié)果，對于這些場景，HSF提供異步調(diào)用的方式，讓客戶端不必同步阻塞在HSF操作上。在HSF服務(wù)發(fā)起異步調(diào)用，調(diào)用結(jié)果都是返回的默認值。而真正的結(jié)果要在HSFResponseFuture或者回調(diào)函數(shù)callback中獲取。
Futrue異步調(diào)用
HSF與Spring框架無縫集成，可以使用Spring XML的方式進行Future異步調(diào)用配置。
Callback異步調(diào)用
使用Spring XML進行Callback異步調(diào)用配置。
開發(fā)HSF泛化調(diào)用
背景信息
相對于依賴業(yè)務(wù)客戶端Jar包的正常調(diào)用，需要依賴二方包，使用特定的GenericService接口，而傳入需要調(diào)用的方法名，方法簽名和參數(shù)值進行調(diào)用服務(wù)。泛化調(diào)用更適用于一些網(wǎng)關(guān)應(yīng)用，其中hsfops服務(wù)測試也是依賴泛化調(diào)用功能。
API形式配置HSF服務(wù)
將HSFConsumerBean，配置generic為true，標識客戶端忽略加載不到接口的異常。
GenericService提供的$invoke方法包含了真實調(diào)用的方法名、入?yún)㈩愋秃蛥?shù)，以便服務(wù)端找到改方法。由于沒有依賴服務(wù)端的API jar包，傳入的參數(shù)如果是自定義的DTO，需要轉(zhuǎn)成客戶端可以序列化的Map類型。
Spring配置HSF服務(wù)
上面描述了通過API配置HSF服務(wù)，也可以通過Spring XML配置HSF服務(wù)。
調(diào)用上下文
背景信息
請求上下文包括一次性調(diào)用相關(guān)的屬性，比如調(diào)用的地址，調(diào)用方的應(yīng)用名，超時時間等屬性和用戶在接口定義的參數(shù)之外傳遞自定義的數(shù)據(jù)。
設(shè)置和獲取本次調(diào)用上下文
com.taobao.hsf.util.RequestCtxUtil提供設(shè)置和獲取調(diào)用上下文的靜態(tài)方法，基于ThreadLocal工作，getXXX操作會將XXX屬性從當(dāng)前ThreadLocal變量中remove掉，僅作用于當(dāng)前線程的單次調(diào)用。
?表1. 客戶端
| 名稱 | 描述 |
| setRequestTimeout() | 設(shè)置單次調(diào)用的超時時間 |
| setUserId() | 設(shè)置本次調(diào)用的單元化服務(wù)的userId（泛化調(diào)用中需要通過此方法配置） |
| getProviderIp() | 獲取【最近一次】調(diào)用的服務(wù)端的IP |
| setTargetServerIp(String ip) | 設(shè)置當(dāng)前線程下一次調(diào)用的目標服務(wù)器IP（此IP必須包含在內(nèi)存已提供服務(wù)的地址列表里） |
| setDirectTargetServerIp(String targetIp) | 設(shè)置當(dāng)前線程下一次調(diào)用的目標服務(wù)器IP（繞過注冊中心，忽略內(nèi)存里的地址列表） |
表 2.?服務(wù)端
| 名稱 | 描述 |
| getClientIp() | 服務(wù)端獲取調(diào)用方IP |
| getAppNameOfClient() | 服務(wù)端獲取調(diào)用方的應(yīng)用名 |
| isHttpRequest() | 是否是http調(diào)用 |
| getHttpHeader(String key) | 獲取http請求的header屬性 |
傳遞自定義請求上下文
RpcContext提供一種不修改接口，向服務(wù)端額外傳遞數(shù)據(jù)的方式。參數(shù)可以是自定義的DO或者基本類型。要保證對端也有該對應(yīng)的類型，并且可以能夠被序列化。
配置序列化
序列化的過程是將JAVA對象轉(zhuǎn)成byte數(shù)組在網(wǎng)絡(luò)中傳輸，反序列化會將byte數(shù)組轉(zhuǎn)成JAVA對象。
序列化方式配置
序列化的選擇需要考慮兼容性，性能等因素，HSF的序列化方式支持JAVA、hessian、hessian2、JSON、kyro，默認是hessian2。這些序列化方式的對比和配置（只在服務(wù)端配置HSFApiProviderBean）如下表所示：
| 序列化方式 | maven依賴 | 配置 | 兼容性 | 性能 |
| hessian2 | <artifactId>hsf-io-serialize-hessian2</artifactId> | setPreferSerializeType("hessian2") | 好 | 好 |
| java | <artifactId>hsf-io-serialize-java</artifactId> | setPreferSerializeType("java") | 最好 | 一般 |
| fastjson | <artifactId>hsf-io-serialize-json</artifactId> | setPreferSerializeType("json") | 好 | 好 |
| kryo | <artifactId>hsf-io-serialize-kryo</artifactId> | setPreferSerializeType("kryo") | 一般 | 最好 |
API形式配置HSF服務(wù)
Spring配置HSF服務(wù)
Spring框架是在應(yīng)用中廣泛使用的組件，如果不想通過API的形式配置HSF服務(wù)，可以使用Spring XML的形式進行配置，上述例子中的API配置等同于如下XML配置：
超時設(shè)置
背景信息
有關(guān)網(wǎng)絡(luò)調(diào)用的請求，都需要配置超時，HSF的默認超時時間是3000ms。客戶端和服務(wù)端都可以設(shè)置超時，默認優(yōu)先采用客戶端的配置，如果客戶端沒有配置，使用服務(wù)端的超時配置。在服務(wù)端設(shè)置超時時，需要考慮到業(yè)務(wù)本身的執(zhí)行耗時，加上序列化和網(wǎng)絡(luò)通訊的時間。所以推薦服務(wù)端給每個服務(wù)都配置個默認的時間。當(dāng)然客戶端也可以根據(jù)自己的業(yè)務(wù)場景配置超時時間，比如一些前端應(yīng)用，需要用戶快速看到結(jié)果，可以把超時時間設(shè)置小一些。
客戶端超時配置
客戶端超時配置有以下兩種方式：
- API形式配置HSF服務(wù)，配置HSFApiConsumerBean的clientTimeout屬性，單位是ms，我們把接口的超時配置為1000ms，方法queryOrder配置為100ms，代碼如下：
- Spring配置HSF服務(wù)，上述例子中的API配置等同于如下XML配置：
服務(wù)端超時配置
服務(wù)端超時配置也有兩種不同的方式：
- API形式配置HSF服務(wù)，配置HSFApiProviderBean的clientTimeout屬性，單位是ms，代碼如下：
- Spring配置HSF服務(wù)，上述例子中的API配置等同于如下XML配置：
服務(wù)端線程池配置
HSF服務(wù)端線程池主要分為IO線程和業(yè)務(wù)線程，其中IO線程模型就是netty reactor網(wǎng)絡(luò)模型中使用的。
默認線程池配置
服務(wù)端線程池是用來執(zhí)行業(yè)務(wù)邏輯的線程池，線程池默認的core size是50，max size是720，keepAliveTime 500s。隊列使用的是SynchronousQueue，沒有緩存隊列，不會堆積用戶請求。 當(dāng)服務(wù)端線程池所有線程（720）都在處理請求時，對于新的請求，會立即拒絕，返回Thread pool is full異常。可以使用下面VM參數(shù)（-D參數(shù)）進行配置。
- 線程池最小配置：-Dhsf.server.min.poolsize。
- 線程池最大的配置：-Dhsf.server.max.poolsize。
- 線程收斂的存活時間：-Dhsf.server.thread.keepalive。
服務(wù)線程池配置
對于一些慢服務(wù)、并發(fā)高，可以為其單獨配置線程池，以免占用過多的業(yè)務(wù)線程，影響應(yīng)用的其他服務(wù)的調(diào)用，你可以通過以下兩種方式配置HSF應(yīng)用：
- API形式配置HSF應(yīng)用：
- Spring配置HSF應(yīng)用：
Pandora Boot開發(fā)流程
開發(fā)流程節(jié)點：
開發(fā)Pandora Boot應(yīng)用
構(gòu)建Pandora Boot maven工程
編寫Pandora Boot服務(wù)提供者
編寫Pandora Boot消費者服務(wù)
開發(fā)Pandora Boot異步調(diào)用
對于客戶端來說，并不是所有的HSF服務(wù)都是需要同步等待服務(wù)端返回結(jié)果的，對于這些場景，HSF提供異步調(diào)用的方式，讓客戶端不必同步阻塞在HSF操作上。在HSF服務(wù)發(fā)起異步調(diào)用，調(diào)用結(jié)果都是返回的默認值。而真正的結(jié)果要在HSFResponseFuture或者回調(diào)函數(shù)callback中獲取。
Futrue異步調(diào)用
Callback異步調(diào)用
開發(fā)Pandora Boot超時設(shè)置
背景信息
注解配置HSF服務(wù)，SpringBoot廣泛使用的今天，使用注解裝配SpringBean也成為一種選擇，HSF也支持使用注解進行配置，用來訂閱服務(wù)。
客戶端注解超時配置
服務(wù)端注解超時配置
開發(fā)Pandora Boot服務(wù)線程池配置
背景信息
注解配置HSF服務(wù)，SpringBoot被廣泛使用的今天，使用注解裝配SpringBean也成為一種選擇，HSF也支持使用注解進行配置，用來訂閱服務(wù)。
我們是阿里云智能全球技術(shù)服務(wù)-SRE團隊，我們致力成為一個以技術(shù)為基礎(chǔ)、面向服務(wù)、保障業(yè)務(wù)系統(tǒng)高可用的工程師團隊；提供專業(yè)、體系化的SRE服務(wù)，幫助廣大客戶更好地使用云、基于云構(gòu)建更加穩(wěn)定可靠的業(yè)務(wù)系統(tǒng)，提升業(yè)務(wù)穩(wěn)定性。我們期望能夠分享更多幫助企業(yè)客戶上云、用好云，讓客戶云上業(yè)務(wù)運行更加穩(wěn)定可靠的技術(shù)，您可用釘釘掃描下方二維碼，加入阿里云SRE技術(shù)學(xué)院釘釘圈子，和更多云上人交流關(guān)于云平臺的那些事。
原文鏈接：https://developer.aliyun.com/article/784841?
版權(quán)聲明：本文內(nèi)容由阿里云實名注冊用戶自發(fā)貢獻，版權(quán)歸原作者所有，阿里云開發(fā)者社區(qū)不擁有其著作權(quán)，亦不承擔(dān)相應(yīng)法律責(zé)任。具體規(guī)則請查看《阿里云開發(fā)者社區(qū)用戶服務(wù)協(xié)議》和《阿里云開發(fā)者社區(qū)知識產(chǎn)權(quán)保護指引》。如果您發(fā)現(xiàn)本社區(qū)中有涉嫌抄襲的內(nèi)容，填寫侵權(quán)投訴表單進行舉報，一經(jīng)查實，本社區(qū)將立刻刪除涉嫌侵權(quán)內(nèi)容。總結(jié)
以上是生活随笔為你收集整理的专有云传统HSF升级Pandora Boot开发的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。
- 上一篇： 未来，让我们一起想象 — “Imagin
- 下一篇： 全链路压测构建高可用应用最佳实践