游戏界面设计网站,峨眉网站建设,被电商代运营骗了怎么办,wordpress 代码规范1.什么是dubbo#xff1f; Apache Dubbo 是一款 RPC 服务开发框架#xff0c;用于解决微服务架构下的服务治理与通信问题#xff0c;官方提供了 Java、Golang 等多语言 SDK 实现。使用 Dubbo 开发的微服务原生具备相互之间的远程地址发现与通信能力#xff0c; 利用 Dubbo …1.什么是dubbo Apache Dubbo 是一款 RPC 服务开发框架用于解决微服务架构下的服务治理与通信问题官方提供了 Java、Golang 等多语言 SDK 实现。使用 Dubbo 开发的微服务原生具备相互之间的远程地址发现与通信能力 利用 Dubbo 提供的丰富服务治理特性可以实现诸如服务发现、负载均衡、流量调度等服务治理诉求。Dubbo 被设计为高度可扩展用户可以方便的实现流量拦截、选址的各种定制逻辑。 以上是官方的解释我个人的理解dubbo作为一个RPC服务开发框架除了满足我微服务之间远程调用的目的之外还能有以下几个重要的点。 1.和nacos等注册中心完成dubbo接口服务的服务发现消费方调用接口无需关注服务端的ip、端口 2.和sentinel集成可以完成限流和熔断的目的 3.dubbo实现了多个负载均衡算法只需yml文件配置即可。 4.dubbo和seata可以很方便的集成轻松达到业务数据一致性的目的。
2.dubbo的常用注解
EnableDubbo创建Springboot启动类需添加EnableDubbo注解开启Dubbo自动配置功能
DubboServiceDubbo会将对应的服务注册到spring 在spring启动后调用对应的服务导出方法将服务注册到注册中心 这样Consumer端才能发现我们发布的服务并调用与spring的Service注解作用类似
DubboReference通过DubboReference注解对需要调用的服务进行引入。即可像调用本地方法一样调用远程服务了。和spring的Autowired功能类似
*注DubboService和DubboReference的version参数和group参数的值必须一致。这两个参数可以确定一个实现类接口一般可以有多个实现类的多个实现类可以通过version和group参数进行区分。
3.代码示例 示例需要三个工程一个接口定义、一个服务端一个消费端。
maven依赖的版本号取决于项目使用的springboot版本及springcloud版本我使用的版本如下
!-- SpringBoot的依赖配置--dependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-dependencies/artifactIdversion2.6.11/versiontypepom/typescopeimport/scope/dependencydependencygroupIdorg.springframework.cloud/groupIdartifactIdspring-cloud-dependencies/artifactIdversion2021.0.1/versiontypepom/typescopeimport/scope/dependencydependencygroupIdcom.alibaba.cloud/groupIdartifactIdspring-cloud-alibaba-dependencies/artifactIdversion2021.0.4.0/versiontypepom/typescopeimport/scope/dependencydependencygroupIdorg.apache.dubbo/groupIdartifactIddubbo-bom/artifactIdversion3.0.9/versiontypepom/typescopeimport/scope/dependency3.1接口示例代码
工程名称dubbo-demo-interface
实体类必须实现序列化接口因为在远程调用时实体类数据是序列化后传输的
package com.jc.shop.dubbo.demo.domain;/*** 用户表*/
public class User implements java.io.Serializable{/*** 主键ID*/private long id;/*** 用户名称*/private String name;/*** 所属部门*/private long deptId;/*** 岗位*/private String post;private Dept dept;public Dept getDept() {return dept;}public void setDept(Dept dept) {this.dept dept;}public long getId() {return id;}public void setId(long id) {this.id id;}public String getName() {return name;}public void setName(String name) {this.name name;}public long getDeptId() {return deptId;}public void setDeptId(long deptId) {this.deptId deptId;}public String getPost() {return post;}public void setPost(String post) {this.post post;}
}接口定义
package com.jc.shop.dubbo.demo.service;import com.jc.shop.dubbo.demo.domain.User;/*** 业务接口*/
public interface IUserService {public int insert(User user);
}3.2服务端示例
服务端工程名dubbo-demo-provider jar包依赖maven !-- dubbo与spring集成可实现dubbo的自动初始化 --dependencygroupIdorg.apache.dubbo/groupIdartifactIddubbo-spring-boot-starter/artifactId/dependency!-- 实现将dubbo的服务注册到nacos --dependencygroupIdcom.alibaba.nacos/groupIdartifactIdnacos-client/artifactId/dependency!-- nacos的相关依赖 --dependencygroupIdcom.alibaba.cloud/groupIdartifactIdspring-cloud-starter-alibaba-nacos-config/artifactId/dependency!-- 加载bootstrap.yml文件 --dependencygroupIdorg.springframework.cloud/groupIdartifactIdspring-cloud-starter-bootstrap/artifactId/dependency!-- 引入接口层jar包 --dependencygroupIdcom.jc/groupIdartifactIddubbo-demo-interface/artifactIdversion1.0-SNAPSHOT/version/dependency
yml配置
dubbo:application:name: dubbo-providerprotocol: #dubbo协议信息name: dubbohost: 127.0.0.1port: 20881registry:address: nacos://localhost:8848 #使用nacos作为注册中心
服务层的代码实现
package com.jc.shop.dubbo.demo.service.impl;import com.jc.shop.dubbo.demo.domain.User;
import com.jc.shop.dubbo.demo.mapper.UserMapper;
import com.jc.shop.dubbo.demo.service.IUserService;
import io.seata.core.context.RootContext;
import org.apache.dubbo.config.annotation.DubboService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;/*** 业务层接口Service注解不用加因为我在当前工程的controller中需要调用所以加了Service注解*/
Service
DubboService(version 1.0.0,loadbalance leastactive)//负载策略为“最少活跃优先 加权随机”
public class UserServiceImpl implements IUserService {Autowiredprivate UserMapper mapper;Overridepublic int insert(User user) {//以下打印信息是为了集成seata框架的可忽略本次不涉及seata框架内容System.out.println(用户新增的事务ID为 RootContext.getXID());return mapper.insert(user);}
}在当前工程的启动类中添加EnableDubbo注解开启dubbo配置的自动配置功能
package com.jc;import org.apache.dubbo.config.spring.context.annotation.EnableDubbo;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;SpringBootApplication
EnableDubbo
public class DubboProviderApplication {public static void main(String[] args) {//以下4个变量的设置是为了避免同一台机器启动多个dubbo服务缓存默认使用的同一个地址会报错。System.setProperty(dubbo.meta.cache.filePath,/media/zhangzz/localDisk/home/zhangzz/dubbo/provider/);System.setProperty(dubbo.meta.cache.fileName,provider);System.setProperty(dubbo.mapping.cache.filePath,/media/zhangzz/localDisk/home/zhangzz/dubbo/provider/);System.setProperty(dubbo.mapping.cache.fileName,provider1);SpringApplication.run(DubboProviderApplication.class,args);}
}3.3消费端代码示例
消费端工程名dubbo-demo-consumer
maven依赖配置 dependencygroupIdorg.apache.dubbo/groupIdartifactIddubbo-spring-boot-starter/artifactIdversion3.2.7/version/dependencydependencygroupIdcom.alibaba.nacos/groupIdartifactIdnacos-client/artifactId/dependencydependencygroupIdcom.alibaba.cloud/groupIdartifactIdspring-cloud-starter-alibaba-nacos-config/artifactId/dependencydependencygroupIdorg.springframework.cloud/groupIdartifactIdspring-cloud-starter-bootstrap/artifactId/dependency
yml配置
dubbo:application:name: dubbo-consumerprotocol: #dubbo协议信息name: dubboport: -1 # -1表示端口随机registry:address: nacos://localhost:8848 #nacos地址
业务层代码调用
package com.jc.shop.dubbo.demo.service.impl;import com.jc.shop.dubbo.demo.domain.User;
import com.jc.shop.dubbo.demo.service.IConsumerService;
import com.jc.shop.dubbo.demo.service.IUserService;
import org.apache.dubbo.config.annotation.DubboReference;
import org.springframework.stereotype.Service;Service
public class ConsumerServiceImpl implements IConsumerService {DubboReference(version 1.0.0) //版本号需和服务端一致若有group也需保持一致private IUserService userService;Overridepublic int insertUser(User user) {int j userService.insert(user);System.out.println(用户新增影响行数j);return j;}
}controller层代码
package com.jc.shop.dubbo.demo.controller;import com.jc.core.domain.AjaxResult;
import com.jc.shop.dubbo.demo.domain.User;
import com.jc.shop.dubbo.demo.service.IConsumerService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;RestController
RequestMapping(/demo)
public class DemoController {Autowiredprivate IConsumerService service;PostMapping(/insert)public AjaxResult insert(RequestBody User user){int i service.insertUser(user);if(i0) {return AjaxResult.success(success);}else{return AjaxResult.error();}}
}应用启动类
package com.jc;import org.apache.dubbo.config.spring.context.annotation.EnableDubbo;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;SpringBootApplication
EnableDubbo
public class DubboConsumerApplication {public static void main(String[] args) {System.setProperty(dubbo.meta.cache.filePath,/media/zhangzz/localDisk/home/zhangzz/dubbo/consumer/);System.setProperty(dubbo.meta.cache.fileName,consumer);System.setProperty(dubbo.mapping.cache.filePath,/media/zhangzz/localDisk/home/zhangzz/dubbo/consumer/);System.setProperty(dubbo.mapping.cache.fileName,consumer1);SpringApplication.run(DubboConsumerApplication.class,args);}
}启动之后访问http://localhost:8082/demo/insert地址 4.与sentinel集成 集成的配置可参考《sentinel-单机流量控制》或《sentinel-集群流量控制》此处不再赘述。此处只说明下限流、熔断的资源名称如何定义
以我的代码为例规则定义如下
FlowRule flowRule new FlowRule(IUserService.class.getName()).setCount(10).setGrade(RuleConstant.FLOW_GRADE_QPS);
FlowRuleManager.loadRules(Collections.singletonList(flowRule));
由以上代码可以看出资源名称是类的全路径“com.jc.shop.dubbo.demo.service.IUserService”一般我们的流控规则都是在nacos中配置由代码动态加载。nacos中的配置如下
[{resource:com.jc.shop.dubbo.demo.service.IUserService, limitApp:default, grade:1, count:1, strategy:0, controlBehavior:0, clusterMode:false}
]
官方文档传送门dubbo与Sentinel集成的限流示例
5.负载均衡
目前 Dubbo 内置了如下负载均衡算法用户可直接配置使用
算法特性备注配置值Weighted Random LoadBalance加权随机默认算法默认权重相同random (默认)RoundRobin LoadBalance加权轮询借鉴于 Nginx 的平滑加权轮询算法默认权重相同roundrobinLeastActive LoadBalance最少活跃优先 加权随机背后是能者多劳的思想leastactiveShortest-Response LoadBalance最短响应优先 加权随机更加关注响应速度shortestresponseConsistentHash LoadBalance一致性哈希确定的入参确定的提供者适用于有状态请求consistenthashP2C LoadBalancePower of Two Choice随机选择两个节点后继续选择“连接数”较小的那个节点。p2cAdaptive LoadBalance自适应负载均衡在 P2C 算法基础上选择二者中 load 最小的那个节点adaptive
5.1 使用方式
DubboService(loadbalance leastactive)
DubboReference(loadbalance leastactive)
服务端方法级别的负载配置
DubboService(method{Method(nameinsert,loadbalance leastactive)})
消费端方法级别的负载配置
DubboReference(method{Method(nameinsert,loadbalance leastactive)})
