节点角色说明
节点 | 角色说明 |
---|---|
provider | 暴露服务的服务提供方 |
consumer | 调用远程服务的服务消费方 |
registry | 服务注册与发现的注册中心 |
monitor | 统计服务的调用次数和调用时间的监控中心 |
container | 服务运行的容器 |
调用关系说明
开发环境主要涉及以下方面:
具体代码可以查看 github 的 dubbo 模块:https://github.com/uniquedong/springboot-study
定义服务接口,打成 jar 包让消费者依赖,服务者实现接口。该工程只有接口定义以及 model 对象。@data 属于lombok 开源库提供的特性,方便开发。
@data public class user implements serializable { private long id; private string username; }
public interface userprovider { list<user> listuser(); }
引入spring-boot-starter,dubbo-api 接口就是我们上面提到的 接口定义 jar ,dubbo-spring-boot-starter ,dubbo-dependencies-zookeeper。
<dependencies> <dependency> <groupid>org.springframework.boot</groupid> <artifactid>spring-boot-starter</artifactid> <exclusions> <exclusion> <artifactid>spring-boot-starter-logging</artifactid> <groupid>org.springframework.boot</groupid> </exclusion> </exclusions> </dependency> <dependency> <groupid>zero.springboot.study</groupid> <artifactid>dubbo-api</artifactid> <version>1.0.0-snapshot</version> </dependency> <!--dubbo start--> <dependency> <groupid>org.apache.dubbo</groupid> <artifactid>dubbo-spring-boot-starter</artifactid> <version>2.7.1</version> </dependency> <dependency> <groupid>org.apache.dubbo</groupid> <artifactid>dubbo</artifactid> <version>2.7.1</version> </dependency> <!-- zookeeper dependencies --> <dependency> <groupid>org.apache.dubbo</groupid> <artifactid>dubbo-dependencies-zookeeper</artifactid> <version>2.7.1</version> <type>pom</type> <exclusions> <exclusion> <artifactid>log4j</artifactid> <groupid>log4j</groupid> </exclusion> <exclusion> <artifactid>slf4j-log4j12</artifactid> <groupid>org.slf4j</groupid> </exclusion> </exclusions> </dependency> <!--dubbo end--> <dependency> <groupid>com.alibaba</groupid> <artifactid>fastjson</artifactid> <version>1.2.57</version> </dependency> </dependencies>
spring: application: name: dubbo-provider #自定义配置 embedded: zookeeper: # zookeeper 服务连接端口 port: 2181 # dubbo 配置 dubbo: # 注册中心配置 registry: id: dubbo-provider address: zookeeper://127.0.0.1:${embedded.zookeeper.port} group: local application: name: dubbo-provider id: dubbo-provider logger: slf4j qosenable: true qosport: 22224 qosacceptforeignip: false # dubbo 协议配置 protocol: # -1 表示使用随机未被占用的端口 port: -1 name: dubbo scan: # dubbo 服务提供者实现类所在包 base-packages: com.zero.provider.impl
实现 api 定义的接口
注意 @service 是 dubbo 的,不要导入了 spring 的。
import com.google.common.collect.lists; import com.zero.api.model.user; import com.zero.api.provider.userprovider; import org.apache.dubbo.config.annotation.service; import java.util.list; @service(interfaceclass = userprovider.class) public class userproviderimpl implements userprovider { @override public list<user> listuser() { user user = new user(); user.setid(1l); user.setusername("青龙"); return lists.newarraylist(user); } }
我们要依赖 spring-boot-starter-web 提供http rest接口给前端调用。同时内部通过 dubbo 实现 rpc调用服务提供者。
<dependencies> <dependency> <groupid>org.springframework.boot</groupid> <artifactid>spring-boot-starter-web</artifactid> <exclusions> <exclusion> <groupid>org.springframework.boot</groupid> <artifactid>spring-boot-starter-logging</artifactid> </exclusion> </exclusions> </dependency> <dependency> <groupid>zero.springboot.study</groupid> <artifactid>dubbo-api</artifactid> <version>1.0.0-snapshot</version> </dependency> <!--dubbo start--> <dependency> <groupid>org.apache.dubbo</groupid> <artifactid>dubbo-spring-boot-starter</artifactid> <version>2.7.1</version> </dependency> <dependency> <groupid>org.apache.dubbo</groupid> <artifactid>dubbo</artifactid> <version>2.7.1</version> </dependency> <!-- zookeeper dependencies --> <dependency> <groupid>org.apache.dubbo</groupid> <artifactid>dubbo-dependencies-zookeeper</artifactid> <version>2.7.1</version> <type>pom</type> <exclusions> <exclusion> <artifactid>log4j</artifactid> <groupid>log4j</groupid> </exclusion> <exclusion> <artifactid>slf4j-log4j12</artifactid> <groupid>org.slf4j</groupid> </exclusion> </exclusions> </dependency> <!--dubbo end--> <dependency> <groupid>org.projectlombok</groupid> <artifactid>lombok</artifactid> <optional>true</optional> </dependency> </dependencies>
server: # web 日更年期端口 port: 9005 spring: application: name: dubbo-comsumer #自定义配置 embedded: zookeeper: port: 2181 # dubbo 配置 dubbo: registry: id: dubbo-comsumer address: zookeeper://127.0.0.1:${embedded.zookeeper.port} group: local application: name: dubbo-comsumer id: dubbo-comsumer logger: slf4j qosenable: false qosport: 22223 qosacceptforeignip: false protocol: port: -1 name: dubbo # 是否检查服务提供者有效 consumer: check: false
import com.zero.api.model.user; import com.zero.api.provider.userprovider; import org.apache.dubbo.config.annotation.reference; import org.springframework.stereotype.service; import java.util.list; @service public class userservice { @reference private userprovider userprovider; public list<user> listuser() { return userprovider.listuser(); } }
@restcontroller @requestmapping("/users") public class usercontroller { @autowired private userservice userservice; @getmapping public object listuser() { list<user> list = userservice.listuser(); return list; } }
各种具体协议、注册中心、多注册中心、超时等配置可以查看官方文档
欢迎大家讨论纠正,邮箱:zero_develop@163.com 。点赞与关注微信公众号是我们前进的动力。
如对本文有疑问, 点击进行留言回复!!
网友评论