1.pom引入dubbo依赖
<dependency>
<groupId>io.dubbo.springboot</groupId>
<artifactId>spring-boot-starter-dubbo</artifactId>
<version>1.0.0</version>
</dependency
2.application.properties中引入dubbo 配置信息
# Dubbo provider server config
spring.dubbo.application.name=provider
spring.dubbo.registry.address=zookeeper://ip:2181
spring.dubbo.protocol.name=dubbo
spring.dubbo.protocol.port=20880
spring.dubbo.scan=com
3.封装接口service,接口实现类加dubbo的service注解
import com.alibaba.dubbo.config.annotation.Service;
以上是服务提供,服务消费和提供引入类似
4.消费者引用dubbo服务
首先把服务提供者的service接口打成jar包,service接口一定要有注释,此处最好打包时带源码,方便别人调用时查看调用的方法。
import com.alibaba.dubbo.config.annotation.Reference;
@Reference(timeout=6000)
private IRedisService redisService;
引入即可。
5.dubbo提供服务时的注意点:
若服务内有被事务代理的bean注入,或是方法有
import javax.transaction.Transactional;
被事务管理的,则服务注册zookeeper时会失败。
解决方案:
将有事务管理的方法写到另外的service类内。比如:
@Service
public class UserServiceImpl implements IUserService{
private Logger logger = LoggerFactory.getLogger(UserServiceImpl.class);
@Autowired
private MemberRepository memberRepository;
@Autowired
private VoiceprintRepository voiceprintRepository;
@Autowired
private TranscationService transcationService;
private Member insertMember(String contract, YHTUserVO yhtUserVO) {
transcationService.save(member);
}
UserServiceImpl是我要注册的dubbo服务,TranscationService为放置事务管理的方法类
import javax.transaction.Transactional;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
@Service
public class TranscationService {
@Autowired
private MemberRepository memberRepository;
@Transactional
public void save(Member member){
memberRepository.save(member);
}
@Transactional
public void saveAndFlush(Member member){
memberRepository.save(member);
}
}
至此,基本就简单实现了注册服务与调用服务了。
查看dubbo服务是否注册和发布成功:
6.若是服务既是提供者又是消费者,发现服务发现不了,可以把扫描包路径设置成一致的即可。