Java教程

Dubbo无法发布被事务代理的问题

本文主要是介绍Dubbo无法发布被事务代理的问题,对大家解决编程问题具有一定的参考价值,需要的程序猿们随着小编来一起学习吧!

前言

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

修改前配置文件

<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管理中心,生产者和消费者是否都存在

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

这篇关于Dubbo无法发布被事务代理的问题的文章就介绍到这儿,希望我们推荐的文章对大家有所帮助,也希望大家多多支持为之网!