想练习dubbo接口测试,但是没接口?
Dubbo是一款高性能、轻量级的开源Java RPC框架。
很多朋友想练习dubbo接口测试,但是苦于没有接口而放弃,下面我就带大家开发一个简单的dubbo接口。
接口需求
客户端输入uncleyong(当然,也可以输入其它字符串),服务端返回hello uncleyong
开发环境
jdk + idea + maven + zookeeper
jdk安装:https://www.cnblogs.com/uncleyong/p/10732951.html
idea安装:https://www.cnblogs.com/uncleyong/p/10971923.html
maven安装:https://www.cnblogs.com/uncleyong/p/10743181.html
zookeeper安装:https://www.cnblogs.com/uncleyong/p/10737119.html
common开发
idea中创建模块dubbo-common
存放公共的实体类、接口
package com.uncleyong.dubbotest.service;
public interface SayHelloToClient {
public String sayHello(String name);
}
然后mvn install打包,供provider及consumer在pom文件中引包
provider开发
idea中创建模块dubbo_provider
创建实现类
package com.uncleyong.dubbotest.service.impl;
import com.uncleyong.dubbotest.service.SayHelloToClient;
public class SayHelloToClientImpl implements SayHelloToClient {
public String sayHello(String name){
System.out.println("from client :" + name);
return "hello, " + name;
}
}
配置文件,provider.xml
<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.xsd http://dubbo.apache.org/schema/dubbo http://dubbo.apache.org/schema/dubbo/dubbo.xsd">
<dubbo:application name="dubbo-provider"/>
<!-- 使用zookeeper广播注册中心暴露服务地址 -->
<dubbo:registry address="zookeeper://127.0.0.1:2181"/>
<!-- 用dubbo协议在20880端口暴露服务 -->
<dubbo:protocol name="dubbo" port="20888"/>
<!-- 声明需要暴露的服务接口 -->
<dubbo:service interface="com.uncleyong.dubbotest.service.SayHelloToClient" ref="sayhellotoclient"/>
<!-- 和本地bean一样实现服务 -->
<bean id="sayhellotoclient" class="com.uncleyong.dubbotest.service.impl.SayHelloToClientImpl"/>
</beans>
创建主运行文件,ProviderMain
package com.uncleyong.dubbotest.main;
import org.springframework.context.support.ClassPathXmlApplicationContext;
public class ProviderMain {
public static void main(String[] args) throws Exception {
ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(
new String[] {"provider.xml"});
context.start();
System.out.println("注册成功,如想退出,按任意键退出");
System.in.read(); // 按任意键退出
}
}
consumer开发
idea中创建模块dubbo_consumer
主运行文件
package com.uncleyong.dubbotest.main;
import com.uncleyong.dubbotest.service.SayHelloToClient;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import java.util.Scanner;
public class ConsumerMain {
public static void main(String[] args) throws Exception {
ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(
new String[] {"consumer.xml"});
context.start();
// 获取远程服务代理
SayHelloToClient say = (SayHelloToClient) context.getBean("sayhellotoclient");
// 执行远程方法
String res = say.sayHello("UncleYong");
// 显示调用结果
System.out.println(res);
new Scanner(System.in).next();
}
}
配置文件,consumer.xml
<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.xsd http://dubbo.apache.org/schema/dubbo http://dubbo.apache.org/schema/dubbo/dubbo.xsd">
<dubbo:application name="dubbo-consumer"/>
<!-- 使用zookeeper广播注册中心暴露发现服务地址 -->
<dubbo:registry address="zookeeper://127.0.0.1:2181"/>
<!-- 生成远程服务代理,可以和本地bean一样使用demoService -->
<dubbo:reference id="sayhellotoclient" interface="com.uncleyong.dubbotest.service.SayHelloToClient"/>
</beans>
运行结果
先启动zookeeper,进入zookeeper的bin目录,点击【zkServer.cmd】
启动provider
服务注册成功
启动consumer,可以看到输出了结果
在provider端,也可以看到客户端发过来的消息
至此,开发完成,下一篇,分享用jmeter测试dubbo接口。
抛砖引玉,欢迎交流;
声明:封面图片来源于网络,如有侵权,请联系删除。
END
星标|在看|留言|转发分享,铁粉
长按二维码关注,第一时间获取干货
点击「阅读原文」