1.dubbox-provider示例
在eclipse中建立maven project,名为provider-parent,包含两个maven medule:provider-api 和 provider。
项目源码已经上传至码云:http://git.oschina.net/yeyouluo/dubbox-demo-provider。
使用mvn install命令编译provider-api,最终在本地maven仓库中会生成对应的provider-api-0.0.1-SNAPSHOT.jar。如果在实际生产环境中,还应该上传到私服或*仓库中,便于消费者使用(暴露的服务在此jar中)。
运行Provider.java,执行main方法:
package com.yeyouluo.dubbox.provider.test; import java.io.IOException; import org.springframework.context.support.ClassPathXmlApplicationContext; public class Provider { public static void main(String[] args) throws IOException {
// TODO Auto-generated method stub
ClassPathXmlApplicationContext ac = new ClassPathXmlApplicationContext("dubbox-provider.xml");
ac.start(); // 为保证服务一直开着,利用输入流的阻塞来模拟
System.in.read();
} }
Provider.java
启动后,admin中出现提供者实例:
2.dubbox-consumer示例
consumer实例比较简单,配置好<dubbo:consumer>标签,就可以像调用本地服务一样调用远程服务。
项目源码已经上传至码云:http://git.oschina.net/yeyouluo/dubbox-demo-consumer。
运行Consumer.java,执行main方法:
package com.yeyouluo.dubbox.consumer.test; import java.io.IOException;
import java.util.List; import org.springframework.context.support.ClassPathXmlApplicationContext; import com.yeyouluo.dubbox.provider.inter.IDemoService;
import com.yeyouluo.dubbox.provider.pojo.User; public class Consumer { public static void main(String[] args) throws IOException {
ClassPathXmlApplicationContext ac = new ClassPathXmlApplicationContext("dubbox-consumer.xml");
ac.start(); IDemoService demoService = (IDemoService)ac.getBean("demoService");
String res = demoService.sayHello("yeyouluo");
System.out.println(res);
List<User> users = demoService.getUsers();
for( User u : users ){
System.out.println(u.toString());
} System.in.read();
} }
Consumer.java
控制台输出如下:
admin中出现消费者实例:
3.附:使用ZooInspector可视化zk内容
ZooInspector下载地址:
链接: https://pan.baidu.com/s/1c2KQDpQ 密码: uxpa