前言

当程序中加入事务时，生产者服务就会发布失败

修改前配置文件

<dubbo:application name="dubbo-provider"/>
<dubbo:registry address="zookeeper://192.168.211.131:2181"/>
<dubbo:protocol name="dubbo" port="20880"/>
<dubbo:annotation package="com.kkb.dubbo.service.impl"/>

<bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource">
        <property name="driverClassName" value="com.mysql.cj.jdbc.Driver"/>
        <property name="url" value="jdbc:mysql:///school"/>
        <property name="username" value="root"/>
        <property name="password" value="root"/>
</bean>
<bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
        <property name="dataSource" ref="dataSource"/>
</bean>
<tx:annotation-driven/>

修改前接口实现类

@Service
@Transactional(rollbackFor = Exception.class)
public class UserServiceImpl implements UserService {

    @Override
    public String hello(String name) {
        return "hello :" +name;
    }
}

解决：

1、在事务注解支持里加入：proxy-target-class=true

<tx:annotation-driven proxy-target-class="true"/>

作用：基于cglib代理，默认是基于jdk代理

此时发布的服务接口为Spring默认的SpringProxy代理类

完整配置文件：

<dubbo:application name="dubbo-provider"/>
<dubbo:registry address="zookeeper://192.168.211.131:2181"/>
<dubbo:protocol name="dubbo" port="20880"/>
<dubbo:annotation package="com.kkb.dubbo.service.impl"/>

<bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource">
        <property name="driverClassName" value="com.mysql.cj.jdbc.Driver"/>
        <property name="url" value="jdbc:mysql:///school"/>
        <property name="username" value="root"/>
        <property name="password" value="root"/>
</bean>
<bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
        <property name="dataSource" ref="dataSource"/>
</bean>
    <!--默认使用jdk动态代理，proxy-target-class：使用cglib代理-->
<tx:annotation-driven proxy-target-class="true"/>

2、在实现类上添加：

@Service(interfaceClass = UserService.class)

作用：指定发布的服务接口

完整实现类：

@Service(interfaceClass = UserService.class)
@Transactional(rollbackFor = Exception.class)
public class UserServiceImpl implements UserService {

    @Override
    public String hello(String name) {
        return "hello :" +name;
    }
}

至此，配置完成。

下图是我在操作过程中碰到的问题：消费方调用超时

解决方法可以参考如下：

1、数据源的配置是否有误

2、检查实体类，是否实现了序列化接口

3、检查zookeeper管理中心，生产者和消费者是否都存在

我出现这种情况，是因为数据库不存在导致的，我更新了数据库之后，调用就正常了。