Dubbo在项目中的应用（一）

Dubbo作为分布式服务治理框架在企业级应用开发中运用的特别广泛，它打破了传统垂直项目架构的开发模式，将各个模块更细粒度的切分部署，在解耦的同时也提高了代码的重用性。

2018-01-09_111925.png

部分代码，

service-product工程

TestTbServiceImpl.java

@Service("testTbService")
@Transactional
public class TestTbServiceImpl implements TestTbService {   
    @Autowired
    private TestTbDao testTbDao;
    
    public void insertTestTb(TestTb testTb){
        testTbDao.insertTestTb(testTb);
    }
}

dubbo-provider.xml

<beans xmlns="http://www.springframework.org/schema/beans"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:mvc="http://www.springframework.org/schema/mvc"
    xmlns:context="http://www.springframework.org/schema/context"
    xmlns:aop="http://www.springframework.org/schema/aop" 
    xmlns:tx="http://www.springframework.org/schema/tx"
    xmlns:task="http://www.springframework.org/schema/task"
    xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
    xsi:schemaLocation="http://www.springframework.org/schema/beans 
        http://www.springframework.org/schema/beans/spring-beans-4.0.xsd 
        http://www.springframework.org/schema/mvc 
        http://www.springframework.org/schema/mvc/spring-mvc-4.0.xsd 
        http://www.springframework.org/schema/context 
        http://www.springframework.org/schema/context/spring-context-4.0.xsd 
        http://www.springframework.org/schema/aop 
        http://www.springframework.org/schema/aop/spring-aop-4.0.xsd 
        http://www.springframework.org/schema/tx 
        http://www.springframework.org/schema/tx/spring-tx-4.0.xsd
        http://www.springframework.org/schema/task
        http://www.springframework.org/schema/task/spring-task-4.0.xsd
        http://code.alibabatech.com/schema/dubbo        
        http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
        
    <!-- Dubbo提供方 -->
    <!-- 1：名称  计算机 区别 唯一 -->
    <dubbo:application name="babasport-service-product"/>
    <!-- 2：设置注册中心  地址  zookeeper在哪里  redis ...(集群的zk执行以“，”相隔，写入ip即可) -->
    <dubbo:registry address="192.168.90.201:2181" protocol="zookeeper"/>
    <!-- 3：dubbo://192.168.39.80:20880  默认  设置提供服务的端口号 -->
    <dubbo:protocol port="20881" name="dubbo"/>
    <!-- 4： 暴露实现类-->
    <dubbo:service interface="cn.babasport.core.service.TestTbService" ref="testTbService"/>
        
    <!-- 5：服务端的全局配置 -->
    <dubbo:provider></dubbo:provider>   
</beans>

区别zk启动，并发布服务

2018-01-09_113627.png

看日志很明显，服务接口以及在zk中注册成功，我们可以去dubbo的控制台确认

2018-01-09_113808.png

console工程调用

controller.java

@Controller
public class CenterController {

    @Autowired
    private TestTbService testTbService;//注意这里注入的是接口，interface工程的
    
    //入口
    /**
     * ModelAndView  : 跳转视图+数据     不用
     * void  : 异步时 ajax    
     * String  : 跳转视图      +  Model
     */
    @RequestMapping(value = "/test/index.do")
    public String index(Model model){
        TestTb testTb = new TestTb();
        testTb.setName("zhangsan");
        testTbService.insertTestTb(testTb);
        
        System.out.println("-----------");
        return "index";
    }   
}

dubbo-consumer.xml调用配置

<beans xmlns="http://www.springframework.org/schema/beans"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:mvc="http://www.springframework.org/schema/mvc"
    xmlns:context="http://www.springframework.org/schema/context"
    xmlns:aop="http://www.springframework.org/schema/aop" 
    xmlns:tx="http://www.springframework.org/schema/tx"
    xmlns:task="http://www.springframework.org/schema/task"
    xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
    xsi:schemaLocation="http://www.springframework.org/schema/beans 
        http://www.springframework.org/schema/beans/spring-beans-4.0.xsd 
        http://www.springframework.org/schema/mvc 
        http://www.springframework.org/schema/mvc/spring-mvc-4.0.xsd 
        http://www.springframework.org/schema/context 
        http://www.springframework.org/schema/context/spring-context-4.0.xsd 
        http://www.springframework.org/schema/aop 
        http://www.springframework.org/schema/aop/spring-aop-4.0.xsd 
        http://www.springframework.org/schema/tx 
        http://www.springframework.org/schema/tx/spring-tx-4.0.xsd
        http://www.springframework.org/schema/task
        http://www.springframework.org/schema/task/spring-task-4.0.xsd
        http://code.alibabatech.com/schema/dubbo        
        http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
        
    <!-- Dubbo消费方 -->
    <!-- 1：名称  计算机 区别 唯一 -->
    <dubbo:application name="babasport-console"/>
    <!-- 2：设置注册中心  地址  zookeeper在哪里  redis ...(集群的zk执行以“，”相隔，写入ip即可) -->
    <dubbo:registry address="192.168.90.201:2181" protocol="zookeeper"/>
    <!-- 3： 调用此接口对应的实现类-->
    <dubbo:reference interface="cn.babasport.core.service.TestTbService" id="testTbService"/>
    
    <!-- dubbo全局设置超时时间 -->
    <dubbo:consumer timeout="600000" check="false"></dubbo:consumer>
</beans>

当然在springMVC的配置中也少不了对dubbo消费配置的读取
springMVC.xml配置

//引入即可
<import resource="dubbo-consumer.xml"/>

以上要注意的是在dubbo服务暴露接口的配置中ref属性的值要与service实现类在注入service中的值相同@Service("testTbService")，当然，这里用的是spring中的service注解，而非dubbo中的service注解

<dubbo:service interface="cn.babasport.core.service.TestTbService" ref="testTbService"/>

dubbo优化

我们知道，dubbo需要注册中心，在开发过程中，我们完全可以使用dubbo直连的方式避开注册中心，这样就不用去启用ZK了，另外去check也可以提高dubbo的效率

优化1，直连

//即将服务提高和服务消费方的注册中心设为“N/A”即可
<dubbo:registry address="N/A"/>

优化2，停止检查

<!-- dubbo全局设置超时时间 -->
<dubbo:consumer timeout="600000" check="false"></dubbo:consumer>