基于dubbo protocol的demo怎么實現

這篇文章主要講解了“ 基于dubbo protocol的demo怎么實現”，文中的講解內容簡單清晰，易于學習與理解，下面請大家跟著小編的思路慢慢深入，一起來研究和學習“ 基于dubbo protocol的demo怎么實現”吧！

說明：本文基于redhat6做的demo，jdk等各種環境都已經就緒了。建議java開發者了解linux系統。

demo項目如圖：

運行結果如圖：

2、新建接口服務：com.enson.demo.service.DubboService

代碼：

package com.enson.demo.service;

public interface DubboService {
	
	public String printWord(String word);

}

3、實現接口：com.enson.demo.service.impl.DubboServiceImpl

代碼：

package com.enson.demo.service.impl;

import java.text.SimpleDateFormat;
import java.util.Date;

import com.enson.demo.service.DubboService;

public class DubboServiceImpl implements DubboService{

	@Override
	public String printWord(String word) {
		String outWord = new SimpleDateFormat("[yyyy-MM-dd HH:mm:ss ]")
			.format(new Date()) + word;
		System.err.println(outWord);
		return outWord;
	}

}

4、創建provider.xml

<?xml version="1.0">

5、創建test.Provider類，作為服務注冊的入口：

package test;

import java.io.IOException;

import org.springframework.context.support.ClassPathXmlApplicationContext;

public class Provider {

	public static void main(String[] args) throws IOException {
		ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(new String[] {"provider.xml"});
        context.start();
 
        System.in.read(); // 按任意鍵退出

	}

}

以上完成了服務提供者的編寫。

6、創建com.enson.custom.action.DubboAction

package com.enson.custom.action;

import com.enson.demo.service.DubboService;

public class DubboAction {
	public DubboService dubboService ;

	//Spring 方法注入
	public void setDubboService(DubboService dubboService) {
		this.dubboService = dubboService;
	}
	
	public String printWord(){
		System.out.println("action printWord被執行！");
		return this.dubboService.printWord("Hello World");// 執行遠程方法
	}
}

7、創建cstom.xml

<?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://code.alibabatech.com/schema/dubbo"
    xsi:schemaLocation="http://www.springframework.org/schema/beans
        http://www.springframework.org/schema/beans/spring-beans.xsd
        http://code.alibabatech.com/schema/dubbo
        http://code.alibabatech.com/schema/dubbo/dubbo.xsd
        ">
 
    <!-- 消費方應用名，用于計算依賴關系，不是匹配條件，不要與提供方一樣 -->
    <dubbo:application name="dubbo-custom-app"  />
 
    <!-- 使用zookeeper注冊中心暴露發現服務地址 -->
    <dubbo:registry address="zookeeper://127.0.0.1:2181" />
 
    <!-- 生成遠程服務代理，可以和本地bean一樣使用dubboService -->
    <dubbo:reference id="dubboService" interface="com.enson.demo.service.DubboService" />
    
    <!-- 普通的spring bean的定義 -->
    <bean id="dubboAction" class="com.enson.custom.action.DubboAction">
    <!-- 實例化action中的dubboService 方法注入 -->
    	<property name="dubboService" ref="dubboService"/>
    </bean>
 
</beans>

8、創建消費者類：test.Custom

package test;

import org.springframework.context.support.ClassPathXmlApplicationContext;

import com.enson.custom.action.DubboAction;

public class Custom {

	public static void main(String[] args) {
		ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(
				new String[] { "consumer.xml" });
		context.start();

		DubboAction dubboAction = (DubboAction) context.getBean("dubboAction"); // 獲取遠程服務代理
		String word = dubboAction.printWord();// 執行遠程方法

		System.out.println(word); // 顯示調用結果

	}

}

測試：

1、啟動zookeeper。

2、執行Provider。Run as java application

3、執行Custom。Run as java application

查看控制臺即可。

感謝各位的閱讀，以上就是“ 基于dubbo protocol的demo怎么實現”的內容了，經過本文的學習后，相信大家對 基于dubbo protocol的demo怎么實現這一問題有了更深刻的體會，具體使用情況還需要大家實踐驗證。這里是億速云，小編將為大家推送更多相關知識點的文章，歡迎關注！