1.dubbo快速入门
2.dubbo常规配置
一 、dubbo快速入门
dubbo是什么
dubbo是由阿里开源的SPA服务治理框架，更为贴切的说法是RPC远程过程调用框架，支持多种传输及序列化的方案。
引入依赖
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>dubbo</artifactId>
<version>2.6.2</version>
</dependency>
模块结构说明
模块.png
dubbo-client 是消费端模块，dubbo-server是服务提供端模块，server-SDK是作为组件，供dubbo-client与dubbo-server依赖,提供了功能接口与pojo类，目的是屏蔽掉服务提供端的接口实现类的业务逻辑，针对server-SDK的作用，相信阅读并coding完本文内容之后就可以理解了。
服务提供端代码(先引入API层面如何实现)
public class DubboServer {
public void buildService(int port){
ServiceConfig<UserService> serviceConfig = new ServiceConfig();
//设置注册中心,暂时没有引入注册中心
serviceConfig.setRegistry(new RegistryConfig(RegistryConfig.NO_AVAILABLE));
//设置传输过程中通信协议及端口号
serviceConfig.setProtocol(new ProtocolConfig("dubbo",port));
// 设置应用名
serviceConfig.setApplication(new ApplicationConfig("dubbo-server"));
//设置暴露服务的接口
serviceConfig.setInterface(UserService.class);
UserService userService = new UserServiceImpl();
//设置暴露服务的实现类
serviceConfig.setRef(userService);
//对外暴漏userService服务
serviceConfig.export();
int realPort = serviceConfig.getExportedUrls().get(0).getPort();
((UserServiceImpl) userService).setPort(realPort);
System.out.println("dubbo服务已开启："+realPort);
}
public static void main(String[] args) throws IOException {
new DubboServer().buildService(-1);
System.in.read();
}
}
服务消费端代码(先引入API层面如何实现)
public class DubboClient {
private String remoteUrl = "dubbo://169.254.103.163:20880/com.ckd.dubbo.server.UserService"
public UserService getUser(){
ReferenceConfig<UserService> referenceConfig = new ReferenceConfig();
referenceConfig.setInterface(UserService.class);
referenceConfig.setApplication(new ApplicationConfig("dubbo-client"));
referenceConfig.setUrl(remoteUrl);
UserService userService = referenceConfig.get();
return userService;
}
public static void main(String[] args) {
UserService user = new DubboClient().getUser();
System.out.println(user.getUser(1));
}
}
服务端集群
试想一下,上面代码中需要服务消费端知道服务端地址才可以实现通信,此时可以将地址配置在消费端，但是随着服务端访问量变大时，需要增加节点时，消费端需要人工维护地址，并自己实现负载策略以决定调用那个节点。不利于动态扩容。
集群
因此需要引入注册中心，以实现动态扩容，监控服务的上下线。
注册中心
修改服务端与消费端API
服务提供端
serviceConfig.setRegistry(new RegistryConfig("multicast://224.5.6.7:1234"));
服务消费端
referenceConfig.setRegistry(new RegistryConfig("multicast://224.5.6.7:1234"));
集成spring
服务提供端
<beans xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:dubbo="http://dubbo.apache.org/schema/dubbo"
xmlns="http://www.springframework.org/schema/beans"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.3.xsd
http://dubbo.apache.org/schema/dubbo http://dubbo.apache.org/schema/dubbo/dubbo.xsd">
<!--provider应用名-->
<dubbo:application name="dubbo-provider"/>
<!--用dubbo协议从20800端口开始暴漏服务-->
<dubbo:protocol name="dubbo" port="-1"/>
<!--<dubbo:registry address="zookeeper://localhost:2181"/>-->
<!--用multicast广播注册中心暴漏服务地址-->
<dubbo:registry address="multicast://224.5.6.7:1234"/>
<!--dubbo:provider 提供了默认配置
protocol="dubbo" port="-1" 可以不用<dubbo:protocol>标签
application 可以代替<dubbo:application>标签
timeout,retries....可以应用在<dubbo:service>标签里，避免配置多个<dubbo:service>时重复配置
-->
<dubbo:provider protocol="dubbo" port="-1" application="dubbo-provider" retries="2"
timeout="5000" loadbalance="roundrobin" threadpool="fixed" />
<dubbo:service loadbalance="roundrobin" interface="com.ckd.dubbo.server.UserService" ref="userService"/>
<bean id="userService" class="com.ckd.dubbo.server.impl.UserServiceImpl"/>
</beans>
