这篇文章主要讲解了“ 基于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怎么实现这一问题有了更深刻的体会,具体使用情况还需要大家实践验证。这里是亿速云,小编将为大家推送更多相关知识点的文章,欢迎关注!
亿速云「云服务器」,即开即用、新一代英特尔至强铂金CPU、三副本存储NVMe SSD云盘,价格低至29元/月。点击查看>>
免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。
原文链接:https://my.oschina.net/enson16855/blog/711877