设为首页收藏本站
开启辅助访问

在路上

 找回密码
 立即注册
在路上 › 站点首页 ›学习 › 查看内容

Dubbo

2016-7-29 15:47| 发布者: zhangjf| 查看: 634| 评论: 0

摘要: Dubbo+Spring+注解+简单Demo(前提是搭建了Dubbo+Zookeeper,搭建可以参考http://blog.csdn.net/u010379996/article/details/51942588) public interface UserService { public ListUser getAll ...
Dubbo+Spring+注解+简单Demo(前提是搭建了Dubbo+Zookeeper,搭建可以参考http://blog.csdn.net/u010379996/article/details/51942588)
  1. public interface UserService {
  2. public List<User> getAllUsers();
  3. public String bind(String name);
  4. }
复制代码
  1. public class User implements Serializable{
  2. private static final long serialVersionUID = 1L;
  3. private String name;
  4. public String getName() {
  5. return name;
  6. }
  7. public void setName(String name) {
  8. this.name = name;
  9. }
  10. public String toString() {
  11. return "User [name=" + name + "]";
  12. }
  13. }
复制代码
  1. public class Provider {
  2. public static void main(String[] args) throws Exception {
  3. @SuppressWarnings({ "unused", "resource" })
  4. ApplicationContext context = new ClassPathXmlApplicationContext("spring-provider.xml");
  5. new Provider().test();
  6. }
  8. public void test() throws IOException{
  9. System.in.read();
  10. }
  12. }
复制代码
  1. @Component("service")
  2. @com.alibaba.dubbo.config.annotation.Service()
  3. public class UserServiceImpl implements UserService{
  5. public List<User> getAllUsers() {
  6. List<User> list = new ArrayList<User>();
  7. User u1 = new User();
  8. u1.setName("jack");
  10. User u2 = new User();
  11. u2.setName("tom");
  13. User u3 = new User();
  14. u3.setName("rose");
  16. list.add(u1);
  17. list.add(u2);
  18. list.add(u3);
  19. return list;
  20. }
  22. public String bind(String name) {
  23. System.out.println(name);
  24. return "provider";
  25. }
  26. }
复制代码
  1. public class Consumer {
  2. public static void main(String[] args) throws Exception {
  3. ApplicationContext context = new ClassPathXmlApplicationContext("spring-consumer.xml");
  4. new Consumer().test(context);
  5. }
  6. public void test(ApplicationContext context) throws IOException {
  8. ServiceFactory factory = (ServiceFactory) context.getBean("factory");
  10. UserService service = factory.getService();
  12. System.out.println(service.bind("consumer"));
  14. List<User> list = service.getAllUsers();
  15. if (list != null && list.size() > 0) {
  16. for (int i = 0; i < list.size(); i++) {
  17. System.out.println(list.get(i));
  18. }
  19. }
  20. System.in.read();
  21. }
  22. }
复制代码
  1. @Service("factory")
  2. public class ServiceFactory {
  3. @Reference
  4. private UserService service;
  6. public UserService getService() {
  7. return service;
  8. }
  10. public void setService(UserService service) {
  11. this.service = service;
  12. }
  13. }
复制代码
  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <beans xmlns="http://www.springframework.org/schema/beans"
  3. xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  4. xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
  5. xmlns:context="http://www.springframework.org/schema/context"
  6. xsi:schemaLocation="http://www.springframework.org/schema/beans
  7. http://www.springframework.org/schema/beans/spring-beans.xsd
  8. http://www.springframework.org/schema/context
  9. http://www.springframework.org/schema/context/spring-context-4.0.xsd
  10. http://code.alibabatech.com/schema/dubbo
  11. http://code.alibabatech.com/schema/dubbo/dubbo.xsd
  12. ">
  13. <context:annotation-config />
  14. <context:component-scan base-package="cn.consumer" />
  16. <dubbo:application name="consumer" />
  17. <dubbo:registry address="zookeeper://127.0.0.1:2181" />
  18. <dubbo:annotation package="cn.consumer"/>
  20. </beans>
复制代码
  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <beans xmlns="http://www.springframework.org/schema/beans"
  3. xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  4. xmlns:context="http://www.springframework.org/schema/context"
  5. xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
  6. xsi:schemaLocation="http://www.springframework.org/schema/beans
  7. http://www.springframework.org/schema/beans/spring-beans.xsd
  8. http://www.springframework.org/schema/context
  9. http://www.springframework.org/schema/context/spring-context-4.0.xsd
  10. http://code.alibabatech.com/schema/dubbo
  11. http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
  13. <context:annotation-config />
  14. <context:component-scan base-package="cn.provider" />
  15. <dubbo:application name="provider" />
  16. <dubbo:registry address="zookeeper://127.0.0.1:2181" />
  17. <dubbo:protocol name="dubbo" port="20880" />
  18. <dubbo:annotation package="cn.provider"/>
  20. </beans>
复制代码
  1. <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  2. xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  3. <modelVersion>4.0.0</modelVersion>
  5. <groupId>cn</groupId>
  6. <artifactId>DubboDemo</artifactId>
  7. <version>0.0.1-SNAPSHOT</version>
  8. <packaging>jar</packaging>
  10. <name>DubboDemo</name>
  11. <url>http://maven.apache.org</url>
  13. <properties>
  14. <spring.version>4.0.8.RELEASE</spring.version>
  15. <zookeeper.version>3.3.3</zookeeper.version>
  16. <zkclient.version>0.1</zkclient.version>
  17. <servlet.version>2.5</servlet.version>
  18. <dubbo.version>2.5.3</dubbo.version>
  19. <log4j.version>1.2.16</log4j.version>
  21. </properties>
  22. <dependencies>
  23. <dependency>
  24. <groupId>org.springframework</groupId>
  25. <artifactId>spring-core</artifactId>
  26. <version>${spring.version}</version>
  27. </dependency>
  28. <dependency>
  29. <groupId>org.springframework</groupId>
  30. <artifactId>spring-aop</artifactId>
  31. <version>${spring.version}</version>
  32. </dependency>
  33. <dependency>
  34. <groupId>org.springframework</groupId>
  35. <artifactId>spring-tx</artifactId>
  36. <version>${spring.version}</version>
  37. </dependency>
  38. <dependency>
  39. <groupId>org.springframework</groupId>
  40. <artifactId>spring-context</artifactId>
  41. <version>${spring.version}</version>
  42. </dependency>
  43. <dependency>
  44. <groupId>org.springframework</groupId>
  45. <artifactId>spring-orm</artifactId>
  46. <version>${spring.version}</version>
  47. </dependency>
  48. <dependency>
  49. <groupId>org.springframework</groupId>
  50. <artifactId>spring-context-support</artifactId>
  51. <version>${spring.version}</version>
  52. </dependency>
  53. <dependency>
  54. <groupId>com.alibaba</groupId>
  55. <artifactId>dubbo</artifactId>
  56. <version>${dubbo.version}</version>
  57. </dependency>
  58. <dependency>
  59. <groupId>com.github.sgroschupf</groupId>
  60. <artifactId>zkclient</artifactId>
  61. <version>${zkclient.version}</version>
  62. </dependency>
  63. <dependency>
  64. <groupId>org.apache.zookeeper</groupId>
  65. <artifactId>zookeeper</artifactId>
  66. <version>${zookeeper.version}</version>
  67. </dependency>
  68. <dependency>
  69. <groupId>log4j</groupId>
  70. <artifactId>log4j</artifactId>
  71. <version>${log4j.version}</version>
  72. </dependency>
  73. </dependencies>
  74. </project>
复制代码
  1. log4j.rootLogger=WARN, stdout, R
  2. log4j.appender.stdout=org.apache.log4j.ConsoleAppender
  3. log4j.appender.stdout.layout=org.apache.log4j.PatternLayout
  4. # Pattern to output the caller's file name and line number.
  5. #log4j.appender.stdout.layout.ConversionPattern=%5p [%t] (%F:%L) - %m%n
  6. # Print the date in ISO 8601 format
  7. log4j.appender.stdout.layout.ConversionPattern=%d [%t] %-5p %c - %m%n
  8. log4j.appender.R=org.apache.log4j.RollingFileAppender
  9. log4j.appender.R.File=example.log
  10. log4j.appender.R.MaxFileSize=100KB
  11. # Keep one backup file
  12. log4j.appender.R.MaxBackupIndex=1
  13. log4j.appender.R.layout=org.apache.log4j.PatternLayout
  14. log4j.appender.R.layout.ConversionPattern=%p %t %c - %m%n
  15. # Print only messages of level WARN or above in the package com.foo.
  16. log4j.logger.com.foo=WARN
复制代码
收藏 邀请
上一篇：Android 自定义圆形文字头像下一篇：EditText中只允许输入数字、字母、汉字和-

最新评论

相关分类

小黑屋|在路上 ( 蜀ICP备15035742号-1 )  

;

GMT+8, 2025-5-6 13:29

Copyright 2015-2025 djqfx

返回顶部