前言：剛完成的Spring基礎專題本想更新原始碼的，但是發現分布式非常火，而我喜歡玩這個，所以今年我希望把我的知識可以分享給正在奮斗中的互聯網開發人員，以及未來想往架構師上走的道友們我們一起進步，從一個互聯網職場小白到一個滬漂濕人，一路讓我知道分享是一件多么重要的事情，總之不對的地方，多多指出，我們一起徜徉代碼的海洋！
我這里做每個章節去說的前提，不是一定很標準的套用一些官方名詞，目的是為了讓大家可以理解更加清楚，如果形容的不恰當，可以留言出來，萬分感激！
1、工程搭建
睡醒了，接著上節的講，我們還是這個圖，要實作下面的三個模塊，那么對于新手來說，可能不知道什么是公共介面層，那這我就先不做這一層，我先做兩個工程，一個是訂單模塊作為消費者，一個是用戶服務模塊作為生產者
實作的業務是，訂單服務要查詢用戶的地址，訂單是有用戶的地址的！
我這里拿idea演示步驟，順便講下多工程是怎么創建的，如果會的人，就快速過一遍就好了~！
先創建一個父類的pom檔案，這個pom是管理里面的所有的專案及其子專案的！
接下來
接著
點擊finish，然后專案建成了，再點擊右鍵new——module
還是這個老界面
2、創建一個消費者gmall-order-service
下一步，然后保持默認的
然后finish后，成這樣，注意，你要把src洗掉，洗掉后是這樣
這個時候我們再建gmall-user，是生產者，用戶服務模塊
重復上面的步驟，我不寫了啊，結果專案結構是這樣的！（有些細節不用太在意，我們本節的目的是dubbo的基礎開發）
此時我們創建一個類，叫做UserAddress，在com.chenxin.dubbo.entity下，此類是用戶地址類
/** * 用戶地址 * * @author chenxin */ public class UserAddress implements Serializable { private Integer id; //用戶地址 private String userAddress; //用戶id private String userId; //識訓人 private String consignee; //電話號碼 private String phoneNum; //是否為默認地址 Y-是 N-否 private String isDefault; public UserAddress() { super(); // TODO Auto-generated constructor stub } public UserAddress(Integer id, String userAddress, String userId, String consignee, String phoneNum, String isDefault) { super(); this.id = id; this.userAddress = userAddress; this.userId = userId; this.consignee = consignee; this.phoneNum = phoneNum; this.isDefault = isDefault; } public Integer getId() { return id; } public void setId(Integer id) { this.id = id; } public String getUserAddress() { return userAddress; } public void setUserAddress(String userAddress) { this.userAddress = userAddress; } public String getUserId() { return userId; } public void setUserId(String userId) { this.userId = userId; } public String getConsignee() { return consignee; } public void setConsignee(String consignee) { this.consignee = consignee; } public String getPhoneNum() { return phoneNum; } public void setPhoneNum(String phoneNum) { this.phoneNum = phoneNum; } public String getIsDefault() { return isDefault; } public void setIsDefault(String isDefault) { this.isDefault = isDefault; } }再寫個業務類UserService，在com.chenxin.dubbo.service下
/** * 用戶服務 * @author chenxin * */ public interface UserService { /** * 按照用戶id回傳所有的識訓地址 * @param userId * @return */ public List<UserAddress> getUserAddressList(String userId); }實作類com.chenxin.dubbo.service.impl.UserServiceImpl，我這里就不連接資料庫不做這么復雜了，簡簡單單的過下核心的東西！
public class UserServiceImpl implements UserService { @Override public List<UserAddress> getUserAddressList(String userId) { System.out.println("UserServiceImpl.....old..."); // TODO Auto-generated method stub UserAddress address1 = new UserAddress(1, "阿里西溪園區螞蟻金服大樓", "1", "chenxin", "010-56253825", "Y"); UserAddress address2 = new UserAddress(2, "阿里西溪園區支付寶大樓", "1", "chenxin2", "010-56253825", "N"); return Arrays.asList(address1,address2); } }那么服務的提供者我已經寫好了，接下來我寫服務的呼叫者，也就是訂單服務！
3、創建服務的消費者gmall-order-service
創建工程依舊是maven工程，我這里不重復創建了
我需要一個訂單的service業務，進行訂單的業務處理
public interface OrderService { List<UserAddress> initOrder(String userId); }實作類
@Service public class OrderServiceImpl implements OrderService { @Autowired private UserService userService; @Override public List<UserAddress> initOrder(String userId) { // TODO Auto-generated method stub System.out.println("用戶id：" + userId); //1、查詢用戶的識訓地址 List<UserAddress> addressList = userService.getUserAddressList(userId); for (UserAddress userAddress : addressList) { System.out.println(userAddress.getUserAddress()); } return addressList; } }但是這個時候在訂單服務里，需要用到查詢用戶的地址，所以就需要有重復的UserAddress類，因為需要注入，所以需要用到UserService，所以你需要在訂單服務里，也要寫OrderService，你看，代碼是不是重復了？
給你看下最后的效果！
所以你知道為什么Dubbo官網建議我們有句話，建議將服務介面、服務模型、服務例外等均放在 API 包中！！！！
所以我們需要多一個專案，這個專案只放：物體類+api介面，因為這些都是重復可以被重復使用的，很有可能其他的服務也要呼叫UserService這個介面，去呼叫里面的方法，當然不僅僅是這個用法，后面我再說
此時新建一個專案叫做api-service，其實就是文章開始前的gmall-interface這個專案，因為屬于公共介面層，所以我這里就命名為api-service
我們把所有的介面，和物體類都放在里面，pom檔案記得要加上這個api-service的依賴，我這里就默認知道你們是懂maven的，不懂的就回去看看maven，
那么這個結構就已經完成了，代碼我會貼出來的，到時候你們下下來看看，
那么這個時候，訂單服務在A服務器上，用戶服務在B服務器上，他們怎么進行通信呢？對，就是RPC，就好像呼叫本地一樣，不會改什么代碼，
所以我們要把這兩個服務做成可以支持遠程呼叫的
1、引入dubbo的依賴，提供方和呼叫方都要引入，注意我用的是2.6.x版本后，用的curator依賴，操作Zookeeper，2.6之前的用zkClient依賴，所以根據你專案的來，我這用的是2.6.2版本
<!-- 引入dubbo --> <!-- https://mvnrepository.com/artifact/com.alibaba/dubbo --> <dependency> <groupId>com.alibaba</groupId> <artifactId>dubbo</artifactId> <version>2.6.2</version> </dependency> <!-- 注冊中心使用的是zookeeper，引入操作zookeeper的客戶端 --> <dependency> <groupId>org.apache.curator</groupId> <artifactId>curator-framework</artifactId> <version>2.12.0</version> </dependency>2、將服務提供者user注冊到注冊中心，也就是暴露服務，
怎么暴露呢，官網上有相關說明
所以我這創建一個provider.xml在用戶服務的resource下，代碼可以從官網貼來后改改
<?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:dubbo="http://dubbo.apache.org/schema/dubbo" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.3.xsd http://dubbo.apache.org/schema/dubbo http://dubbo.apache.org/schema/dubbo/dubbo.xsd"> <!-- 提供方應用資訊，用于計算依賴關系 --> <dubbo:application name="gmall-user" /> <!-- 使用zookeeper注冊中心暴露服務地址 --> <dubbo:registry address="zookeeper://127.0.0.1:2181" /> <!-- 用dubbo協議在20880埠暴露服務 --> <dubbo:protocol name="dubbo" port="20880" /> <!-- 宣告需要暴露的服務介面 --> <dubbo:service interface="com.chenxin.dubbo.service.UserService" ref="userService" /> <!-- 和本地bean一樣實作服務 --> <bean id="userService" class="com.chenxin.dubbo.service.impl.UserServiceImpl" /> </beans>看下標簽的意義：我還是貼出來官網的圖
所以對于xml的標簽意思，對著這個圖看看就可以了，應該都是很好理解的，
注意幾個點，因為我們當前用的注冊中心是zookeeper，所以我這里寫的registry是 <dubbo:registry address="zookeeper://127.0.0.1:2181" />
詳見：其實官網真的很詳細，要學會看官方檔案!!!!
那我們到這就完成了暴露程序，我們可以寫個main函式試試看是不是真的，
測驗下main函式后，因為本地已經啟動了dubbo-admin服務，所以我們訪問下localhost:7001 看看，因為main函式我寫了個read卡著，就可以看到下圖的效果，我的UserService已經被暴露在這上面了
有很多初學者會疑惑，這個界面哪來的，這個界面其實是dubbo-admin的埠，zk的埠是2181，所以千萬不要認為這個是注冊中心的界面啊，zk是一個協議，協議，不是一個控制臺的東西，千萬記住，
3、服務的消費者，就是order模塊，要訂閱服務的提供者的介面
同樣我在order專案的resource下建立一個consumer.xml
<beans xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:dubbo="http://dubbo.apache.org/schema/dubbo" xmlns="http://www.springframework.org/schema/beans" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://dubbo.apache.org/schema/dubbo http://dubbo.apache.org/schema/dubbo/dubbo.xsd"> <dubbo:application name="gmall-order-web"/> <dubbo:registry address="zookeeper://127.0.0.1:2181"/> <dubbo:reference id="userService" interface="com.chenxin.dubbo.service.UserService"/> </beans>同樣標簽的意思，服務消費者為什么要也要寫registry？因為你要去呼叫，需要發現注冊中心的地方在哪里，不然怎么能發現其他的服務呢，
同樣reference是參考的意思，你要參考提供者的什么呢，當然是介面UserService了，
寫個消費者的測驗類：
public class OrderApplication { @SuppressWarnings("resource") public static void main(String[] args) throws IOException { ClassPathXmlApplicationContext applicationContext = new ClassPathXmlApplicationContext("consumer.xml"); OrderService orderService = applicationContext.getBean(OrderService.class); orderService.initOrder("1"); System.out.println("呼叫完成...."); System.in.read(); } }所以啟動后，發現消費者order，也注冊在zk中，并且控制臺也列印了呼叫的結果！！
這個時候如果你發現你啟動報錯no Provider，那把提供者重啟下就好了，后面我說原理為什么會這樣！
所以到這里我們的服務的呼叫者和消費者都已經成功注冊上Zookeeper并且在dubbo-admin的控制臺我們可以看到相關的資訊！！
代碼地址：
鏈接：https://pan.baidu.com/s/1XyFOfPDskI9lJbn2fThkvw 提取碼：hfui
到這，我們就通過簡單的Spring案例，將兩個服務注冊到注冊中心上，并且實作了服務提供者和服務消費者之間的簡單呼叫關系，模擬了rpc遠程呼叫的程序，實際上，你發現沒有，這個遠程呼叫，你只要暫時先理解為，就好比本地呼叫你的java代碼一樣，沒
有什么其他的變動，我們還是像在一個服務內，該寫注入寫注入，這就是rpc的特色，當然這是基礎的一點點，遠不止這些！！
下一節我來整合Springboot后，詳細說明Dubbo里面的很多使用，和屬性點，敬請期待！！
轉載請註明出處，本文鏈接：https://www.uj5u.com/ruanti/282909.html
標籤：其他
下一篇：從零開始學架構-day04