基于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怎么实现这一问题有了更深刻的体会，具体使用情况还需要大家实践验证。这里是亿速云，小编将为大家推送更多相关知识点的文章，欢迎关注！