<!-- 簡化開發(fā)的工具, 這里只用到在實體類上@Data注解, 
減少get/set方法生成, 使用時在ide添加插件, 不會自行百度  -->
       <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <version>1.18.2</version>
        </dependency>

package com.example.pojo;

import lombok.Data;

import java.io.Serializable;

/**
 * 用戶
 */
@Data
//這里注意下, 一定要實現(xiàn)Serializable接口~, 不然消費者調(diào)用返回json時候會序列化失敗
public class User implements Serializable{

    private Integer id;

    private String name;

    private Integer age;


}

package com.example.service;

import com.example.pojo.User;

/**
 * 該地方只定義接口, 一般為公用接口
 * 可以定義許多接口; 這里為了演示, 只定義一個
 */
public interface UserService {

    User getUserById(int id);
}

       <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-jdbc</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>

        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <version>5.1.38</version>
        </dependency>

        <!--接口, 3.1我們定義的接口, 這里進行引用-->
        <dependency>
            <groupId>com.example</groupId>
            <artifactId>dubbo-interface</artifactId>
            <version>0.0.1-SNAPSHOT</version>
        </dependency>
        <!-- dubbo starter 這里已經(jīng)集成了zookeeper的客戶端jar -->
        <dependency>
            <groupId>com.alibaba.boot</groupId>
            <artifactId>dubbo-spring-boot-starter</artifactId>
            <version>0.2.0</version>
        </dependency>
        <!--myabtis plus-->
        <dependency>
            <groupId>com.baomidou</groupId>
            <artifactId>mybatis-plus-boot-starter</artifactId>
            <version>3.0.6</version>
        </dependency>
       <!--  使用阿里的數(shù)據(jù)庫數(shù)據(jù)源  -->
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>druid</artifactId>
            <version>1.1.12</version>
        </dependency>

package com.example.dubboproducer.impl;

import com.alibaba.dubbo.config.annotation.Service;
import com.example.dubboproducer.dao.UserDao;
import com.example.pojo.User;
import com.example.service.UserService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
@Service //這里是dubbo的注解, 將接口暴露在外, 可以供調(diào)用, 這里就是放在了注冊中心
//@org.springframework.stereotype.Service   spring自己的注解, 為了區(qū)分, 使用了@Component
@Component //讓spring掃描該類, 用spring的 @Service也行
public class UserServiceImpl implements UserService {

    @Autowired
    private UserDao userDao;

    @Override
    public User getUserById(int id) {
        return userDao.selectUserById(id);
    }
}

spring:
  datasource:
    url: jdbc:mysql://localhost:3306/dubbo?useUnicode=true&characterEncoding=utf-8
    username: root
    password: root
mybatis-plus:
  type-aliases-package: com.example.pojo
  mapper-locations: classpath:mapper/*.xml
  global-config:
      db-config:
        id-type: auto

#*****************分割線, 上面我就不解釋了, 下面是dubbo的配置************************
dubbo:
  application:
    name: dubbo-producer  #dubbo的注冊的服務(wù)名, 唯一性
  registry:
    address: zookeeper://127.0.0.1:2181  #注冊zookeeper的地址

package com.example.dubboproducer;

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

@SpringBootApplication
@EnableDubbo  //啟動dubbo的配置
public class DubboProducerApplication {

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

}

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>

        <!-- dubbo -->
        <dependency>
            <groupId>com.alibaba.boot</groupId>
            <artifactId>dubbo-spring-boot-starter</artifactId>
            <version>0.2.0</version>
        </dependency>
      <!-- 使用3.1的創(chuàng)建的接口 -->
        <dependency>
            <groupId>com.example</groupId>
            <artifactId>dubbo-interface</artifactId>
            <version>0.0.1-SNAPSHOT</version>
        </dependency>

package com.example.dubboconsumer.controller;

import com.alibaba.dubbo.config.annotation.Reference;
import com.example.service.UserService;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
@RequestMapping("/user")
public class UserController {

    @Reference  //將生產(chǎn)者注冊到Dubbo映射到該對象上, 這里完成了服務(wù)之間的調(diào)用
    private UserService userService;

    @RequestMapping("/getUserById")
    public Object getUserById (int id){
       return userService.getUserById(id);
    }
}

dubbo:
  application:
    name: dubbo-consumer
  registry:
    address: zookeeper://127.0.0.1:2181
server:
  port: 8081  #應(yīng)為我這里是將服務(wù)起在一臺電腦, 和生產(chǎn)者的tomcat端口區(qū)分以免沖突