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

在路上

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

Dubbox入门示例（注册服务器使用zookeeper）

2017-2-7 13:39| 发布者: zhangjf| 查看: 562| 评论: 0

摘要: 前言：Dubbox now means Dubbo eXtensions, and it adds features like RESTful remoting, Kyro/FST serialization, etc to the Dubbo service framework. http://dangdangdotcom.github.io/dubbox 本文将在Dubbox ...

前言：Dubbox now means Dubbo eXtensions, and it adds features like RESTful remoting, Kyro/FST serialization, etc to the Dubbo service framework. http://dangdangdotcom.github.io/dubbox

本文将在Dubbox的基础上进行演示

github地址：https://github.com/dangdangdotcom/dubbox

准备工作：

1，安装好 zookeeper （可参考前一篇文章）

2，安装好maven

3，安装git（也可以不安装，直接下载源码）

下面进入正式步骤

1，在 git 命令行下，下载项目源码

  1. git clone https://github.com/dangdangdotcom/dubbox
复制代码

2，对下载下来的源码进行编译

  1. mvn install -Dmaven.test.skip=true
复制代码

3，下载下来的有一个文件夹 dubbo-demo ，这里包含了官方demo，可以参考。

官方demo里包含了3个文件夹 dubbo-demo-api（服务接口及传输对象）、dubbo-demo-provider（服务生产者）、dubbo-demo-consumer（服务消费方）

4，下载下来的有一个文件夹 dubbo-admin，这个是dubbo的后台管理，其配置文件在webappWEB-INF底下，名为 dubbo.properties

  1. dubbo.registry.address=zookeeper://127.0.0.1:2181
  2. dubbo.admin.root.password=root
  3. dubbo.admin.guest.password=guest
复制代码

将 dubbo-admin 打成war包，放在tomcat底下，即可以在浏览器进入dubo的后台，进行管理。

注意：zookeeper启动之后会占用8080端口。

5，dubbo-monitor项目用于性能监控

6，模拟官方demo，编写小demo

6.1，新建api项目

pom.xml

  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/maven-v4_0_0.xsd">
  3. <modelVersion>4.0.0</modelVersion>
  4. <groupId>org.viking</groupId>
  5. <artifactId>dubbo-hello-api</artifactId>
  6. <version>0.0.1-SNAPSHOT</version>
  7. <name>dubbo-hello-api</name>
  8. <dependencies>
  9. <dependency>
  10. <groupId>com.alibaba</groupId>
  11. <artifactId>dubbo</artifactId>
  12. <version>2.8.4</version>
  13. </dependency>
  14. <dependency>
  15. <groupId>javax.validation</groupId>
  16. <artifactId>validation-api</artifactId>
  17. <version>1.0.0.GA</version>
  18. </dependency>
  19. <dependency>
  20. <groupId>javax.annotation</groupId>
  21. <artifactId>javax.annotation-api</artifactId>
  22. <version>1.2</version>
  23. </dependency>
  24. <dependency>
  25. <groupId>org.codehaus.jackson</groupId>
  26. <artifactId>jackson-mapper-asl</artifactId>
  27. <version>1.9.12</version>
  28. </dependency>
  29. </dependencies>
  30. <build>
  31. <finalName>dubbo-hello-api</finalName>
  32. </build>
  33. </project>
复制代码

SerializationOptimizerImpl.java

  1. /**
  2. * Copyright 1999-2014 dangdang.com.
  3. *
  4. * Licensed under the Apache License, Version 2.0 (the "License");
  5. * you may not use this file except in compliance with the License.
  6. * You may obtain a copy of the License at
  7. *
  8. * http://www.apache.org/licenses/LICENSE-2.0
  9. *
  10. * Unless required by applicable law or agreed to in writing, software
  11. * distributed under the License is distributed on an "AS IS" BASIS,
  12. * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  13. * See the License for the specific language governing permissions and
  14. * limitations under the License.
  15. */
  16. package viking.dubbo.demo.api;
  18. import com.alibaba.dubbo.common.serialize.support.SerializationOptimizer;
  19. import java.util.Collection;
  20. import java.util.LinkedList;
  21. import java.util.List;
  23. /**
  24. * This class must be accessible from both the provider and consumer
  25. *
  26. * @author lishen
  27. */
  28. public class SerializationOptimizerImpl implements SerializationOptimizer {
  30. public Collection<Class> getSerializableClasses() {
  31. List<Class> classes = new LinkedList<Class>();
  32. classes.add(User.class);
  33. return classes;
  34. }
  35. }
复制代码

User.java

  1. package viking.dubbo.demo.api;
  2. import org.codehaus.jackson.annotate.JsonProperty;
  3. import javax.validation.constraints.Min;
  4. import javax.validation.constraints.NotNull;
  5. import javax.validation.constraints.Size;
  6. import javax.xml.bind.annotation.XmlAccessType;
  7. import javax.xml.bind.annotation.XmlAccessorType;
  8. import javax.xml.bind.annotation.XmlElement;
  9. import javax.xml.bind.annotation.XmlRootElement;
  10. import java.io.Serializable;
  12. @XmlRootElement
  13. @XmlAccessorType(XmlAccessType.FIELD)
  14. public class User implements Serializable {
  16. @NotNull
  17. @Min(1L)
  18. private Long id;
  20. @JsonProperty("username")
  21. @XmlElement(name = "username")
  22. @NotNull
  23. @Size(min = 6, max = 50)
  24. private String name;
  26. public User() {
  27. }
  29. public User(Long id, String name) {
  30. this.id = id;
  31. this.name = name;
  32. }
  34. public Long getId() {
  35. return id;
  36. }
  38. public void setId(Long id) {
  39. this.id = id;
  40. }
  42. public String getName() {
  43. return name;
  44. }
  46. public void setName(String name) {
  47. this.name = name;
  48. }
  50. @Override
  51. public String toString() {
  52. return "User (" +
  53. "id=" + id +
  54. ", name='" + name + ''' +
  55. ')';
  56. }
  57. }
复制代码

UserRestService.java

  1. package viking.dubbo.demo.api;
  3. import javax.validation.constraints.Min;
  5. public interface UserRestService {
  6. User getUser(@Min(value = 1L, message = "User ID must be greater than 1") Long id);
  7. }
复制代码

UserService.java

  1. package viking.dubbo.demo.api;
  3. public interface UserService {
  4. User getUser(Long id);
  5. }
复制代码

6.2，新建provider

pom.xml

  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/maven-v4_0_0.xsd">
  3. <modelVersion>4.0.0</modelVersion>
  4. <groupId>org.viking</groupId>
  5. <artifactId>dubbo-hello-provider</artifactId>
  6. <version>0.0.1-SNAPSHOT</version>
  7. <name>dubbo-hello-provider</name>
  8. <dependencies>
  9. <!--公用的服务接口 -->
  10. <dependency>
  11. <groupId>org.viking</groupId>
  12. <artifactId>dubbo-hello-api</artifactId>
  13. <version>0.0.1-SNAPSHOT</version>
  14. </dependency>
  16. <dependency>
  17. <groupId>com.alibaba</groupId>
  18. <artifactId>dubbo</artifactId>
  19. <version>2.8.4</version>
  20. </dependency>
  22. <dependency>
  23. <groupId>org.javassist</groupId>
  24. <artifactId>javassist</artifactId>
  25. <version>3.15.0-GA</version>
  26. </dependency>
  28. <dependency>
  29. <groupId>org.apache.mina</groupId>
  30. <artifactId>mina-core</artifactId>
  31. <version>1.1.7</version>
  32. </dependency>
  34. <dependency>
  35. <groupId>org.glassfish.grizzly</groupId>
  36. <artifactId>grizzly-core</artifactId>
  37. <version>2.1.4</version>
  38. </dependency>
  40. <dependency>
  41. <groupId>org.apache.httpcomponents</groupId>
  42. <artifactId>httpclient</artifactId>
  43. <version>4.2.1</version>
  44. </dependency>
  46. <dependency>
  47. <groupId>com.alibaba</groupId>
  48. <artifactId>fastjson</artifactId>
  49. <version>1.1.39</version>
  50. </dependency>
  52. <dependency>
  53. <groupId>com.thoughtworks.xstream</groupId>
  54. <artifactId>xstream</artifactId>
  55. <version>1.4.1</version>
  56. </dependency>
  58. <dependency>
  59. <groupId>org.apache.bsf</groupId>
  60. <artifactId>bsf-api</artifactId>
  61. <version>3.1</version>
  62. </dependency>
  64. <dependency>
  65. <groupId>org.apache.zookeeper</groupId>
  66. <artifactId>zookeeper</artifactId>
  67. <version>3.4.6</version>
  68. </dependency>
  70. <dependency>
  71. <groupId>com.github.sgroschupf</groupId>
  72. <artifactId>zkclient</artifactId>
  73. <version>0.1</version>
  74. </dependency>
  76. <dependency>
  77. <groupId>org.apache.curator</groupId>
  78. <artifactId>curator-framework</artifactId>
  79. <version>2.5.0</version>
  80. </dependency>
  82. <dependency>
  83. <groupId>com.googlecode.xmemcached</groupId>
  84. <artifactId>xmemcached</artifactId>
  85. <version>1.3.6</version>
  86. </dependency>
  88. <dependency>
  89. <groupId>org.apache.cxf</groupId>
  90. <artifactId>cxf-rt-frontend-simple</artifactId>
  91. <version>2.6.1</version>
  92. </dependency>
  94. <dependency>
  95. <groupId>org.apache.cxf</groupId>
  96. <artifactId>cxf-rt-transports-http</artifactId>
  97. <version>2.6.1</version>
  98. </dependency>
  100. <dependency>
  101. <groupId>org.apache.thrift</groupId>
  102. <artifactId>libthrift</artifactId>
  103. <version>0.8.0</version>
  104. </dependency>
  106. <dependency>
  107. <groupId>com.caucho</groupId>
  108. <artifactId>hessian</artifactId>
  109. <version>4.0.7</version>
  110. </dependency>
  112. <dependency>
  113. <groupId>javax.servlet</groupId>
  114. <artifactId>javax.servlet-api</artifactId>
  115. <version>3.1.0</version>
  116. </dependency>
  118. <dependency>
  119. <groupId>org.mortbay.jetty</groupId>
  120. <artifactId>jetty</artifactId>
  121. <version>6.1.26</version>
  122. <exclusions>
  123. <exclusion>
  124. <groupId>org.mortbay.jetty</groupId>
  125. <artifactId>servlet-api</artifactId>
  126. </exclusion>
  127. </exclusions>
  128. </dependency>
  130. <dependency>
  131. <groupId>log4j</groupId>
  132. <artifactId>log4j</artifactId>
  133. <version>1.2.16</version>
  134. </dependency>
  136. <dependency>
  137. <groupId>org.slf4j</groupId>
  138. <artifactId>slf4j-api</artifactId>
  139. <version>1.6.2</version>
  140. </dependency>
  142. <dependency>
  143. <groupId>redis.clients</groupId>
  144. <artifactId>jedis</artifactId>
  145. <version>2.1.0</version>
  146. </dependency>
  148. <dependency>
  149. <groupId>javax.validation</groupId>
  150. <artifactId>validation-api</artifactId>
  151. <version>1.0.0.GA</version>
  152. </dependency>
  154. <dependency>
  155. <groupId>org.hibernate</groupId>
  156. <artifactId>hibernate-validator</artifactId>
  157. <version>4.2.0.Final</version>
  158. </dependency>
  160. <dependency>
  161. <groupId>javax.cache</groupId>
  162. <artifactId>cache-api</artifactId>
  163. <version>0.4</version>
  164. </dependency>
  166. <dependency>
  167. <groupId>org.jboss.resteasy</groupId>
  168. <artifactId>resteasy-jaxrs</artifactId>
  169. <version>3.0.7.Final</version>
  170. </dependency>
  172. <dependency>
  173. <groupId>org.jboss.resteasy</groupId>
  174. <artifactId>resteasy-client</artifactId>
  175. <version>3.0.7.Final</version>
  176. </dependency>
  178. <dependency>
  179. <groupId>org.jboss.resteasy</groupId>
  180. <artifactId>resteasy-netty</artifactId>
  181. <version>3.0.7.Final</version>
  182. </dependency>
  184. <dependency>
  185. <groupId>org.jboss.resteasy</groupId>
  186. <artifactId>resteasy-jdk-http</artifactId>
  187. <version>3.0.7.Final</version>
  188. </dependency>
  190. <dependency>
  191. <groupId>org.jboss.resteasy</groupId>
  192. <artifactId>resteasy-jackson-provider</artifactId>
  193. <version>3.0.7.Final</version>
  194. </dependency>
  196. <dependency>
  197. <groupId>org.jboss.resteasy</groupId>
  198. <artifactId>resteasy-jaxb-provider</artifactId>
  199. <version>3.0.7.Final</version>
  200. </dependency>
  202. <dependency>
  203. <groupId>org.apache.tomcat.embed</groupId>
  204. <artifactId>tomcat-embed-core</artifactId>
  205. <version>8.0.11</version>
  206. </dependency>
  208. <dependency>
  209. <groupId>org.apache.tomcat.embed</groupId>
  210. <artifactId>tomcat-embed-logging-juli</artifactId>
  211. <version>8.0.11</version>
  212. </dependency>
  214. <dependency>
  215. <groupId>com.esotericsoftware.kryo</groupId>
  216. <artifactId>kryo</artifactId>
  217. <version>2.24.0</version>
  218. </dependency>
  220. <dependency>
  221. <groupId>de.javakaffee</groupId>
  222. <artifactId>kryo-serializers</artifactId>
  223. <version>0.26</version>
  224. </dependency>
  226. <dependency>
  227. <groupId>de.ruedigermoeller</groupId>
  228. <artifactId>fst</artifactId>
  229. <version>1.55</version>
  230. </dependency>
  231. </dependencies>
  232. <build>
  233. <finalName>dubbo-hello-provider</finalName>
  234. </build>
  235. </project>
复制代码

DemoProvider.java

  1. package viking.dubbo.demo.provider;
  3. import java.io.IOException;
  4. import org.springframework.context.support.ClassPathXmlApplicationContext;
  6. public class DemoProvider {
  7. public static void main(String[] args) throws IOException {
  8. ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("classpath*:META-INF/spring/*.xml");
  9. context.start();
  10. System.out.println("服务已经启动...");
  11. System.in.read();
  12. }
  13. }
复制代码

UserRestServiceImpl.java

  1. package viking.dubbo.demo.provider;
  3. import com.alibaba.dubbo.rpc.RpcContext;
  4. import com.alibaba.dubbo.rpc.protocol.rest.support.ContentType;
  5. import viking.dubbo.demo.api.User;
  6. import viking.dubbo.demo.api.UserRestService;
  7. import viking.dubbo.demo.api.UserService;
  8. import javax.servlet.http.HttpServletRequest;
  9. import javax.servlet.http.HttpServletResponse;
  10. import javax.ws.rs.*;
  11. import javax.ws.rs.core.MediaType;
  13. @Path("users")
  14. @Consumes({MediaType.APPLICATION_JSON, MediaType.TEXT_XML})
  15. @Produces({ContentType.APPLICATION_JSON_UTF_8, ContentType.TEXT_XML_UTF_8})
  16. public class UserRestServiceImpl implements UserRestService {
  18. private UserService userService;
  20. public void setUserService(UserService userService) {
  21. this.userService = userService;
  22. }
  24. @GET
  25. @Path("{id : \d+}")
  26. public User getUser(@PathParam("id") Long id) {
  27. if (RpcContext.getContext().getRequest(HttpServletRequest.class) != null) {
  28. System.out.println("Client IP address from RpcContext: " + RpcContext.getContext().getRequest(HttpServletRequest.class).getRemoteAddr());
  29. }
  30. if (RpcContext.getContext().getResponse(HttpServletResponse.class) != null) {
  31. System.out.println("Response object from RpcContext: " + RpcContext.getContext().getResponse(HttpServletResponse.class));
  32. }
  33. return userService.getUser(id);
  34. }
  35. }
复制代码

UserServiceImpl.java

  1. package viking.dubbo.demo.provider;
  3. import viking.dubbo.demo.api.User;
  4. import viking.dubbo.demo.api.UserService;
  6. public class UserServiceImpl implements UserService {
  7. public User getUser(Long id) {
  8. return new User(id, "username" + id);
  9. }
  10. }
复制代码

dubbo-demo-provider.xml

  1. <?xml version="1.0" encoding="UTF-8"?>
  3. <beans xmlns="http://www.springframework.org/schema/beans"
  4. xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  5. xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
  6. xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsd
  7. http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
  9. <dubbo:application name="demo-provider" owner="programmer" organization="dubbox"/>
  11. <dubbo:registry address="zookeeper://127.0.0.1:2181"/>
  13. <dubbo:protocol name="dubbo" serialization="kryo" optimizer="viking.dubbo.demo.api.SerializationOptimizerImpl"/>
  15. <!-- use tomcat server -->
  16. <dubbo:protocol name="rest" port="8888" threads="500" contextpath="services" server="tomcat" accepts="500"
  17. extension="com.alibaba.dubbo.rpc.protocol.rest.support.LoggingFilter"/>
  20. <dubbo:service interface="viking.dubbo.demo.api.UserService" ref="userService" protocol="dubbo" />
  22. <dubbo:service interface="viking.dubbo.demo.api.UserRestService" ref="userRestService" protocol="rest" validation="true"/>
  24. <bean id="userService" class="viking.dubbo.demo.provider.UserServiceImpl"/>
  26. <bean id="userRestService" class="viking.dubbo.demo.provider.UserRestServiceImpl">
  27. <property name="userService" ref="userService"/>
  28. </bean>
  30. </beans>
复制代码

6.3，新建 consumer

pom.xml

  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/maven-v4_0_0.xsd">
  3. <modelVersion>4.0.0</modelVersion>
  4. <groupId>org.viking</groupId>
  5. <artifactId>dubbo-hello-consumer</artifactId>
  6. <version>0.0.1-SNAPSHOT</version>
  7. <name>dubbo-hello-consumer</name>
  8. <dependencies>
  9. <!--公用的服务接口 -->
  10. <dependency>
  11. <groupId>org.viking</groupId>
  12. <artifactId>dubbo-hello-api</artifactId>
  13. <version>0.0.1-SNAPSHOT</version>
  14. </dependency>
  17. <dependency>
  18. <groupId>com.alibaba</groupId>
  19. <artifactId>dubbo</artifactId>
  20. <version>2.8.4</version>
  21. </dependency>
  23. <dependency>
  24. <groupId>org.javassist</groupId>
  25. <artifactId>javassist</artifactId>
  26. <version>3.15.0-GA</version>
  27. </dependency>
  29. <dependency>
  30. <groupId>org.apache.mina</groupId>
  31. <artifactId>mina-core</artifactId>
  32. <version>1.1.7</version>
  33. </dependency>
  35. <dependency>
  36. <groupId>org.glassfish.grizzly</groupId>
  37. <artifactId>grizzly-core</artifactId>
  38. <version>2.1.4</version>
  39. </dependency>
  41. <dependency>
  42. <groupId>org.apache.httpcomponents</groupId>
  43. <artifactId>httpclient</artifactId>
  44. <version>4.2.1</version>
  45. </dependency>
  47. <dependency>
  48. <groupId>com.alibaba</groupId>
  49. <artifactId>fastjson</artifactId>
  50. <version>1.1.39</version>
  51. </dependency>
  53. <dependency>
  54. <groupId>com.thoughtworks.xstream</groupId>
  55. <artifactId>xstream</artifactId>
  56. <version>1.4.1</version>
  57. </dependency>
  59. <dependency>
  60. <groupId>org.apache.bsf</groupId>
  61. <artifactId>bsf-api</artifactId>
  62. <version>3.1</version>
  63. </dependency>
  65. <dependency>
  66. <groupId>org.apache.zookeeper</groupId>
  67. <artifactId>zookeeper</artifactId>
  68. <version>3.4.6</version>
  69. </dependency>
  71. <dependency>
  72. <groupId>com.github.sgroschupf</groupId>
  73. <artifactId>zkclient</artifactId>
  74. <version>0.1</version>
  75. </dependency>
  77. <dependency>
  78. <groupId>org.apache.curator</groupId>
  79. <artifactId>curator-framework</artifactId>
  80. <version>2.5.0</version>
  81. </dependency>
  83. <dependency>
  84. <groupId>com.googlecode.xmemcached</groupId>
  85. <artifactId>xmemcached</artifactId>
  86. <version>1.3.6</version>
  87. </dependency>
  89. <dependency>
  90. <groupId>org.apache.cxf</groupId>
  91. <artifactId>cxf-rt-frontend-simple</artifactId>
  92. <version>2.6.1</version>
  93. </dependency>
  95. <dependency>
  96. <groupId>org.apache.cxf</groupId>
  97. <artifactId>cxf-rt-transports-http</artifactId>
  98. <version>2.6.1</version>
  99. </dependency>
  101. <dependency>
  102. <groupId>org.apache.thrift</groupId>
  103. <artifactId>libthrift</artifactId>
  104. <version>0.8.0</version>
  105. </dependency>
  107. <dependency>
  108. <groupId>com.caucho</groupId>
  109. <artifactId>hessian</artifactId>
  110. <version>4.0.7</version>
  111. </dependency>
  113. <dependency>
  114. <groupId>javax.servlet</groupId>
  115. <artifactId>javax.servlet-api</artifactId>
  116. <version>3.1.0</version>
  117. </dependency>
  119. <dependency>
  120. <groupId>org.mortbay.jetty</groupId>
  121. <artifactId>jetty</artifactId>
  122. <version>6.1.26</version>
  123. <exclusions>
  124. <exclusion>
  125. <groupId>org.mortbay.jetty</groupId>
  126. <artifactId>servlet-api</artifactId>
  127. </exclusion>
  128. </exclusions>
  129. </dependency>
  131. <dependency>
  132. <groupId>log4j</groupId>
  133. <artifactId>log4j</artifactId>
  134. <version>1.2.16</version>
  135. </dependency>
  137. <dependency>
  138. <groupId>org.slf4j</groupId>
  139. <artifactId>slf4j-api</artifactId>
  140. <version>1.6.2</version>
  141. </dependency>
  143. <dependency>
  144. <groupId>redis.clients</groupId>
  145. <artifactId>jedis</artifactId>
  146. <version>2.1.0</version>
  147. </dependency>
  149. <dependency>
  150. <groupId>javax.validation</groupId>
  151. <artifactId>validation-api</artifactId>
  152. <version>1.0.0.GA</version>
  153. </dependency>
  155. <dependency>
  156. <groupId>org.hibernate</groupId>
  157. <artifactId>hibernate-validator</artifactId>
  158. <version>4.2.0.Final</version>
  159. </dependency>
  161. <dependency>
  162. <groupId>javax.cache</groupId>
  163. <artifactId>cache-api</artifactId>
  164. <version>0.4</version>
  165. </dependency>
  167. <dependency>
  168. <groupId>org.jboss.resteasy</groupId>
  169. <artifactId>resteasy-jaxrs</artifactId>
  170. <version>3.0.7.Final</version>
  171. </dependency>
  173. <dependency>
  174. <groupId>org.jboss.resteasy</groupId>
  175. <artifactId>resteasy-client</artifactId>
  176. <version>3.0.7.Final</version>
  177. </dependency>
  179. <dependency>
  180. <groupId>org.jboss.resteasy</groupId>
  181. <artifactId>resteasy-netty</artifactId>
  182. <version>3.0.7.Final</version>
  183. </dependency>
  185. <dependency>
  186. <groupId>org.jboss.resteasy</groupId>
  187. <artifactId>resteasy-jdk-http</artifactId>
  188. <version>3.0.7.Final</version>
  189. </dependency>
  191. <dependency>
  192. <groupId>org.jboss.resteasy</groupId>
  193. <artifactId>resteasy-jackson-provider</artifactId>
  194. <version>3.0.7.Final</version>
  195. </dependency>
  197. <dependency>
  198. <groupId>org.jboss.resteasy</groupId>
  199. <artifactId>resteasy-jaxb-provider</artifactId>
  200. <version>3.0.7.Final</version>
  201. </dependency>
  203. <dependency>
  204. <groupId>org.apache.tomcat.embed</groupId>
  205. <artifactId>tomcat-embed-core</artifactId>
  206. <version>8.0.11</version>
  207. </dependency>
  209. <dependency>
  210. <groupId>org.apache.tomcat.embed</groupId>
  211. <artifactId>tomcat-embed-logging-juli</artifactId>
  212. <version>8.0.11</version>
  213. </dependency>
  215. <dependency>
  216. <groupId>com.esotericsoftware.kryo</groupId>
  217. <artifactId>kryo</artifactId>
  218. <version>2.24.0</version>
  219. </dependency>
  221. <dependency>
  222. <groupId>de.javakaffee</groupId>
  223. <artifactId>kryo-serializers</artifactId>
  224. <version>0.26</version>
  225. </dependency>
  227. <dependency>
  228. <groupId>de.ruedigermoeller</groupId>
  229. <artifactId>fst</artifactId>
  230. <version>1.55</version>
  231. </dependency>
  232. </dependencies>
  233. <build>
  234. <finalName>dubbo-hello-consumer</finalName>
  235. </build>
  236. </project>
复制代码

DemoConsumer.java

  1. package viking.dubbo.demo.consumer;
  3. import org.springframework.context.support.ClassPathXmlApplicationContext;
  4. import viking.dubbo.demo.api.UserService;
  5. import javax.ws.rs.client.Client;
  6. import javax.ws.rs.client.ClientBuilder;
  7. import javax.ws.rs.client.WebTarget;
  8. import javax.ws.rs.core.Response;
  10. public class DemoConsumer {
  12. public static void main(String[] args) {
  13. final String port = "8888";
  15. //测试Rest服务
  16. getUser("http://localhost:" + port + "/services/users/1.json");
  17. getUser("http://localhost:" + port + "/services/users/1.xml");
  19. //测试常规服务
  20. ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("classpath*:META-INF/spring/*.xml");
  21. context.start();
  22. UserService userService = context.getBean(UserService.class);
  23. System.out.println(userService.getUser(1L));
  24. }
  27. private static void getUser(String url) {
  28. System.out.println("Getting user via " + url);
  29. Client client = ClientBuilder.newClient();
  30. WebTarget target = client.target(url);
  31. Response response = target.request().get();
  32. try {
  33. if (response.getStatus() != 200) {
  34. throw new RuntimeException("Failed with HTTP error code : " + response.getStatus());
  35. }
  36. System.out.println("Successfully got result: " + response.readEntity(String.class));
  37. } finally {
  38. response.close();
  39. client.close();
  40. }
  41. }
  42. }
复制代码

dubbo-hello-consumer.xml

  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. xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsd
  6. http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
  8. <dubbo:application name="demo-consumer" owner="programmer" organization="dubbox"/>
  10. <dubbo:registry address="zookeeper://127.0.0.1:2181"/>
  12. <dubbo:reference id="userRestService" interface="viking.dubbo.demo.api.UserRestService"/>
  14. <dubbo:reference id="userService" interface="viking.dubbo.demo.api.UserService"/>
  16. </beans>
复制代码

7，运行查看结果

首先运行 provider，然后运行 consumer，同时也可以在dubbo的后台管理查看结果

  1. Getting user via http://localhost:8888/services/users/1.json
  2. log4j:WARN No appenders could be found for logger (org.jboss.resteasy.plugins.providers.DocumentProvider).
  3. log4j:WARN Please initialize the log4j system properly.
  4. log4j:WARN See http://logging.apache.org/log4j/1.2/faq.html#noconfig for more info.
  5. Successfully got result: {"id":1,"username":"username1"}
  6. Getting user via http://localhost:8888/services/users/1.xml
  7. Successfully got result: <?xml version="1.0" encoding="UTF-8" standalone="yes"?><user><id>1</id><username>username1</username></user>
  8. User (id=1, name='username1')
复制代码

来自： http://my.oschina.net/u/238296/blog/602446

收藏 邀请
上一篇：微信公众号发送模板消息 Java实现。下一篇：通过读取excel文件生成sql语句

最新评论

相关分类

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

;

GMT+8, 2025-7-9 07:13

Copyright 2015-2025 djqfx

返回顶部