微服务之 -- dubbox初次使用

关于dubbox的介绍可以自行百度。

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

Dubbox需要什么版本的JDK？

目前最好在JDK 1.7以上运行

Dubbo REST的服务能和Dubbo注册中心、监控中心集成吗？

可以的，而且是自动集成的，也就是你在dubbo中开发的所有REST服务都会自动注册到服务册中心和监控中心，可以通过它们做管理。

但是，只有当REST的消费端也是基于dubbo的时候，注册中心中的许多服务治理操作才能完全起作用。而如果消费端是非dubbo的，自然不受注册中心管理，所以其中很多操作是不会对消费端起作用的。

不废话，代码可以说明一切

可以参考官方的文档 http://dangdangdotcom.github.io/dubbox/rest.html

一、先从git上面下载项目，然后在项目根目录执行mvn install，执行完成之后将下图中红色框里面的war包放tomcat里面运行。

二、创建如下项目

项目程序结构如图：

1、pom.xml

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">

<modelVersion>4.0.0</modelVersion>

<groupId>hvgroup</groupId>

<artifactId>com</artifactId>

<version>0.0.1-SNAPSHOT</version>

<packaging>war</packaging>

<name>dbxtest</name>

<dependencies>

<dependency>

<groupId>com.alibaba</groupId>

<artifactId>dubbo-demo-api</artifactId>

<version>2.8.4</version>

</dependency>

<dependency>

<groupId>com.alibaba</groupId>

<artifactId>dubbo</artifactId>

<version>2.8.4</version>

</dependency>

<dependency>

<groupId>org.javassist</groupId>

<artifactId>javassist</artifactId>

<version>3.20.0-GA</version>

</dependency>

<dependency>

<groupId>io.netty</groupId>

<artifactId>netty</artifactId>

<version>3.7.0.Final</version>

</dependency>

<dependency>

<groupId>org.apache.mina</groupId>

<artifactId>mina-core</artifactId>

<version>1.1.7</version>

</dependency>

<dependency>

<groupId>org.glassfish.grizzly</groupId>

<artifactId>grizzly-core</artifactId>

<version>2.1.4</version>

</dependency>

<dependency>

<groupId>org.apache.httpcomponents</groupId>

<artifactId>httpclient</artifactId>

<version>4.2.1</version>

</dependency>

<dependency>

<groupId>com.alibaba</groupId>

<artifactId>fastjson</artifactId>

<version>1.1.39</version>

</dependency>

<dependency>

<groupId>com.thoughtworks.xstream</groupId>

<artifactId>xstream</artifactId>

<version>1.4.1</version>

</dependency>

<dependency>

<groupId>org.apache.bsf</groupId>

<artifactId>bsf-api</artifactId>

<version>3.1</version>

</dependency>

<dependency>

<groupId>org.apache.zookeeper</groupId>

<artifactId>zookeeper</artifactId>

<version>3.4.6</version>

</dependency>

<dependency>

<groupId>com.github.sgroschupf</groupId>

<artifactId>zkclient</artifactId>

<version>0.1</version>

</dependency>

<dependency>

<groupId>org.apache.curator</groupId>

<artifactId>curator-framework</artifactId>

<version>2.5.0</version>

</dependency>

<dependency>

<groupId>com.googlecode.xmemcached</groupId>

<artifactId>xmemcached</artifactId>

<version>1.3.6</version>

</dependency>

<dependency>

<groupId>org.apache.cxf</groupId>

<artifactId>cxf-rt-frontend-simple</artifactId>

<version>2.6.1</version>

</dependency>

<dependency>

<groupId>org.apache.cxf</groupId>

<artifactId>cxf-rt-transports-http</artifactId>

<version>2.6.1</version>

</dependency>

<dependency>

<groupId>org.apache.thrift</groupId>

<artifactId>libthrift</artifactId>

<version>0.8.0</version>

</dependency>

<dependency>

<groupId>com.caucho</groupId>

<artifactId>hessian</artifactId>

<version>4.0.7</version>

</dependency>

<dependency>

<groupId>javax.servlet</groupId>

<artifactId>javax.servlet-api</artifactId>

<version>3.1.0</version>

</dependency>

<dependency>

<groupId>org.mortbay.jetty</groupId>

<artifactId>jetty</artifactId>

<exclusions>

<exclusion>

<groupId>org.mortbay.jetty</groupId>

<artifactId>servlet-api</artifactId>

</exclusion>

</exclusions>

<version>6.1.26</version>

</dependency>

<dependency>

<groupId>log4j</groupId>

<artifactId>log4j</artifactId>

<version>1.2.16</version>

</dependency>

<dependency>

<groupId>org.slf4j</groupId>

<artifactId>slf4j-api</artifactId>

<version>1.6.2</version>

</dependency>

<dependency>

<groupId>redis.clients</groupId>

<artifactId>jedis</artifactId>

<version>2.1.0</version>

</dependency>

<dependency>

<groupId>javax.validation</groupId>

<artifactId>validation-api</artifactId>

<version>1.0.0.GA</version>

</dependency>

<dependency>

<groupId>org.hibernate</groupId>

<artifactId>hibernate-validator</artifactId>

<version>4.2.0.Final</version>

</dependency>

<dependency>

<groupId>javax.cache</groupId>

<artifactId>cache-api</artifactId>

<version>0.4</version>

</dependency>

<dependency>

<groupId>org.jboss.resteasy</groupId>

<artifactId>resteasy-jaxrs</artifactId>

<version>3.0.7.Final</version>

</dependency>

<dependency>

<groupId>org.jboss.resteasy</groupId>

<artifactId>resteasy-client</artifactId>

<version>3.0.7.Final</version>

</dependency>

<dependency>

<groupId>org.jboss.resteasy</groupId>

<artifactId>resteasy-netty</artifactId>

<version>3.0.7.Final</version>

</dependency>

<dependency>

<groupId>org.jboss.resteasy</groupId>

<artifactId>resteasy-jdk-http</artifactId>

<version>3.0.7.Final</version>

</dependency>

<dependency>

<groupId>org.jboss.resteasy</groupId>

<artifactId>resteasy-jackson-provider</artifactId>

<version>3.0.7.Final</version>

</dependency>

<dependency>

<groupId>org.jboss.resteasy</groupId>

<artifactId>resteasy-jaxb-provider</artifactId>

<version>3.0.7.Final</version>

</dependency>

<dependency>

<groupId>org.apache.tomcat.embed</groupId>

<artifactId>tomcat-embed-core</artifactId>

<version>8.0.11</version>

</dependency>

<dependency>

<groupId>org.apache.tomcat.embed</groupId>

<artifactId>tomcat-embed-logging-juli</artifactId>

<version>8.0.11</version>

</dependency>

<dependency>

<groupId>com.esotericsoftware.kryo</groupId>

<artifactId>kryo</artifactId>

<version>2.24.0</version>

</dependency>

<dependency>

<groupId>de.javakaffee</groupId>

<artifactId>kryo-serializers</artifactId>

<version>0.26</version>

</dependency>

<dependency>

<groupId>de.ruedigermoeller</groupId>

<artifactId>fst</artifactId>

<version>1.55</version>

</dependency>

</dependencies>

<build>

<plugins>

<plugin>

<artifactId>maven-compiler-plugin</artifactId>

<configuration>

<source>1.6</source>

<target>1.6</target>

</configuration>

</plugin>

</plugins>

</build>

</project>

2、User.java

package com.hvgroup.user;

import java.io.Serializable;

import javax.validation.constraints.Min;

import javax.validation.constraints.NotNull;

import javax.validation.constraints.Size;

import javax.xml.bind.annotation.XmlAccessType;

import javax.xml.bind.annotation.XmlAccessorType;

import javax.xml.bind.annotation.XmlElement;

import javax.xml.bind.annotation.XmlRootElement;

import org.codehaus.jackson.annotate.JsonProperty;

@XmlRootElement

@XmlAccessorType(XmlAccessType.FIELD)

public class User implements Serializable {

@NotNull

@Min(1L)

private Long id;

@JsonProperty("username")

@XmlElement(name = "username")

@NotNull

@Size(min = 6, max = 50)

private String name;

public User() {

}

public User(Long id, String name) {

this.id = id;

this.name = name;

}

public Long getId() {

return id;

}

public void setId(Long id) {

this.id = id;

}

public String getName() {

return name;

}

public void setName(String name) {

this.name = name;

}

@Override

public String toString() {

return "User (" +

"id=" + id +

", name='" + name + '\'' +

')';

}

}

3、UserService.java

package com.hvgroup.user;

public interface UserService {

void registerUser(User user);

User getUser(Long id);

}

4、UserServiceImpl.java

package com.hvgroup.user;

public class UserServiceImpl implements UserService {

public void registerUser(User user) {

// save the user...

}

public User getUser(Long id) {

return new User(id, "username" + id);

}

}

5、UserServiceWebImpl.java

package com.hvgroup.user;

import com.alibaba.dubbo.rpc.RpcContext;

import com.hvgroup.user.User;

import com.hvgroup.user.UserService;

import javax.servlet.http.HttpServletRequest;

import javax.servlet.http.HttpServletResponse;

import javax.ws.rs.Consumes;

import javax.ws.rs.GET;

import javax.ws.rs.POST;

import javax.ws.rs.Path;

import javax.ws.rs.PathParam;

import javax.ws.rs.Produces;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

@Path("users")

@Consumes({"application/json", "text/xml"})

@Produces({"application/json; charset=UTF-8", "text/xml; charset=UTF-8"})

public class UserServiceWebImpl implements UserService {

private static final Logger logger = LoggerFactory.getLogger(UserServiceWebImpl.class);

private UserService userService;

public void setUserService(UserService userService) {

this.userService = userService;

}

@GET

@Path("{id : \\d+}")

public User getUser(@PathParam("id") Long id)

{

if (RpcContext.getContext().getRequest(HttpServletRequest.class) != null) {

System.out.println("Client IP address from RpcContext: " + ((HttpServletRequest)RpcContext.getContext().getRequest(HttpServletRequest.class)).getRemoteAddr());

}

if (RpcContext.getContext().getResponse(HttpServletResponse.class) != null) {

System.out.println("Response object from RpcContext: " + RpcContext.getContext().getResponse(HttpServletResponse.class));

}

return this.userService.getUser(id);

}

@POST

@Path("register")

public void registerUser(User user) {

}

}

6、dubbo-demo-provider.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-2.5.xsd

http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd">

<dubbo:application name="dubboxtest" owner="programmer" organization="dubbox"/>

<dubbo:registry address="zookeeper://192.168.89.135:2181"/>



<dubbo:protocol name="rest" port="8888" threads="500" server="tomcat" accepts="500"

extension="com.alibaba.dubbo.demo.extension.TraceInterceptor,

com.alibaba.dubbo.demo.extension.TraceFilter,

com.alibaba.dubbo.demo.extension.ClientTraceFilter,

com.alibaba.dubbo.demo.extension.DynamicTraceBinding,

com.alibaba.dubbo.demo.extension.CustomExceptionMapper,

com.alibaba.dubbo.rpc.protocol.rest.support.LoggingFilter"/>





<dubbo:service interface="com.hvgroup.user.UserWebService" ref="userWebService" protocol="rest" validation="true"/>





<bean id="userService" class="com.hvgroup.user.UserServiceImpl" />

<bean id="userWebService" class="com.hvgroup.user.UserServiceWebImpl">

<property name="userService" ref="userService"/>

</bean>

</beans>

7、log4j.xml

<?xml version="1.0" encoding="UTF-8"?>

<!DOCTYPE log4j:configuration SYSTEM "log4j.dtd">

<log4j:configuration xmlns:log4j="http://jakarta.apache.org/log4j/" debug="false">

<appender name="CONSOLE" class="org.apache.log4j.ConsoleAppender">

<layout class="org.apache.log4j.PatternLayout">

<param name="ConversionPattern" value="[%d{dd/MM/yy hh:mm:ss:sss z}] %t %5p %c{2}: %m%n" />

</layout>

</appender>

<root>

<level value="INFO" />

<appender-ref ref="CONSOLE" />

</root>

</log4j:configuration>

8、web.xml

<?xml version="1.0"?>

<!DOCTYPE web-app PUBLIC

"-//Sun Microsystems, Inc.//DTD Web Application 2.3//EN"

"http://java.sun.com/dtd/web-app_2_3.dtd" >

<web-app>

<context-param>

<param-name>contextConfigLocation</param-name>

<param-value>/WEB-INF/classes/dubbo-demo-provider.xml</param-value>

</context-param>

<listener>

<listener-class>com.alibaba.dubbo.remoting.http.servlet.BootstrapListener</listener-class>

</listener>

<listener>

<listener-class>org.springframework.web.context.ContextLoaderListener</listener-class>

</listener>

<servlet>

<servlet-name>dispatcher</servlet-name>

<servlet-class>com.alibaba.dubbo.remoting.http.servlet.DispatcherServlet</servlet-class>

<load-on-startup>1</load-on-startup>

</servlet>

<servlet-mapping>

<servlet-name>dispatcher</servlet-name>

<url-pattern>/*</url-pattern>

</servlet-mapping>

</web-app>

三、将新创建的项目部署到tomcat里面运行起来。

四、在浏览器上面 http://localhost:8888/users/1001

Een~~

更多内容请关注我，会第一时间持续进行更新。

人面猴
序言：七十年代末，一起剥皮案震惊了整个滨河市，随后出现的几起案子，更是在滨河造成了极大的恐慌，老刑警刘岩，带你破解...
沈念sama阅读 194,457评论 5赞 459
死咒
序言：滨河连续发生了三起死亡事件，死亡现场离奇诡异，居然都是意外死亡，警方通过查阅死者的电脑和手机，发现死者居然都...
沈念sama阅读 81,837评论 2赞 371
救了他两次的神仙让他今天三更去死
文/潘晓璐我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
开封第一讲书人阅读 141,696评论 0赞 319
道士缉凶录：失踪的卖姜人
文/不坏的土叔我叫张陵，是天一观的道长。经常有香客问我，道长，这世上最难降的妖魔是什么？我笑而不...
开封第一讲书人阅读 52,183评论 1赞 263
港岛之恋（遗憾婚礼）
正文为了忘掉前任，我火速办了婚礼，结果婚礼上，老公的妹妹穿的比我还像新娘。我一直安慰自己，他们只是感情好，可当我...
茶点故事阅读 61,057评论 4赞 355
恶毒庶女顶嫁案：这布局不是一般人想出来的
文/花漫我一把揭开白布。她就那样静静地躺着，像睡着了一般。火红的嫁衣衬着肌肤如雪。梳的纹丝不乱的头发上，一...
开封第一讲书人阅读 46,105评论 1赞 272
城市分裂传说
那天，我揣着相机与录音，去河边找鬼。笑死，一个胖子当着我的面吹牛，可吹牛的内容都是我干的。我是一名探鬼主播，决...
沈念sama阅读 36,520评论 3赞 381
双鸳鸯连环套：你想象不到人心有多黑
文/苍兰香墨我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
开封第一讲书人阅读 35,211评论 0赞 253
万荣杀人案实录
序言：老挝万荣一对情侣失踪，失踪者是张志新（化名）和其女友刘颖，没想到半个月后，有当地人在树林里发现了一具尸体，经...
沈念sama阅读 39,482评论 1赞 290
护林员之死
正文独居荒郊野岭守林人离奇死亡，尸身上长有42处带血的脓包…… 初始之章·张勋以下内容为张勋视角年9月15日...
茶点故事阅读 34,574评论 2赞 309
白月光启示录
正文我和宋清朗相恋三年，在试婚纱的时候发现自己被绿了。大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
茶点故事阅读 36,353评论 1赞 326
活死人
序言：一个原本活蹦乱跳的男人离奇死亡，死状恐怖，灵堂内的尸体忽然破棺而出，到底是诈尸还是另有隐情，我是刑警宁泽，带...
沈念sama阅读 32,213评论 3赞 312
日本核电站爆炸内幕
正文年R本政府宣布，位于F岛的核电站，受9级特大地震影响，放射性物质发生泄漏。R本人自食恶果不足惜，却给世界环境...
茶点故事阅读 37,576评论 3赞 298
男人毒药：我在死后第九天来索命
文/蒙蒙一、第九天我趴在偏房一处隐蔽的房顶上张望。院中可真热闹，春花似锦、人声如沸。这庄子的主人今日做“春日...
开封第一讲书人阅读 28,897评论 0赞 17
一桩弑父案，背后竟有这般阴谋
文/苍兰香墨我抬头看了看天上的太阳。三九已至，却和暖如春，着一层夹袄步出监牢的瞬间，已是汗流浃背。一阵脚步声响...
开封第一讲书人阅读 30,174评论 1赞 250
情欲美人皮
我被黑心中介骗来泰国打工，没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留，地道东北人。一个月前我还...
沈念sama阅读 41,489评论 2赞 341
代替公主和亲
正文我出身青楼，却偏偏与公主长得像，于是被迫代替她去往敌国和亲。传闻我的和亲对象是个残疾皇子，可洞房花烛夜当晚...
茶点故事阅读 40,683评论 2赞 335

微服务之 -- dubbox初次使用

推荐阅读更多精彩内容