The dubbo from zhangkunvip

#dubbo

增加 springmvc,jersey,rest,jsonrpc,xmlrpc,avro,grpc，websocket rpc,hprose,原生thrift,jms,redis rpc.

增加none http容器,只注册服务,不导出服务.使其更好的支持springboot.

增加hystrix 熔断支持。

增加spring oauth2 客户端支持.

增加安卓消费dubbo服务的支持.

###安装

mvn install -Dmaven.test.skip=true

###增加了3个http容器 tomcat8,jetty9,none

<dubbo:protocol name="springmvc" server="jetty9" port="8080" />

<dubbo:protocol name="springmvc" server="tomcat" port="8080" />

 <!-- 如果 server 值为none,只注册服务,不导出服务,由第三方提供rest服务.dubbo消费 第三方rest服务 -->
<dubbo:protocol name="springmvc" server="none" />

###springmvc depenecies

<dependency>
    <groupId>org.springframework</groupId>
    <artifactId>spring-webmvc</artifactId>
</dependency>

<dependency>
    <groupId>io.github.openfeign</groupId>
    <artifactId>feign-core</artifactId>
</dependency>
<dependency>
    <groupId>io.github.openfeign</groupId>
    <artifactId>feign-hystrix</artifactId>
</dependency>
<dependency>
    <groupId>org.hibernate</groupId>
    <artifactId>hibernate-validator</artifactId>
</dependency>
<dependency>
    <groupId>org.apache.httpcomponents</groupId>
    <artifactId>httpclient</artifactId>
</dependency>

<dependency>
    <groupId>com.alibaba</groupId>
    <artifactId>fastjson</artifactId>
</dependency>

<dependency>
    <groupId>com.fasterxml.jackson.core</groupId>
    <artifactId>jackson-databind</artifactId>
</dependency>

###springmvc example

建议使用高版本的springmvc



接口定义,用来指定相关方法地址,请求方法/参数.
@RequestMapping("/comment")
public interface CommentService {

    @RequestMapping(value = "/", method = RequestMethod.POST, consumes = MediaType.APPLICATION_JSON_VALUE)
    public Comment add(@RequestBody Comment comment);

    @RequestMapping(value = "/{id}", method = RequestMethod.GET,produces = MediaType.APPLICATION_JSON_VALUE)
    public Comment get(@PathVariable("id") Integer id);

    @RequestMapping(value = "/{id}", method = RequestMethod.DELETE)
    public Comment delete(@PathVariable("id")Integer id);

    @RequestMapping(value = "/", method = RequestMethod.PUT,consumes = MediaType.APPLICATION_JSON_VALUE)
    public Comment update(@RequestBody Comment comment);

}

###支持消费非dubbo提供的接口

<!-- 生成远程服务代理，可以像使用本地bean一样使用userService -->
 <!-- 如果已经服务中心注册了服务, 可以不用url直连,url直连的是未在服务中心注册的-->
<dubbo:reference id="userService" interface="com.vcg.UserService" protocol="springmvc" url="springmvc://提供服务的server,可以非dubbo服务端" />

###更好的支持springmvc

由于dubbo-springmvc提供的rest服务,有诸多限制.例如不能使用相关拦截器 .这时候可以由自己提供相关 springmvc 的rest服务,由dubbo消费端负责消费
只需配置提供的协议是springmvc 服务为none即可,只注册相关服务,但不导出相关服务.dubbo消费端可以通过提供的注册地址 ,即可消费自定义的rest服务.
<dubbo:protocol name="springmvc" server="none" />

###Avro

<dependency>
    <groupId>org.apache.avro</groupId>
    <artifactId>avro-ipc</artifactId>
    <version>1.8.1</version>
</dependency>

###Avro example

<!--avro-->
<dubbo:protocol port="8084" name="avro"/>
<bean id="avroService" class="com.alibaba.dubbo.demo.provider.AvroServiceImpl"/>
<dubbo:service interface="com.alibaba.dubbo.demo.AvroService" ref="avroService" protocol="avro"/>
<!--avro-->

###Thrift9

<dependency>
    <groupId>org.apache.thrift</groupId>
    <artifactId>libthrift</artifactId>
    <version>0.9.3</version>
    <exclusions>
        <exclusion>
            <groupId>org.apache.httpcomponents</groupId>
            <artifactId>httpcore</artifactId>
        </exclusion>
    </exclusions>
</dependency>
<dependency>
    <groupId>org.apache.commons</groupId>
    <artifactId>commons-pool2</artifactId>
     <version>2.4.2</version>
</dependency>

###Thrift example

<!--Thrift9-->
<dubbo:protocol port="8083" name="thrift9"/>
<bean id="fooService" class="com.alibaba.dubbo.demo.provider.FooServiceImpl"/>
<dubbo:service interface="com.alibaba.dubbo.demo.FooService$Iface" ref="fooService" protocol="thrift9"/>
<!--Thrift9-->

###Grpc

<dependency>
    <groupId>io.grpc</groupId>
    <artifactId>grpc-all</artifactId>
    <version>1.0.3</version>
</dependency>
<dependency>
    <groupId>org.apache.commons</groupId>
    <artifactId>commons-pool2</artifactId>
    <version>2.4.2</version>
</dependency>

###Grpc example

<!--Grpc-->
<dubbo:protocol port="8082" name="grpc"/>
<bean id="helloWorldService" class="com.alibaba.dubbo.demo.provider.grpc.HelloWorldServiceImpl"/>
<dubbo:service interface="io.grpc.examples.helloworld.GreeterGrpc$Greeter" ref="helloWorldService" protocol="grpc"/>
<!--Grpc-->

###Jersey

<dependency>
    <groupId>org.glassfish.jersey.containers</groupId>
    <artifactId>jersey-container-netty-http</artifactId>
</dependency>
<dependency>
    <groupId>org.glassfish.jersey.media</groupId>
    <artifactId>jersey-media-moxy</artifactId>
</dependency>
<dependency>
    <groupId>org.glassfish.jersey.media</groupId>
    <artifactId>jersey-media-json-jackson</artifactId>
</dependency>
<dependency>
    <groupId>org.jboss.resteasy</groupId>
    <artifactId>resteasy-client</artifactId>
</dependency>

<!--Jersey-->
<dubbo:protocol port="8081" name="jersey"/>
<bean id="commentService" class="com.alibaba.dubbo.demo.provider.CommentServiceImpl"/>
<dubbo:service interface="com.alibaba.dubbo.demo.CommentService" ref="commentService" protocol="jersey"/>
<!--Jersey-->

###Dubbo springmvc Rest Proxy

/**
 * http://localhost:8080/
 * POST,PUT,DELETE
 * 调用示例
 * {
 * "jsonrpc":2.0 ,//兼容jsonrpc， 如果携带次参数 将以jsonrpc 格式返回
 * "service":"com.alibaba.dubbo.demo.DemoService",
 * "method":"sayHello", //可以以 com.alibaba.dubbo.demo.DemoService.sayHello 来省略 service
 * "group":"defaultGroup",//可以不写
 * "version":"1.0" ,//可以不写
 * "paramsType":["java.lang.String"], //可以不写 如果有方法重载必须填写
 * "params":["wuyu"]
 * }
 *
 * @param config
 * @return
 */
 
<!--DubboProxy:start-->
<!--代理 Dubbo,并转化为Rest服务 可通过http方式调用dubbo服务-->
<bean class="com.alibaba.dubbo.rpc.protocol.springmvc.proxy.ProxyServiceImpl" id="proxyService"/>

<!--如果本身是web服务,可以省略这一步.该步骤是为了初始化springmvc容器-->
<dubbo:service interface="com.alibaba.dubbo.rpc.protocol.springmvc.proxy.ProxyService" ref="proxyService"
               protocol="springmvc"/>
<!--DubboProxy:end-->

###RestProxy

/**
 * http://localhost:8080/
 * POST,PUT,DELETE
 * 调用示例
 * {
 * "jsonrpc":2.0 ,//兼容jsonrpc， 如果携带次参数 将以jsonrpc 格式返回
 * "service":"com.alibaba.dubbo.demo.DemoService",
 * "method":"sayHello", //可以以 com.alibaba.dubbo.demo.DemoService.sayHello 来省略 service
 * "group":"defaultGroup",//可以不写
 * "version":"1.0" ,//可以不写
 * "paramsType":["java.lang.String"], //可以不写 如果有方法重载必须填写
 * "params":["wuyu"]
 * }
 *
 * @param config
 * @return
 */
 
 <dependency>
     <groupId>com.alibaba</groupId>
     <artifactId>fastjson</artifactId>
 </dependency>
 <dependency>
     <groupId>com.fasterxml.jackson.core</groupId>
     <artifactId>jackson-databind</artifactId>
 </dependency>
 <dependency>
     <groupId>org.apache.httpcomponents</groupId>
     <artifactId>httpclient</artifactId>
 </dependency>
 
 
Server:

<!--代理 Dubbo,并转化为Rest服务 可通过http方式调用dubbo服务-->
<dubbo:protocol port="8087" name="restproxy" server="tomcat"/>
<bean class="com.alibaba.dubbo.rpc.protocol.proxy.ProxyServiceImpl" id="restProxy"/>

<!--发布多个注册中心,代理服务端跨注册中心调用-->
<dubbo:service interface="com.alibaba.dubbo.rpc.protocol.proxy.ProxyService" ref="restProxy" protocol="restproxy"/>

Client:
<dubbo:reference interface="com.alibaba.dubbo.rpc.protocol.proxy.ProxyService" id="proxyService"/>
DemoService demoservice = proxyService.target(DemoService.class);

###WebSocket

<dependency>
    <groupId>com.corundumstudio.socketio</groupId>
    <artifactId>netty-socketio</artifactId>
</dependency>
<dependency>
    <groupId>io.socket</groupId>
    <artifactId>socket.io-client</artifactId>
    <version>0.8.3</version>
</dependency>
<dependency>
    <groupId>com.squareup.okhttp3</groupId>
    <artifactId>okhttp</artifactId>
    <version>3.5.0</version>
</dependency>
<dependency>
    <groupId>com.github.briandilley.jsonrpc4j</groupId>
    <artifactId>jsonrpc4j</artifactId>
    <version>1.2.0</version>
</dependency>
<dependency>
    <groupId>io.reactivex</groupId>
    <artifactId>rxjava</artifactId>
    <version>1.1.10</version>
</dependency>
<dependency>
    <groupId>org.apache.commons</groupId>
    <artifactId>commons-pool2</artifactId>
    <version>2.4.2</version>
</dependency>

###websocket example

<!--websocket-->
<dubbo:protocol port="8086" name="ws"/>
<bean id="webSocketService" class="com.alibaba.dubbo.demo.provider.WebSocketServiceImpl"/>
<dubbo:service interface="com.alibaba.dubbo.demo.WebSocketService" ref="webSocketService" protocol="ws"/>
<!--websocket-->

###rest

<!--rest:start-->
<dubbo:protocol port="8088" name="rest"/>
<bean id="restService" class="com.alibaba.dubbo.demo.provider.RestServiceImpl"/>
<dubbo:service interface="com.alibaba.dubbo.demo.RestService" ref="restService" protocol="rest"/>
<!--rest:end-->

###hprose

<!--hprose:start  hprose 支持两种模式,http,tcp.-->
<dubbo:protocol port="8089" name="hprose" server="tomcat"/>
<dubbo:protocol port="4321" name="hprose_tcp"/>
<bean id="hproseService" class="com.alibaba.dubbo.demo.provider.HproseServiceImpl"/>
<dubbo:service interface="com.alibaba.dubbo.demo.HproseService" ref="hproseService" protocol="hprose,hprose_tcp"/>
<!--hprose:end-->

###更好的支持springboot

springboot 与dubbo结合使用,由于springboot已经提供了相关的rest服务,这时候再用dubbo提供相关的rest服务显得有点多余.
但是 我们可以使用dubbo的注册中心,把相关提供服务的机器注册进去.这样dubbo消费端就可以消费springboot rest提供的相关服务了
<dubbo:protocol name="springmvc" server="none" />

spring-boot-starter-dubbo git: https://git.oschina.net/wuyu15255872976/spring-boot-starter-dubbo.git

###未来

支持eureka,consul,etcd 达到与springcloud 相互兼容,服务发现,服务调用

zhangkunvip / dubbo Goto Github PK

dubbo's Introduction

dubbo's People

Contributors

Watchers

Recommend Projects

React

Vue.js

Typescript

TensorFlow

Django

Laravel

D3

Recommend Topics

javascript

web

server

Machine learning

Visualization

Game

Recommend Org

Facebook

Microsoft

Google

Alibaba

D3

Tencent