Dubbo?

一款高性能、轻量级的开源Java RPC框架，它提供了三大核心能力：面向接口的远程方法调用，智能容错和负载均衡，以及服务自动注册和发现

原理图

特性：

• 面向接口代理的高性能RPC调用
• 智能负载均衡
• 服务自动注册与发现
• 高度可扩展能力
• 运行期流量调度
• 可视化的服务治理与运维

本文使用的是Apache Dubbo 2.7.2版本

首先搭建管理后台

下载源码
git clone https://github.com/apache/dubbo-admin.git
下载后进入目录打包 注：如果zk不是安装在本机，需要指定zk的地址
dubbo-admin-server项目下resource文件夹的application.properties文件
mvn install -DskipTests
找到打好的jar包执行 cd dubbo-admin-distribution/target
java -jar dubbo-admin-0.1.jar

访问8080端口

Demo

提供一个示例依赖pom.xml

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-test</artifactId>
    <scope>test</scope>
</dependency>
<!--自定义接口包-->
<dependency>
    <groupId>com.zkdubbo</groupId>
    <artifactId>zk-dubbo-client</artifactId>
    <version>1.0-SNAPSHOT</version>
</dependency>
<!--dubbo 开始-->
<!--alibaba 提供的starter包依赖了 dubbo2.6.2 zookeeper3.4.8 -->
<!--<dependency>
    <groupId>com.alibaba.boot</groupId>
    <artifactId>dubbo-spring-boot-starter</artifactId>
    <version>0.2.0</version>
</dependency>-->
<!--apache 提供的starter包没有依赖 dubbo zookeeper -->
<dependency>
    <groupId>org.apache.dubbo</groupId>
    <artifactId>dubbo-spring-boot-starter</artifactId>
    <version>RELEASE</version>
</dependency>
<dependency>
    <groupId>org.apache.dubbo</groupId>
    <artifactId>dubbo</artifactId>
    <version>2.7.2</version>
</dependency>
<dependency>
    <groupId>org.apache.curator</groupId>
    <artifactId>curator-framework</artifactId>
    <version>2.12.0</version>
</dependency>
<!-- 这个是必要的 -->
<dependency>
    <groupId>org.apache.curator</groupId>
    <artifactId>curator-recipes</artifactId>
    <version>2.12.0</version>
</dependency>
<!--dubbo 结束-->

<!--dubbo项目这样已经OK了没有问题-->
<!--使用rest协议-->

<dependency>
    <groupId>org.jboss.resteasy</groupId>
    <artifactId>resteasy-jaxrs</artifactId>
    <version>3.0.7.Final</version>
</dependency>
<dependency>
    <groupId>org.jboss.resteasy</groupId>
    <artifactId>resteasy-client</artifactId>
    <version>3.0.7.Final</version>
</dependency>
<dependency>
    <groupId>javax.validation</groupId>
    <artifactId>validation-api</artifactId>
    <version>1.1.0.Final</version>
</dependency>
<!-- 如果要使用json序列化 -->
<dependency>
    <groupId>org.jboss.resteasy</groupId>
    <artifactId>resteasy-jackson-provider</artifactId>
    <version>3.0.7.Final</version>
</dependency>
<!-- 如果要使用xml序列化 -->
<dependency>
    <groupId>org.jboss.resteasy</groupId>
    <artifactId>resteasy-jaxb-provider</artifactId>
    <version>3.0.7.Final</version>
</dependency>
<dependency>
    <groupId>com.esotericsoftware.kryo</groupId>
    <artifactId>kryo</artifactId>
    <version>2.24.0</version>
</dependency>
<dependency>
    <groupId>de.javakaffee</groupId>
    <artifactId>kryo-serializers</artifactId>
    <version>0.26</version>
</dependency>
<!--使用Tomcat服务器-->
<!--<dependency>
    <groupId>org.apache.tomcat.embed</groupId>
    <artifactId>tomcat-embed-core</artifactId>
    <version>9.0.21</version>
</dependency>-->
<!--使用jetty服务器-->
<dependency>
    <groupId>org.eclipse.jetty</groupId>
    <artifactId>jetty-server</artifactId>
    <version>9.4.18.v20190429</version>
</dependency>
<dependency>
    <groupId>org.eclipse.jetty</groupId>
    <artifactId>jetty-util</artifactId>
    <version>9.4.18.v20190429</version>
</dependency>
<dependency>
    <groupId>org.eclipse.jetty</groupId>
    <artifactId>jetty-servlet</artifactId>
    <version>9.4.18.v20190429</version>
</dependency>

创建一个SpringBoot项目什么都不需要勾选任何依赖
1：创建服务接口示例：DubboResponse 可以自定义或者直接就字符串

@Path("zkDubboServer")
@Consumes(MediaType.APPLICATION_JSON)
@Produces({MediaType.APPLICATION_JSON})
public interface IZkDubboServers {

    @GET
    @Path("hello")
    DubboResponse hello();

    @POST
    @Path("hello")
    DubboResponse postHello(Object object);
}

2：创捷服务实现示例：

@Component // spring的注解
@Service   // dubbo提供的注解，这样就暴露了服务
public class UserServer implements IZkDubboServers {
    @Override
    public DubboResponse hello() {
        return DubboResponseBuild.success();
    }

    @Override
    public DubboResponse postHello(Object object) {
        return DubboResponseBuild.success();
    }

}

3：启动类上添加注解 @EnableDubbo

@EnableDubbo // 开启dubbo的自动配置
@SpringBootApplication
public class ZkDubboServerApplication {

    public static void main(String[] args) {
        SpringApplication.run(ZkDubboServerApplication.class, args);
    }

}

4： 配置文件编辑示例

dubbo.application.name= zk-dubbo-server # 服务名称
dubbo.application.owner= bertram #服务拥有者

dubbo.registry.protocol=zookeeper # 注册协议
dubbo.registry.address=centos-01:2181 # zk的地址
# 协议 (有 dubbo、rest、http、hessian、webservice)
dubbo.protocol.name=rest 
dubbo.protocol.port=20880 # rest服务端口 
#dubbo.protocol.server=tomcat # 中间件选择
dubbo.protocol.serialization=kryo # 系列化配置
#序列化优化的实现类
dubbo.protocol.optimizer=com.zkdubbo.server.util.SerializationOptimizerImpl  
dubbo.monitor.protocol=registry # 监控中心

我前面想使用Tomcat服务器的，但是遇到一个问题没解决就换成了jetty。我把问题贴一下求大神指教。。。。。

没解决

启动成功

成功日志

管理页面

postman测试rest设置

postman

如果不想使用rest协议的话就不要引入rest的依赖，配置文件
dubbo.protocol.name=dubbo
重启就可以了