SpringBoot整合Dubbo

  <groupId>com.boot.dubbo.demo</groupId>  <artifactId>dubbo-api</artifactId>  <version>1.0-SNAPSHOT</version>

package com.boot.dubbo.demo.domain;import java.io.Serializable;/** * 用户信息类 */public class UserInfo implements Serializable {    private String account;    private String password;    public String getAccount() {        return account;    }    public void setAccount(String account) {        this.account = account;    }    public String getPassword() {        return password;    }    public void setPassword(String password) {        this.password = password;    }}

package com.boot.dubbo.demo.api;import com.boot.dubbo.demo.domain.UserInfo;public interface UserService {    // 定义用户登录的api    UserInfo login(UserInfo user);}

 <!--依赖API-->        <dependency>            <groupId>com.boot.dubbo.demo</groupId>            <artifactId>boot-dubbo-api</artifactId>            <version>1.0-SNAPSHOT</version>        </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.apache.zookeeper</groupId>    <artifactId>zookeeper</artifactId>    <version>3.4.10</version>    <exclusions>        <exclusion>            <groupId>org.slf4j</groupId>            <artifactId>slf4j-log4j12</artifactId>        </exclusion>        <exclusion>            <groupId>log4j</groupId>            <artifactId>log4j</artifactId>        </exclusion>    </exclusions></dependency>

spring:  dubbo:    application:      name: dubbo-provider    protocol:      name: dubbo      port: 20880    registry:      address: zookeeper://192.168.3.101:2181

package com.boot.dubbo.demo.dubboprovider.service;import com.alibaba.dubbo.config.annotation.Service;import com.boot.dubbo.demo.api.UserService;import com.boot.dubbo.demo.domain.UserInfo;import org.springframework.stereotype.Component;@Component@Service(interfaceClass = UserService.class) //注意是dubbo的注解，向外暴露接口public class UserServiceImpl implements UserService {    public UserInfo login(UserInfo user) {        UserInfo reUser = new UserInfo();        reUser.setAccount("登录的账号为:"+user.getAccount());        reUser.setPassword("登录的密码为:"+user.getPassword());        return reUser;    }}

package com.boot.dubbo.demo.dubboprovider;import com.alibaba.dubbo.spring.boot.annotation.EnableDubbo;import org.springframework.boot.SpringApplication;import org.springframework.boot.autoconfigure.SpringBootApplication;@SpringBootApplication@EnableDubbo // 启用dubbopublic class DubboProviderApplication {    public static void main(String[] args) {        SpringApplication.run(DubboProviderApplication.class, args);    }}

spring:  dubbo:    application:      name: dubbo-provider    protocol:      name: dubbo      port: 20880    registry:      address: zookeeper://192.168.3.101:2181server:  port: 8081

package com.boot.dubbo.demo.dubboconsumer.controller;import com.alibaba.dubbo.config.annotation.Reference;import com.boot.dubbo.demo.api.UserService;import com.boot.dubbo.demo.domain.UserInfo;import org.springframework.web.bind.annotation.GetMapping;import org.springframework.web.bind.annotation.RestController;@RestControllerpublic class UserController {    @Reference // 引用dubbo服务器提供服务器接口    private UserService userService;    @GetMapping("/login")    public UserInfo login(UserInfo userInfo) {        return userService.login(userInfo);    }}

package com.boot.dubbo.demo.dubboconsumer;import com.alibaba.dubbo.spring.boot.annotation.EnableDubbo;import org.springframework.boot.SpringApplication;import org.springframework.boot.autoconfigure.SpringBootApplication;@SpringBootApplication@EnableDubbopublic class DubboConsumerApplication {    public static void main(String[] args) {        SpringApplication.run(DubboConsumerApplication.class, args);    }}