建立基础项目

建立一个maven项目，然后建立一个api模块，作为这个项目的总的调用接口

1
2
learn-dubbo-demo/
├── simple-api

https://github.com/liunaijie/learn-demo/tree/master/learn-dubbo-demo

https://github.com/liunaijie/learn-demo/tree/master/learn-dubbo-demo/sample-api

然后在api项目中创建接口，提供给生产者和消费者调用。

我这里定义一个了sayhello()方法

使用zookeeper作为服务注册中心

1
2
3
4
5
learn-dubbo-demo/
├── simple-api
├── zookeeper-register
	└──zookeeper-consumer-sample
    └──zookeeper-provider-sample

这里使用zookeeper作为dubbo的服务注册中心，简单实现rpc的调用

新建两个子项目，一个作为生产者（spring-boot-starter），一个作为消费者 （spring-boot-starter-web）

在这两个module中都需要引入api的module

生产者：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
package cn.lnj.project.demo.dubbo.zookeeper.provider.service;

import cn.lnj.project.demo.dubbo.api.IUserService;
import org.springframework.beans.factory.annotation.Value;
import org.apache.dubbo.config.annotation.Service; //service的导包要导入dubbo的包，而不是spring的包

//这个版本从配置文件读取，生产者调用的时候只要版本一致就可以调用到这个实现类中
//也就是说我们可以有多个版本的生产者 消费者调用时写不同的版本就可以调用不同的后台内容
@Service(version = "${service.api.version}")
public class UserServiceImpl implements IUserService {
	
	//从配置文件中读取我们这个项目的名称，其实就是我随便定义的返回信息
	@Value("${dubbo.application.name}")
	private String serviceName;

	@Override
	public String sayHello(String name) {
		System.out.println("zookeeper provider works");
		return String.format("[%s] : Hello,i am work, %s", serviceName, name);
	}

}

然后写生产者的配置文件：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
spring:
  application:
    name: zookeeper-provider-sample

dubbo:
  application:
    name: zookeeper-provider-sample
  registry:
    address: zookeeper://****:2181 #zk的注册地址
    file: ${user.home}/dubbo-cache/${spring.application.name}/dubbo.cache
  scan:
    base-packages: cn.lnj.project.demo.dubbo.zookeeper.provider.service #实现类的包，dubbo会扫描这个包下，我们如果把实现类放在这个包外就注册不了

service:
  api:
    version: 0.0.1 #定义我们api的版本号

然后启动生产者会出现如下就表示我们生产者启动成功了。

zookeeper-provider

我又进入zk里面查看了这个生产者的信息：

zk-provider-info

从这里我们可以看到存储了生产者信息的ip地址为192.168.0.18。所以这也就要求了消费者与生产者在一个网段，否则不会调用成功。如果我将生产者与zk放到同一台机器上，那么这个ip地址就会变成127.0.0.1，这样就要求消费者也要在同一台机器上。当然我们也可以修改本机的hosts来修改注册到zk上的地址，最终保证消费者能ping同生产者的ip才能调用成功。这个我认为是rpc调用与http调用的区别之一。

2.2消费者

首先是配置文件

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
spring:
  application:
    name: zookeeper-consumer-sample

dubbo:
  application:
    name: zookeeper-consumer-sample
  registry:
    address: zookeeper://****:2181
    file: ${user.home}/dubbo-cache/${spring.application.name}/dubbo.cache

server:
  port: 8080
  servlet:
    context-path: /zookeeper-consumer #因为我用了web页面来进行调用，所以写了一个上下文

service:
  api:
    version: 0.0.1  #要与生产者里面的版本对应

然后又写了一个controller来提供页面调用

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
package cn.lnj.project.demo.dubbo.zookeeper.consumer.controller;

import cn.lnj.project.demo.dubbo.api.IUserService;
import org.apache.dubbo.config.annotation.Reference;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class UserController {
	
    // dubbo中使用 refernce 来实现注入并指明调用的版本
	@Reference(interfaceClass = IUserService.class,version = "${service.api.version}")
	private IUserService iUserService;

	@RequestMapping(value = "/hello")
	public Object sayHello(@RequestParam(value = "name") String name) {
		return iUserService.sayHello(name);
	}

}

然后进行web页面调用：我传入了一个zookeeper的参数。出现了如下的结果就表示我们这个调用成功了

zk-consumer-web