分散式系統理念

RPC

RPC(Remote Procedure Call)遠端過程呼叫；是一種程序間通訊方式，也是一種思想，而不是規範。允許程式呼叫另一個地址空間（通常是共享網路的另一臺機器上）的過程或函式。

推薦閱讀文章：https://www.jianshu.com/p/2accc2840a1b

RPC的兩個核心：通訊、序列化

序列化：將資料進行轉換

dubbo

dubbo就是高可用，高效能的RPC框架，採用全是 Spring 配置方式，

提供了三大核心能力：面向介面的遠端方法呼叫、智慧容錯和負載均衡，以及服務自動註冊和發現。

參考官網：http://dubbo.apache.org/en-us/

服務註冊實戰

前提：zookeeper服務已開啟

1.提供者提供服務

​ 1）匯入依賴

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

<!--引入zookeeper的客戶端工具-->
<!--引入zookeeper的客戶端工具-->
<dependency>
   <groupId>com.github.sgroschupf</groupId>
   <artifactId>zkclient</artifactId>
   <version>0.1</version>
</dependency>
 

​ 2）配置註冊中心的地址，以及服務發現名，和要掃描的包

dubbo.application.name=privide-ticket
dubbo.registry.address=zookeeper://192.168.1.10:2181
dubbo.scan.base-packages=com.mjh.privideticket.service

​ 3）在想要被註冊的服務上面增加一個註解@Service（Dubbo的）

service層和Impl層

package com.mjh.privideticket.service;


public interface TicketService {
    public String  getTicket();

}
 

package com.mjh.privideticket.service;


import org.springframework.stereotype.Component;
import org.springframework.stereotype.Service;

@Component
@Service//將服務釋出出去
public class TicketServiceImpl implements TicketService {

    @Override
    public String getTicket() {
        return "《厲害了，我的國》";
    }
}

package com.mjh.privideticket;

import com.alibaba.dubbo.config.spring.context.annotation.EnableDubbo;
import com.alibaba.dubbo.config.spring.context.annotation.EnableDubboConfig;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

/**
 * 將服務提供者註冊到註冊中心
 *    1.引入dubbo和zkclient相關服務依賴
 *    2.配置dubbo的掃描包和註冊中心地址
 *    3.使用@Service釋出服務
 */
@EnableDubboConfig
@SpringBootApplication

public class PrivideTicketApplication {

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

}

2.消費者如何消費

​ 1）匯入依賴

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

<!--引入zookeeper的客戶端工具-->
<dependency>
<groupId>com.github.sgroschupf</groupId>
<artifactId>zkclient</artifactId>
<version>0.1</version>
</dependency>

​ 2）配置註冊中心的地址，配置自己的服務名

dubbo.application.name=privide-user
dubbo.registry.address=zookeeper://192.168.1.10:2181

​ 3）從遠端注入服務 @Reference

（要使用遠端的服務，就要跟遠端的服務介面一致）

package com.mjh.privideticket.service;


public interface TicketService {
    public String  getTicket();

}

自己的service層

package com.mjh.privideuser.service;

import com.alibaba.dubbo.config.annotation.Reference;
import com.mjh.privideticket.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);
    }
}

package com.mjh.privideuser;

import com.alibaba.dubbo.config.spring.context.annotation.EnableDubbo;
import com.alibaba.dubbo.config.spring.context.annotation.EnableDubboConfig;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

/**
 * 引入依賴
 * 配置dubbo的註冊中心地址
 * 引用服務
 */
@EnableDubboConfig
@SpringBootApplication
public class PrivideUserApplication {

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

}