淘寶(taobao)HSF框架
http://www.cnblogs.com/mengheyun/archive/2010/12/16/1963077.html
一、背景
隨著網站訪問量增加，僅僅靠增加機器已不能滿足系統的要求，於是需要對應用系統進行垂直拆分和水平拆分。在拆分之後，各個被拆分的模塊如何通信？如何保證性能？如何保證各個應用都以同樣的方式交互？這就需要一種負責各個拆分的模塊間通信的高性能服務框架(HSF)。
二、HSF做的事情
1. 標準Service方式的RPC
1）. service定義：基於OSGI的service定義方式
2）. TCP/IP通信：
IO方式：nio,采用mina框架
連接方式：長連接
服務器端有限定大小的連接池
WebService方式
3）. 序列化：hessian序列化機制
2. 軟件負載體系
采用軟件實現負載均衡，支持隨機、輪詢、權重、按應用路由等方式。軟件負載均衡沒有中間點，通過配置中心統一管理。配置中心收集服務提供者和消費者的註冊信息，以推送的方式發送到服務消費者直接使用，不經過中間點；註冊中心可以感應服務器的狀態，出現failover時，實現註冊信息重新推送。
3. 模塊化、動態化
4. 服務治理
服務治理利用註冊中心實現服務信息管理（服務提供者、調用者信息查詢）、服務依賴關系分析、服務運行狀況感知、服務可用性保障，如：路由調整、流量分配、服務端降級、調用端降級等
本文來自CSDN博客，轉載請標明出處：http://blog.csdn.net/marine2010/archive/2010/03/21/5401366.aspx
背景: WEBX -- 阿裏巴巴網站所采用的WEB應用框架.
HSF接口: com.taobao.item.service.ItemQueryService
需求: 根據商品ID取得商品信息
載體: TBCMS系統
實現步驟: 1. 創建 /bundle/war/src/webroot/META-INF/autoconf/item-hsf-xml.vm
代碼:
<?xml version="1.0" encoding="GB2312"?>
<!DOCTYPE beans PUBLIC "-//SPRING//DTD BEAN//EN" "http://www.springframework.org/dtd/spring-beans.dtd">
<beans default-autowire="byName">
<bean id="itemQueryService" class="com.taobao.hsf.app.spring.util.HSFSpringConsumerBean" init-method="init">
<property name="interfaceName">
<value>com.taobao.item.service.ItemQueryService</value>
</property>
<property name="version">
<value>${item_provide_service_version}
</property>
<!--asyncallMethods為可選配置[List]，含義為調用此服務時需要采用異步調用的方法名列表，默認為空集合，即所有方法都采用同步調用-->
<property name="asyncallMethods">
<list>
</list>
</property>
</bean>
</beans>
2.其中: ${item_provide_service_version} 需要在 auto-config.xml 中配置,在 <group name="arkcms-bundle-war"> ...</group>中增加:
<property name="item.provide.service.version" defaultValue="1.0.0.daily" desc="itemClient調用版本"/>
同時在 <script>...</script>中增加:
<generate template="item-hsf.xml.vm" destfile="WEB-INF/biz/bean/item-hsf.xml" charset="GBK"/>
3.在 /bundle/war/src/webroot/WEB-INF/cms-biz-services.xml中增加:
<service name="BeanFactoryService" class="com.alibaba.service.spring.DefaultBeanFactoryService">
<property name="bean.descriptors">
....................
<value>/cms/biz/bean/item-hsf.xml</value>
</property>
</service>
至此,我們已經引入了ItemQueryService的HSF服務.
4. 接下來我們就要做Servlet接口了,當然寫一個servlet直接調用hsf也是可以的,但是從結構考慮,我們還是先本地封裝一層先.
但是首先,需要對 /all/project.xml 中需要增加對ItemQueryService的支持:
<projects name="taobao/itemcenter" version="1.9.5">
<project id="taobao/itemcenter/itemcenter-client"/>
<project id="taobao/itemcenter/itemcenter-common"/>
</projects>
並在/biz/project.xml和/web/project.xml中增加:
<?xml version="1.0" encoding="GB2312"?>
<project id="tbcms/web" extends="../all/project.xml">
<build>
<dependencies>
............
<include uri="taobao/itemcenter/itemcenter-client"/>
<include uri="taobao/itemcenter/itemcenter-common"/>
</dependencies>
</build>
</project>
命令行模式下執行:antx reactor goals=eclipse來執行對依賴包的裝載.(前提是對/antx/repository.project/taobao/itemcenter/進行SVN更新)
本地封裝: 在/biz/src/java/com/ark/cms/biz/util/item/下創建ItemService.java接口:
package com.ark.cms.biz.util.item;
import com.taobao.item.domain.DbRoute;
import com.taobao.item.domain.query.ItemIdDO;
import com.taobao.item.domain.result.ItemResultDO;
import com.taobao.item.exception.IcException;
/**
* 根據id取得商品信息
* @author duxing
*
*/
public interface ItemService {
public ItemResultDO getItemById(ItemIdDO itemId,DbRoute mainDbRoute) throws IcException;
}
在biz/src/java/com/ark/cms/biz/util/item/impl/下 ItemServiceImpl.java進行實現:
package com.ark.cms.biz.util.item.impl;
import com.ark.cms.biz.util.item.ItemService;
import com.taobao.item.domain.DbRoute;
import com.taobao.item.domain.query.ItemIdDO;
import com.taobao.item.domain.query.QueryItemOptionsDO;
import com.taobao.item.domain.result.ItemResultDO;
import com.taobao.item.exception.IcException;
import com.taobao.item.service.ItemQueryService;
/**
* 根據id取得商品信息 實現
* @author duxing
*
*/
public class ItemServiceImpl implements ItemService {
private ItemQueryService itemQueryService;
public void setItemQueryService(ItemQueryService itemQueryService) {
this.itemQueryService = itemQueryService;
}
@SuppressWarnings("deprecation")
public ItemResultDO getItemById(ItemIdDO itemId, DbRoute mainDbRoute) throws IcException {
QueryItemOptionsDO options = null;
return itemQueryService.queryItemById(itemId, options, mainDbRoute);
}
}
然後將此接口移交給spring,在 /bundle/war/src/webroot/META-INF/autoconf/item-hsf-xml.vm中增加
<bean id="itemService" class="com.ark.cms.biz.util.item.impl.ItemServiceImpl"></bean>
至此,我們已經在spring中產生一個itemService
5.接下來創建servlet
在/web/src/java/com/ark/cms/web/下創建ItemServiceServlet.java
因為servlet中不能直接用set形式讓spring來set itemService進來,所以只能采用一下方法獲取itemService:
BeanFactoryService beanFactory = (BeanFactoryService) BizServiceManager.getInstance().getService(BeanFactoryService.SERVICE_NAME);
ItemService itemService = (ItemService) beanFactory.getBean("itemService");
完整代碼如下:
package com.ark.cms.web;
import java.io.IOException;
import java.io.OutputStream;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import com.alibaba.service.spring.BeanFactoryService;
import com.ark.cms.biz.core.BizServiceManager;
import com.ark.cms.biz.util.item.ItemService;
import com.taobao.item.domain.DbRoute;
import com.taobao.item.domain.ItemDO;
import com.taobao.item.domain.query.ItemIdDO;
import com.taobao.item.domain.result.ItemResultDO;
import com.taobao.item.exception.IcException;
/**
* 根據id取得商品大圖的接口
* @author duxing
*
*/
public class ItemServiceServlet extends HttpServlet {
private static final long serialVersionUID = -3348559907279438489L;
@Override
protected void doPost(HttpServletRequest request,
HttpServletResponse response) throws ServletException, IOException {
// http://item.taobao.com/auction/item_detail-db1-67af640ba3f16a2006cd63f1f...
// long itemId=4399800173l;
String item_id = request.getParameter("item_id");
String xid = request.getParameter("xid");
DbRoute mainDbRoute=DbRoute.getDbRouteByXid(xid);
ItemIdDO itemIDDO=new ItemIdDO();
if(item_id!=null){
itemIDDO.setItemIdStr(item_id);
}
if(request.getParameter("item_num_id")!=null){
Long item_num_id = Long.valueOf(request.getParameter("item_num_id"));
itemIDDO.setItemId(item_num_id);
}
if(request.getParameter("id")!=null){
Long id = Long.valueOf(request.getParameter("id"));
itemIDDO.setItemId(id);
}
// 兩種id的傳入方式
// itemIDDO.setItemId(itemId);
// itemIDDO.setItemIdStr("67af640ba3f16a2006cd63f1f5dddc271");
ItemResultDO itemResultDO;
BeanFactoryService beanFactory = (BeanFactoryService) BizServiceManager.getInstance().getService(BeanFactoryService.SERVICE_NAME);
ItemService itemService = (ItemService) beanFactory.getBean("itemService");
try {
itemResultDO=itemService.getItemById(itemIDDO, mainDbRoute);
} catch (IcException e) {
e.printStackTrace();
itemResultDO=new ItemResultDO();
}
ItemDO itemDO=itemResultDO.getItem();
byte[] result="".getBytes();
if(itemDO!=null){
result=itemDO.getPictUrl().getBytes();
}
response.setContentType("text/xml;charset=gb2312");
response.setContentLength(result.length);
OutputStream out = response.getOutputStream();
out.write(result);
out.flush();
}
}
6.servlet寫好了之後我們就要配置進WEBX了:
在 /bundle/war/src/webroot/META-INF/autoconf/web.xml.vm中增加:
<servlet-mapping>
<servlet-name>ItemServiceServlet</servlet-name>
<url-pattern>/item/query</url-pattern>
</servlet-mapping>
<servlet>
<servlet-name>ItemServiceServlet</servlet-name>
<servlet-class>com.ark.cms.web.ItemServiceServlet</servlet-class>
</servlet>
7.至此,開發完成
命令行模式下執行:antx reactor goals=clean,default來對項目重新編譯打包.重啟本地服務器進行測試.
對/item/query接口進行post的時候觸發此servlet.
淘寶(taobao)HSF框架