dubbo项目开发实战

dubbo结合spring boot,直接采用注解的方式,没有采用xml配置
使用的是zookeeper作为服务注册中心
spring cloud的服务化是使用的restful的方式,是基于http,但是http请求会有连接的问题存在,因此使用dubbo的rpc的方式是比较好的服务化的实现方式。
服务化的基本要素是一个服务需要能独立完成一个业务内容,否则会导致分布式事务的问题。

专注于为中小企业提供成都网站设计、成都做网站服务,电脑端+手机端+微信端的三站合一,更高效的管理,为中小企业台州免费做网站提供优质的服务。我们立足成都,凝聚了一批互联网行业人才,有力地推动了数千家企业的稳健成长,帮助中小企业通过网站建设实现规模扩充和转变。

1:创建空的maven项目,引入依赖:

    
    
        com.alibaba.boot
        dubbo-spring-boot-starter
        0.2.0
    

2:使用properties配置

app.service.version=1.0.0
\# Base packages to scan Dubbo Component: @com.alibaba.dubbo.config.annotation.Service
dubbo.scan.basePackages=com.seasfood.producer.
\# Dubbo Config properties
\## ApplicationConfig Bean
dubbo.application.id=seasfood-dubbo-id
dubbo.application.name=seasfood-dubbo-name
dubbo.application.qos.port=22222
dubbo.application.qos.enable=true
\## ProtocolConfig Bean
dubbo.protocol.id=dubbo-id
\#只能是dubbo,这个是协议名
dubbo.protocol.name=dubbo
dubbo.protocol.port=9090
dubbo.protocol.status=server
\## RegistryConfig Bean
dubbo.registry.id=zookeeper
dubbo.registry.address=zookeeper://zk-cs:2181
\# Enables Dubbo All Endpoints
management.endpoint.dubbo.enabled=true
management.endpoint.dubbo-shutdown.enabled=true
management.endpoint.dubbo-configs.enabled=true
management.endpoint.dubbo-services.enabled=true
management.endpoint.dubbo-references.enabled=true
management.endpoint.dubbo-properties.enabled=true
\# Dubbo Health
\## StatusChecker Name defaults (default : "memory", "load" )
management.health.dubbo.status.defaults=memory
\## StatusChecker Name extras (default : empty )
management.health.dubbo.status.extras=load,threadpool

3:声明一个服务接口,声明一个实现类实现接口,然后在实现类上注解

public interface MyInterface{}

@Service(
                version = "${app.service.version}",
                application = "${dubbo.application.id}",
                protocol = "${dubbo.protocol.id}",
                registry = "${dubbo.registry.id}"
)
public class MyService implements MyIneterface {}

4:如果接口中需要传输DTO类型的,需要给类型实现序列化接口Serializable,否则在rpc调用会报错

5:消费者只需要注入使用即可

     @Reference(version = "${app.service.version}",
                        lazy = true,
                        application = "${dubbo.application.id}",
                        registry = "${dubbo.registry.id}"
        )
        private MyInterface myInterface;

6:配置:有很多配置,目前我这用到的,一个是均衡负载配置,一个是服务降级配置,一个是集群容错(重试)负载均衡配置在服务端和客户端都可以配置,配置loadbalance属性即可,缺省为random,可以配置roundrobin
集群容错配置retries属性,
服务降级配置:在@Reference里配置mock属性
br/>负载均衡配置在服务端和客户端都可以配置,配置loadbalance属性即可,缺省为random,可以配置roundrobin
集群容错配置retries属性,
服务降级配置:在@Reference里配置mock属性

当前文章:dubbo项目开发实战
文章链接:http://ybzwz.com/article/iejesg.html