springcloud

springboot集成dubbo

 

## 1.创建公共工程 dubbo-common-api

 

定义接口

​

 

```java

package com.anyec.demo.service;

import java.util.List;

 

import com.anyec.demo.model.User;

 

public interface UserService {

 

User getUserById(String id);

List<User> listUser(User u);

}

```

 

定义数据对象

 

```package com.anyec.demo.model;

import java.io.Serializable;

import java.util.Date;

 

import com.alibaba.fastjson.JSON;

 

public class User implements Serializable {

private String id;

private String name;

private Date createDate;

public String getId() {

return id;

}

public void setId(String id) {

this.id = id;

}

public String getName() {

return name;

}

public void setName(String name) {

this.name = name;

}

public Date getCreateDate() {

return createDate;

}

public void setCreateDate(Date createDate) {

this.createDate = createDate;

}

@Override

public String toString() {

return JSON.toJSONString(this);

}

 

}

```

 

```JAVA

 

```

 

 

 

## 2 创建 provider工程

 

2.1工程依赖公共工程对应的接口和数据对象

 

2.2使用spring initlazer创建功能加入pom依赖

 

```

<?xml version="1.0" encoding="UTF-8"?>

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">

<modelVersion>4.0.0</modelVersion>

 

<groupId>com.anyec</groupId>

<artifactId>dobbo-demo-provider</artifactId>

<version>1.0.0</version>

<packaging>jar</packaging>

 

<name>dobbo-demo-provider</name>

<description>Demo project for Spring Boot</description>

 

<parent>

<groupId>org.springframework.boot</groupId>

<artifactId>spring-boot-starter-parent</artifactId>

<version>2.0.5.RELEASE</version>

<relativePath /> <!-- lookup parent from repository -->

</parent>

 

<properties>

<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>

<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>

<java.version>1.8</java.version>

</properties>

 

<dependencies>

<dependency>

<groupId>org.springframework.boot</groupId>

<artifactId>spring-boot-starter-web</artifactId>

</dependency>

<dependency>

<groupId>com.alibaba.spring.boot</groupId>

<artifactId>dubbo-spring-boot-starter</artifactId>

<version>2.0.0</version>

</dependency>

<dependency>

<groupId>com.101tec</groupId>

<artifactId>zkclient</artifactId>

<version>0.10</version>

</dependency>

<dependency>

<groupId>org.springframework.boot</groupId>

<artifactId>spring-boot-starter-test</artifactId>

<scope>test</scope>

</dependency>

</dependencies>

 

<build>

<plugins>

<plugin>

<groupId>org.springframework.boot</groupId>

<artifactId>spring-boot-maven-plugin</artifactId>

</plugin>

</plugins>

</build>

 

 

</project>

 

```

 

 

 

2.3设置配置文件

 

```java

spring.application.name=demo-dubbo-provider#工程名称

spring.dubbo.server=true#开启dubbo服务

spring.dubbo.registry=zookeeper://localhost:2181 #配置注册方式和地址

```

 

2.4启动类加上注解

 

```java

package com.anyec.demo.provider;

 

import org.springframework.boot.SpringApplication;

import org.springframework.boot.autoconfigure.SpringBootApplication;

 

import com.alibaba.dubbo.spring.boot.annotation.EnableDubboConfiguration;

 

@SpringBootApplication

@EnableDubboConfiguration

public class DobboDemoProviderApplication {

 

public static void main(String[] args) {

SpringApplication.run(DobboDemoProviderApplication.class, args);

}

}

 

```

 

2.5实现创建服务实例实现服务接口

 

```

package com.anyec.demo.provider.service;

 

import java.util.ArrayList;

import java.util.Date;

import java.util.List;

import java.util.UUID;

 

import org.springframework.stereotype.Component;

 

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

import com.anyec.demo.model.User;

@Service   //使用的是dubbo的service

@Component  //使用的是spring注解,避免service重复

public class UserServiceImpl implements com.anyec.demo.service.UserService{

 

@Override

public User getUserById(String id) {

User u=new User();

u.setId(id);

u.setName("test"+id);

u.setCreateDate(new Date());

return u;

}

 

@Override

public List<User> listUser(User u2) {

List<User> list=new ArrayList<User>();

for(int i=0;i<10;i++){

User u=new User();

u.setId(UUID.randomUUID().toString());

u.setName("test"+i);

u.setCreateDate(new Date());

list.add(u);

}

return list;

}

 

}

 

```

 

## 3 消费端实现

 

3.1 创建工程加入pom依赖

 

```

<?xml version="1.0" encoding="UTF-8"?>

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">

<modelVersion>4.0.0</modelVersion>

 

<groupId>com.anyec</groupId>

<artifactId>dobbo-demo-consumer</artifactId>

<version>1.0.0</version>

<packaging>jar</packaging>

 

<name>dobbo-demo-consumer</name>

<description>Demo project for Spring Boot</description>

 

<parent>

<groupId>org.springframework.boot</groupId>

<artifactId>spring-boot-starter-parent</artifactId>

<version>2.0.5.RELEASE</version>

<relativePath /> <!-- lookup parent from repository -->

</parent>

 

<properties>

<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>

<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>

<java.version>1.8</java.version>

</properties>

 

<dependencies>

<dependency>

<groupId>org.springframework.boot</groupId>

<artifactId>spring-boot-starter-web</artifactId>

</dependency>

<dependency>

<groupId>com.alibaba.spring.boot</groupId>

<artifactId>dubbo-spring-boot-starter</artifactId>

<version>2.0.0</version>

</dependency>

<dependency>

<groupId>com.101tec</groupId>

<artifactId>zkclient</artifactId>

<version>0.10</version>

</dependency>

<dependency>

<groupId>org.springframework.boot</groupId>

<artifactId>spring-boot-starter-test</artifactId>

<scope>test</scope>

</dependency>

</dependencies>

 

<build>

<plugins>

<plugin>

<groupId>org.springframework.boot</groupId>

<artifactId>spring-boot-maven-plugin</artifactId>

</plugin>

</plugins>

</build>

 

 

</project>

 

```

 

2.2 添加配置项

 

```

spring.application.name=demo-dubbo-consumer

spring.dubbo.registry=zookeeper://localhost:2181

```

 

 

 

2.3添加消费实现

 

```java

package com.anyec.demo.consumer;

 

import java.util.Date;

import java.util.List;

 

import org.springframework.stereotype.Component;

 

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

import com.alibaba.fastjson.JSON;

import com.anyec.demo.model.User;

import com.anyec.demo.service.UserService;

 

@Component

public class UserClientService {

@Reference(interfaceClass = UserService.class)

UserService userService;

public void getUser(){

User u = userService.getUserById("");

System.out.println(u);

}

public void listUser(){

User u = new User();

u.setId("aaa");

u.setName("aasdfdsf");

u.setCreateDate(new Date());

List<User> list = userService.listUser(u);

System.out.println( JSON.toJSONString(list));

}

}

 

```

 

2.4添加注解

 

```

package com.anyec.demo.consumer;

 

import org.springframework.boot.SpringApplication;

import org.springframework.boot.autoconfigure.SpringBootApplication;

 

import com.alibaba.dubbo.spring.boot.annotation.EnableDubboConfiguration;

 

@SpringBootApplication

@EnableDubboConfiguration  //添加注解

public class DobboDemoConsumerApplication {

 

public static void main(String[] args) {

SpringApplication.run(DobboDemoConsumerApplication.class, args);

}

}

 

```