Spring boot分布式-------Spring boot高级------31/32/33

        远程RPC

        注册中心。

   zookeeper是注册中心

  dubble是连接框架

   

  dubble容器。invoke基于负载均衡机制调用服务。

  dubble的监控机制。

  docker hub 搜索

31---------------------------------------------------------------------------------------------------------------

    

docker run --name zk01 -p 2181:2181 --restart always -d 2a7f6fc5c8a1

  2181交互      2888集群        3181选举

32----------------------------------------------------------------------------------------------------------------

   创建两个工程：服务提供者和服务消费者。

   服务的提供者：

        

   服务的消费者：

   步骤：

         1.首先将服务的提供者注册到注册中心。

                  在提供者的pom文件上。搜索dubbo的官网。

                  进去dubbo的官网，点击view on Github

           找到依赖：

	<dependency>
			<groupId>com.alibaba.boot</groupId>
			<artifactId>dubbo-spring-boot-starter</artifactId>
			<version>0.1.0</version>
		</dependency>

 

      由于要操作zookeeper则可知引入zookeeper的客户端工具，直接去mavenRepositpry搜索：

      2.配置服务端的相关属性

                   

dubbo.application.name=provider-ticket

dubbo.registry.address=zookeeper://192.168.244.130:2181

dubbo.scan.base-packages=com.atguigu.ticket.service

 

package com.atguigu.ticket.service;

import com.alibaba.dubbo.config.annotation.Service;
import org.springframework.stereotype.Component;


@Component
@Service //将服务发布出去
public class TicketServiceImpl implements TicketService {
    @Override
    public String getTicket() {
        return "《厉害了，我的国》";
    }
}

@Service将服务发布出去，注意是dubbo的service。

启动服务端。

             

 

消费者：

      1.引入dubbo和zookeeper的相关依赖

                    将依赖赋值一份。dubbo和zookpper的。

       2.配置注册中心的地址

       3.引用服务。

                    这个是重点：service要放一份一模一样的接口，全类名是相同的。

    

  

       注意消费者的service是spring的service。

   注意这个远程调用：

   

package com.atguigu.user.service;


import com.alibaba.dubbo.config.annotation.Reference;

import com.atguigu.ticket.service.TicketService;
import org.springframework.stereotype.Service;

@Service
public class UserService{

    @Reference
    TicketService ticketService;

    public void hello(){
        String ticket = ticketService.getTicket();
        System.out.println("买到票了："+ticket);
    }


}

测试类进行测试：

           注入service调用hello方法。

33----------------------------------------------------------------------------------------------------------------