我要评论循环依赖详解
一、什么是循环依赖
1.1 定义
循环依赖（circular dependency）指的是两个或多个模块之间相互引用，形成闭环的情况。简单来说，就是a依赖b，b又依赖a，或者a→b→c→a这样的依赖链。
1.2 为什么会产生
循环依赖通常在以下情况下产生：
- 架构设计不当：模块划分不够清晰，职责边界模糊
- 功能耦合过紧：相关功能被错误地分散在不同模块中
- 缺乏统一接口：模块间直接依赖具体实现而非抽象接口
1.3 危害
循环依赖会带来以下几个严重问题：
- 编译错误：在某些语言中（如c++），循环依赖会导致编译失败
- 运行时错误：模块初始化顺序不确定，可能导致null pointer异常
- 维护困难：修改一个模块可能影响多个其他模块
- 测试复杂：单元测试难以独立进行
二、循环依赖的场景
2.1 后端开发中的循环依赖
以下代码展示了一个典型的spring boot项目中用户服务和订单服务的循环依赖场景：
// userservice.java - 用户服务实现
@service
public class userservice {
@autowired
private orderservice orderservice; // 直接注入orderservice
public void updateuser(long userid, userupdatedto userdata) {
// 更新用户信息
system.out.println("更新用户信息: " + userid);
// 当用户vip等级变化时，需要更新相关订单的优惠策略
if (userdata.getviplevel() != null) {
orderservice.updateordersforuser(userid, userdata.getviplevel());
}
}
public user getuserbyid(long userid) {
// 实际的用户查询逻辑
return new user(userid, "张三", "vip1");
}
}// orderservice.java - 订单服务实现
@service
public class orderservice {
@autowired
private userservice userservice; // 直接注入userservice
public void updateordersforuser(long userid, string viplevel) {
// 更新订单逻辑
system.out.println("更新用户订单，新的vip等级: " + viplevel);
// 订单总额变化可能影响用户等级
user user = userservice.getuserbyid(userid);
bigdecimal totalamount = calculatetotalorderamount(userid);
string newlevel = calculateviplevel(totalamount);
if (!newlevel.equals(user.getviplevel())) {
user.setviplevel(newlevel);
userservice.updateuser(userid, userupdatedto.builder().viplevel(newlevel).build());
}
}
private bigdecimal calculatetotalorderamount(long userid) {
// 计算用户总订单金额
return new bigdecimal("5000.00");
}
private string calculateviplevel(bigdecimal amount) {
return amount.compareto(new bigdecimal("10000")) > 0 ? "vip2" : "vip1";
}
}场景说明：这是一个真实的电商系统案例。在我之前负责的微服务电商项目中，用户vip等级会影响订单优惠，而订单总额又会影响用户vip等级。这种双向依赖在spring容器启动时就会报错，提示"bean currently in creation"。
2.2 spring mvc中的循环依赖
// usercontroller.java - 用户控制器
@restcontroller
@requestmapping("/api/users")
public class usercontroller {
@autowired
private userservice userservice;
@autowired
private ordercontroller ordercontroller; // 错误的做法：控制器间相互依赖
@putmapping("/{userid}")
public responseentity<string> updateuser(@pathvariable long userid, @requestbody userupdatedto dto) {
userservice.updateuser(userid, dto);
// 更新用户后，触发相关订单的重新计算
ordercontroller.recalculateuserorders(userid);
return responseentity.ok("用户更新成功");
}
}// ordercontroller.java - 订单控制器
@restcontroller
@requestmapping("/api/orders")
public class ordercontroller {
@autowired
private orderservice orderservice;
@autowired
private usercontroller usercontroller; // 错误的做法：控制器间相互依赖
@postmapping("/recalculate/{userid}")
public responseentity<string> recalculateuserorders(@pathvariable long userid) {
orderservice.recalculateordersforuser(userid);
// 计算完成后，可能需要更新用户统计信息
usercontroller.updateuserstatistics(userid);
return responseentity.ok("订单重新计算完成");
}
}场景说明：这个案例来自我之前的一个erp项目。当时为了方便，直接在控制器层相互调用，结果造成了循环依赖。正确的做法是将共享逻辑提取到服务层处理。
2.3 spring data jpa中的循环依赖
// user.java - 用户实体
@entity
@table(name = "users")
public class user {
@id
@generatedvalue(strategy = generationtype.identity)
private long id;
private string username;
private string email;
@onetomany(mappedby = "user", cascade = cascadetype.all, fetch = fetchtype.lazy)
private list<order> orders;
@manytoone
@joincolumn(name = "managed_department_id")
private department manageddepartment;
// getters and setters
}// order.java - 订单实体
@entity
@table(name = "orders")
public class order {
@id
@generatedvalue(strategy = generationtype.identity)
private long id;
private bigdecimal amount;
@manytoone
@joincolumn(name = "user_id")
private user user;
@onetomany(mappedby = "relatedorder", cascade = cascadetype.all, fetch = fetchtype.lazy)
private list<orderitem> items;
// getters and setters
}// department.java - 部门实体
@entity
@table(name = "departments")
public class department {
@id
@generatedvalue(strategy = generationtype.identity)
private long id;
private string name;
@onetomany(mappedby = "manageddepartment")
private list<user> members;
@onetoone
@joincolumn(name = "manager_user_id")
private user manager;
// getters and setters
}场景说明：在企业级应用中，这种双向关联非常常见。用户属于部门，部门经理又是一个用户，形成一个循环。如果处理不当，序列化时就会出现栈溢出。我在一个hr管理系统中就遇到过这个问题。
三、循环依赖的解决方案
3.1 spring applicationevent事件驱动解耦
以下代码展示使用spring applicationevent解决循环依赖的方法：
// 领域事件定义
public class userupdatedevent extends applicationevent {
private final long userid;
private final userupdatedto userdata;
private final user olduserdata;
public userupdatedevent(object source, long userid, userupdatedto userdata, user olduserdata) {
super(source);
this.userid = userid;
this.userdata = userdata;
this.olduserdata = olduserdata;
}
// getters
}// 订单更新事件
public class orderupdatedevent extends applicationevent {
private final long userid;
private final bigdecimal totalamount;
private final list<order> updatedorders;
public orderupdatedevent(object source, long userid, bigdecimal totalamount, list<order> updatedorders) {
super(source);
this.userid = userid;
this.totalamount = totalamount;
this.updatedorders = updatedorders;
}
// getters
}// userserviceimpl.java - 使用事件驱动解耦
@service
public class userserviceimpl implements userservice {
@autowired
private applicationeventpublisher eventpublisher;
@autowired
private userrepository userrepository;
@override
@transactional
public void updateuser(long userid, userupdatedto userdata) {
// 获取旧数据
user olduser = userrepository.findbyid(userid)
.orelsethrow(() -> new usernotfoundexception("用户不存在"));
// 更新用户信息
user updateduser = updateuserentity(olduser, userdata);
userrepository.save(updateduser);
system.out.println("更新用户信息: " + userid);
// 发布用户更新事件，而不是直接调用orderservice
userupdatedevent event = new userupdatedevent(this, userid, userdata, olduser);
eventpublisher.publishevent(event);
}
@override
public user getuserbyid(long userid) {
return userrepository.findbyid(userid)
.orelsethrow(() -> new usernotfoundexception("用户不存在"));
}
private user updateuserentity(user user, userupdatedto dto) {
if (dto.getusername() != null) {
user.setusername(dto.getusername());
}
if (dto.getviplevel() != null) {
user.setviplevel(dto.getviplevel());
}
return user;
}
}// orderserviceimpl.java - 使用事件驱动解耦
@service
public class orderserviceimpl implements orderservice {
@autowired
private applicationeventpublisher eventpublisher;
@autowired
private orderrepository orderrepository;
@override
@transactional
public void updateordersforuser(long userid, string viplevel) {
// 更新订单逻辑
list<order> orders = orderrepository.findbyuserid(userid);
// 根据新的vip等级更新订单优惠
for (order order : orders) {
order.setdiscountrate(calculatediscountrate(viplevel));
}
orderrepository.saveall(orders);
// 计算用户总订单金额
bigdecimal totalamount = orders.stream()
.map(order::getamount)
.reduce(bigdecimal.zero, bigdecimal::add);
system.out.println("更新用户订单，总金额: " + totalamount);
// 发布订单更新事件
orderupdatedevent event = new orderupdatedevent(this, userid, totalamount, orders);
eventpublisher.publishevent(event);
}
private bigdecimal calculatediscountrate(string viplevel) {
switch (viplevel) {
case "vip1": return new bigdecimal("0.95");
case "vip2": return new bigdecimal("0.90");
case "vip3": return new bigdecimal("0.85");
default: return bigdecimal.one;
}
}
}// 事件监听器 - 处理跨模块的业务逻辑
@component
public class ordereventlistener {
@autowired
private orderservice orderservice;
@eventlistener
@async("taskexecutor") // 异步处理，避免阻塞主流程
public void handleuserupdated(userupdatedevent event) {
system.out.println("监听到用户更新事件，用户id: " + event.getuserid());
// 根据用户更新调整相关订单
if (event.getuserdata().getviplevel() != null) {
orderservice.updateordersforuser(event.getuserid(), event.getuserdata().getviplevel());
}
}
}
@component
public class usereventlistener {
@autowired
private userservice userservice;
@eventlistener
@async("taskexecutor")
public void handleorderupdated(orderupdatedevent event) {
system.out.println("监听到订单更新事件，用户id: " + event.getuserid());
// 根据订单总金额调整用户等级
string newviplevel = calculateviplevel(event.gettotalamount());
user currentuser = userservice.getuserbyid(event.getuserid());
if (!newviplevel.equals(currentuser.getviplevel())) {
userupdatedto updatedto = userupdatedto.builder()
.viplevel(newviplevel)
.build();
userservice.updateuser(event.getuserid(), updatedto);
}
}
private string calculateviplevel(bigdecimal totalamount) {
if (totalamount.compareto(new bigdecimal("50000")) > 0) return "vip3";
if (totalamount.compareto(new bigdecimal("20000")) > 0) return "vip2";
if (totalamount.compareto(new bigdecimal("5000")) > 0) return "vip1";
return "普通用户";
}
}// 异步配置
@configuration
@enableasync
public class asyncconfig {
@bean("taskexecutor")
public taskexecutor taskexecutor() {
threadpooltaskexecutor executor = new threadpooltaskexecutor();
executor.setcorepoolsize(5);
executor.setmaxpoolsize(10);
executor.setqueuecapacity(100);
executor.setthreadnameprefix("async-");
executor.initialize();
return executor;
}
}实战说明：在我之前的社交电商项目中，用户系统和商品系统就通过spring事件驱动机制解耦。用户发布动态时，商品系统监听事件更新推荐算法；商品价格变动时，用户系统监听事件更新购物车。这种方式不仅解决了循环依赖，还提高了系统的响应速度和可扩展性。
3.2 spring @lazy延迟加载和接口抽象
以下代码展示使用spring的@lazy注解和接口抽象解决循环依赖：
// 定义服务接口
public interface userservice {
void updateuser(long userid, userupdatedto userdata);
user getuserbyid(long userid);
string getuserviplevel(long userid);
}
public interface orderservice {
void updateordersforuser(long userid, string viplevel);
bigdecimal gettotalorderamount(long userid);
list<order> getordersbyuserid(long userid);
}// userserviceimpl.java - 使用@lazy延迟加载
@service
public class userserviceimpl implements userservice {
@autowired
@lazy // 延迟注入，避免循环依赖
private orderservice orderservice;
@autowired
private userrepository userrepository;
@override
@transactional
public void updateuser(long userid, userupdatedto userdata) {
user user = userrepository.findbyid(userid)
.orelsethrow(() -> new usernotfoundexception("用户不存在"));
system.out.println("更新用户信息: " + userid);
// 更新用户实体
if (userdata.getusername() != null) {
user.setusername(userdata.getusername());
}
if (userdata.getviplevel() != null) {
user.setviplevel(userdata.getviplevel());
// vip等级变化时，延迟调用订单服务
// orderservice此时可能还未完全初始化，但@lazy确保了延迟加载
orderservice.updateordersforuser(userid, userdata.getviplevel());
}
userrepository.save(user);
}
@override
public user getuserbyid(long userid) {
return userrepository.findbyid(userid)
.orelsethrow(() -> new usernotfoundexception("用户不存在"));
}
@override
public string getuserviplevel(long userid) {
user user = getuserbyid(userid);
return user.getviplevel();
}
}// orderserviceimpl.java - 同样使用@lazy延迟加载
@service
public class orderserviceimpl implements orderservice {
@autowired
@lazy // 延迟注入
private userservice userservice;
@autowired
private orderrepository orderrepository;
@override
@transactional
public void updateordersforuser(long userid, string viplevel) {
list<order> orders = orderrepository.findbyuserid(userid);
system.out.println("更新用户订单，新的vip等级: " + viplevel);
// 更新订单的折扣率
for (order order : orders) {
bigdecimal discount = calculatediscountbyviplevel(viplevel);
order.setdiscountrate(discount);
order.setfinalamount(order.getamount().multiply(discount));
}
orderrepository.saveall(orders);
// 检查是否需要更新用户等级
bigdecimal totalamount = gettotalorderamount(userid);
string recommendedviplevel = calculateviplevelbyamount(totalamount);
// 延迟调用用户服务
if (!recommendedviplevel.equals(viplevel)) {
userupdatedto updatedto = userupdatedto.builder()
.viplevel(recommendedviplevel)
.build();
userservice.updateuser(userid, updatedto);
}
}
@override
public bigdecimal gettotalorderamount(long userid) {
list<order> orders = orderrepository.findbyuserid(userid);
return orders.stream()
.map(order::getamount)
.reduce(bigdecimal.zero, bigdecimal::add);
}
@override
public list<order> getordersbyuserid(long userid) {
return orderrepository.findbyuserid(userid);
}
private bigdecimal calculatediscountbyviplevel(string viplevel) {
switch (viplevel) {
case "vip1": return new bigdecimal("0.95");
case "vip2": return new bigdecimal("0.90");
case "vip3": return new bigdecimal("0.85");
default: return bigdecimal.one;
}
}
private string calculateviplevelbyamount(bigdecimal amount) {
if (amount.compareto(new bigdecimal("100000")) > 0) return "vip3";
if (amount.compareto(new bigdecimal("50000")) > 0) return "vip2";
if (amount.compareto(new bigdecimal("10000")) > 0) return "vip1";
return "普通用户";
}
}// 另一种方案：使用中间服务协调
@service
public class userordercoordinationservice {
@autowired
private userservice userservice;
@autowired
private orderservice orderservice;
/**
* 协调用户和订单的更新逻辑
* 避免两个服务直接相互调用
*/
@transactional
public void coordinateuserandorderupdate(long userid, userupdatedto userdata) {
// 1. 先更新用户信息
user user = userservice.getuserbyid(userid);
string oldviplevel = user.getviplevel();
if (userdata.getviplevel() != null) {
userservice.updateuser(userid, userdata);
}
// 2. 根据用户更新订单
if (userdata.getviplevel() != null && !userdata.getviplevel().equals(oldviplevel)) {
orderservice.updateordersforuser(userid, userdata.getviplevel());
}
// 3. 检查订单总额是否需要调整用户等级
bigdecimal totalamount = orderservice.gettotalorderamount(userid);
string recommendedlevel = calculateviplevel(totalamount);
string currentlevel = userservice.getuserviplevel(userid);
if (!recommendedlevel.equals(currentlevel)) {
userupdatedto newuserdata = userupdatedto.builder()
.viplevel(recommendedlevel)
.build();
userservice.updateuser(userid, newuserdata);
}
}
private string calculateviplevel(bigdecimal amount) {
if (amount.compareto(new bigdecimal("50000")) > 0) return "vip2";
if (amount.compareto(new bigdecimal("10000")) > 0) return "vip1";
return "普通用户";
}
}// 控制器使用协调服务
@restcontroller
@requestmapping("/api/users")
public class usercontroller {
@autowired
private userordercoordinationservice coordinationservice;
@putmapping("/{userid}")
public responseentity<string> updateuser(@pathvariable long userid,
@requestbody @valid userupdatedto userdata) {
coordinationservice.coordinateuserandorderupdate(userid, userdata);
return responseentity.ok("用户及关联订单更新成功");
}
}实战说明：在金融项目中，我使用过接口隔离的原则解决支付模块和账户模块的循环依赖。支付时需要验证账户，账户变动时又要触发支付回调。通过引入ipaymentgateway接口和iaccountservice接口，并使用spring的@lazy注解延迟加载，成功解决了这个问题。@lazy注解是spring提供的强大工具，它可以让bean在第一次使用时才被初始化，从而避免循环依赖问题。
3.3 spring aop切面和协调者模式
以下代码展示使用spring aop和协调者模式解决循环依赖：
// 定义协调者接口
public interface businessprocesscoordinator {
void processuserupdate(long userid, userupdatedto userdata);
void processorderupdate(long userid, orderupdatedto orderdata);
}
// 实现协调者 - 统一处理跨服务业务逻辑
@service
public class userordercoordinator implements businessprocesscoordinator {
@autowired
private userservice userservice;
@autowired
private orderservice orderservice;
@autowired
private notificationservice notificationservice;
/**
* 协调用户更新的完整流程
* 避免服务间的直接相互调用
*/
@override
@transactional
public void processuserupdate(long userid, userupdatedto userdata) {
// 1. 获取当前用户状态
user currentuser = userservice.getuserbyid(userid);
string oldviplevel = currentuser.getviplevel();
// 2. 更新用户信息
userservice.updateuser(userid, userdata);
// 3. 如果vip等级变化，处理相关订单
if (userdata.getviplevel() != null && !userdata.getviplevel().equals(oldviplevel)) {
list<order> affectedorders = orderservice.getordersbyuserid(userid);
for (order order : affectedorders) {
orderservice.updateorderdiscount(order.getid(), userdata.getviplevel());
}
}
// 4. 发送通知（通过协调者调用，避免循环依赖）
if (userdata.getviplevel() != null && !userdata.getviplevel().equals(oldviplevel)) {
notificationservice.sendviplevelchangenotification(userid, oldviplevel, userdata.getviplevel());
}
}
@override
@transactional
public void processorderupdate(long userid, orderupdatedto orderdata) {
// 1. 处理订单更新
order updatedorder = orderservice.updateorder(userid, orderdata);
// 2. 重新计算用户总消费金额
bigdecimal totalamount = orderservice.gettotalorderamount(userid);
// 3. 根据总消费金额调整用户等级
string newviplevel = calculateviplevel(totalamount);
user currentuser = userservice.getuserbyid(userid);
if (!newviplevel.equals(currentuser.getviplevel())) {
userupdatedto userupdate = userupdatedto.builder()
.viplevel(newviplevel)
.build();
userservice.updateuser(userid, userupdate);
// 4. 发送等级提升通知
notificationservice.sendviplevelupgradenotification(userid, currentuser.getviplevel(), newviplevel);
}
}
private string calculateviplevel(bigdecimal totalamount) {
if (totalamount.compareto(new bigdecimal("100000")) > 0) return "vip3";
if (totalamount.compareto(new bigdecimal("50000")) > 0) return "vip2";
if (totalamount.compareto(new bigdecimal("10000")) > 0) return "vip1";
return "普通用户";
}
}// 使用aop切面记录审计日志，避免在业务服务中直接调用审计服务
@aspect
@component
public class businessauditaspect {
@autowired
private auditservice auditservice;
// 用户操作审计切面
@around("execution(* com.example.service.userservice.updateuser(..))")
public object audituseroperation(proceedingjoinpoint joinpoint) throws throwable {
long userid = (long) joinpoint.getargs()[0];
userupdatedto userdata = (userupdatedto) joinpoint.getargs()[1];
// 记录操作前状态
user olduser = getuserbyid(userid);
try {
// 执行原方法
object result = joinpoint.proceed();
// 记录审计日志（通过切面，避免循环依赖）
auditservice.loguserupdate(userid, olduser, userdata, "success");
return result;
} catch (exception e) {
// 记录失败日志
auditservice.loguserupdate(userid, olduser, userdata, "failed: " + e.getmessage());
throw e;
}
}
// 订单操作审计切面
@around("execution(* com.example.service.orderservice.updateordersforuser(..))")
public object auditorderoperation(proceedingjoinpoint joinpoint) throws throwable {
long userid = (long) joinpoint.getargs()[0];
string viplevel = (string) joinpoint.getargs()[1];
// 记录操作前状态
list<order> oldorders = getordersbyuserid(userid);
try {
object result = joinpoint.proceed();
// 记录审计日志
auditservice.logorderupdate(userid, oldorders, viplevel, "success");
return result;
} catch (exception e) {
auditservice.logorderupdate(userid, oldorders, viplevel, "failed: " + e.getmessage());
throw e;
}
}
// 辅助方法（实际项目中应注入相应服务）
private user getuserbyid(long userid) {
// 模拟实现
return new user(userid, "用户名", "vip1");
}
private list<order> getordersbyuserid(long userid) {
// 模拟实现
return arrays.aslist(new order(1l, userid, new bigdecimal("1000")));
}
}// 重构后的userservice - 只关注用户相关业务逻辑
@service
public class userserviceimpl implements userservice {
@autowired
private userrepository userrepository;
// 不再直接依赖orderservice，避免循环依赖
@override
@transactional
public void updateuser(long userid, userupdatedto userdata) {
user user = userrepository.findbyid(userid)
.orelsethrow(() -> new usernotfoundexception("用户不存在"));
system.out.println("更新用户信息: " + userid);
// 只处理用户相关的业务逻辑
if (userdata.getusername() != null) {
user.setusername(userdata.getusername());
}
if (userdata.getemail() != null) {
user.setemail(userdata.getemail());
}
if (userdata.getviplevel() != null) {
user.setviplevel(userdata.getviplevel());
}
userrepository.save(user);
}
@override
public user getuserbyid(long userid) {
return userrepository.findbyid(userid)
.orelsethrow(() -> new usernotfoundexception("用户不存在"));
}
@override
public string getuserviplevel(long userid) {
return getuserbyid(userid).getviplevel();
}
}// 重构后的orderservice - 只关注订单相关业务逻辑
@service
public class orderserviceimpl implements orderservice {
@autowired
private orderrepository orderrepository;
// 不再直接依赖userservice，避免循环依赖
@override
@transactional
public void updateordersforuser(long userid, string viplevel) {
list<order> orders = orderrepository.findbyuserid(userid);
system.out.println("更新用户订单折扣，vip等级: " + viplevel);
// 只处理订单相关的业务逻辑
for (order order : orders) {
bigdecimal discount = calculatediscountbyviplevel(viplevel);
order.setdiscountrate(discount);
order.setfinalamount(order.getamount().multiply(discount));
}
orderrepository.saveall(orders);
}
@override
public bigdecimal gettotalorderamount(long userid) {
list<order> orders = orderrepository.findbyuserid(userid);
return orders.stream()
.map(order::getamount)
.reduce(bigdecimal.zero, bigdecimal::add);
}
@override
public list<order> getordersbyuserid(long userid) {
return orderrepository.findbyuserid(userid);
}
private bigdecimal calculatediscountbyviplevel(string viplevel) {
switch (viplevel) {
case "vip1": return new bigdecimal("0.95");
case "vip2": return new bigdecimal("0.90");
case "vip3": return new bigdecimal("0.85");
default: return bigdecimal.one;
}
}
public order updateorder(long userid, orderupdatedto orderdata) {
// 订单更新逻辑
return new order();
}
public void updateorderdiscount(long orderid, string viplevel) {
// 更新单个订单折扣的逻辑
}
}// 控制器使用协调者而不是直接调用服务
@restcontroller
@requestmapping("/api/users")
public class usercontroller {
@autowired
private businessprocesscoordinator coordinator;
@putmapping("/{userid}")
public responseentity<string> updateuser(@pathvariable long userid,
@requestbody @valid userupdatedto userdata) {
// 通过协调者处理完整的业务流程
coordinator.processuserupdate(userid, userdata);
return responseentity.ok("用户更新成功");
}
}
@restcontroller
@requestmapping("/api/orders")
public class ordercontroller {
@autowired
private businessprocesscoordinator coordinator;
@putmapping("/user/{userid}")
public responseentity<string> updateordersforuser(@pathvariable long userid,
@requestbody @valid orderupdatedto orderdata) {
// 通过协调者处理完整的业务流程
coordinator.processorderupdate(userid, orderdata);
return responseentity.ok("订单更新成功");
}
}实战说明：这个协调者模式是我在一个大型erp项目中应用的。原来的设计是用户服务、订单服务、通知服务、审计服务互相依赖，系统维护非常困难。重构后引入协调者统一管理跨服务业务流程，使用aop处理横切关注点（如审计、日志），彻底消除了循环依赖问题。各服务职责单一，测试和维护变得非常简单。
3.4 spring代理模式和objectprovider
以下代码展示使用spring的objectprovider和代理模式解决循环依赖：
// 使用objectprovider解决循环依赖
@service
public class userserviceimpl implements userservice {
private final objectprovider<orderservice> orderserviceprovider;
private final userrepository userrepository;
// 通过构造函数注入objectprovider而不是直接注入orderservice
public userserviceimpl(objectprovider<orderservice> orderserviceprovider,
userrepository userrepository) {
this.orderserviceprovider = orderserviceprovider;
this.userrepository = userrepository;
}
@override
@transactional
public void updateuser(long userid, userupdatedto userdata) {
user user = userrepository.findbyid(userid)
.orelsethrow(() -> new usernotfoundexception("用户不存在"));
system.out.println("更新用户信息: " + userid);
// 更新用户实体
if (userdata.getviplevel() != null) {
user.setviplevel(userdata.getviplevel());
}
if (userdata.getusername() != null) {
user.setusername(userdata.getusername());
}
userrepository.save(user);
// 需要时才获取orderservice实例
if (userdata.getviplevel() != null) {
orderservice orderservice = orderserviceprovider.getobject();
orderservice.updateordersforuser(userid, userdata.getviplevel());
}
}
@override
public user getuserbyid(long userid) {
return userrepository.findbyid(userid)
.orelsethrow(() -> new usernotfoundexception("用户不存在"));
}
@override
public string getuserviplevel(long userid) {
return getuserbyid(userid).getviplevel();
}
}// orderservice也使用objectprovider
@service
public class orderserviceimpl implements orderservice {
private final objectprovider<userservice> userserviceprovider;
private final orderrepository orderrepository;
public orderserviceimpl(objectprovider<userservice> userserviceprovider,
orderrepository orderrepository) {
this.userserviceprovider = userserviceprovider;
this.orderrepository = orderrepository;
}
@override
@transactional
public void updateordersforuser(long userid, string viplevel) {
list<order> orders = orderrepository.findbyuserid(userid);
system.out.println("更新用户订单，vip等级: " + viplevel);
// 更新订单折扣
for (order order : orders) {
bigdecimal discount = calculatediscountbyviplevel(viplevel);
order.setdiscountrate(discount);
order.setfinalamount(order.getamount().multiply(discount));
}
orderrepository.saveall(orders);
// 检查是否需要调整用户等级
bigdecimal totalamount = gettotalorderamount(userid);
string recommendedlevel = calculateviplevel(totalamount);
// 延迟获取userservice实例
string currentlevel = userserviceprovider.getobject().getuserviplevel(userid);
if (!recommendedlevel.equals(currentlevel)) {
userservice userservice = userserviceprovider.getobject();
userupdatedto updatedto = userupdatedto.builder()
.viplevel(recommendedlevel)
.build();
userservice.updateuser(userid, updatedto);
}
}
@override
public bigdecimal gettotalorderamount(long userid) {
list<order> orders = orderrepository.findbyuserid(userid);
return orders.stream()
.map(order::getamount)
.reduce(bigdecimal.zero, bigdecimal::add);
}
@override
public list<order> getordersbyuserid(long userid) {
return orderrepository.findbyuserid(userid);
}
private bigdecimal calculatediscountbyviplevel(string viplevel) {
switch (viplevel) {
case "vip1": return new bigdecimal("0.95");
case "vip2": return new bigdecimal("0.90");
case "vip3": return new bigdecimal("0.85");
default: return bigdecimal.one;
}
}
private string calculateviplevel(bigdecimal amount) {
if (amount.compareto(new bigdecimal("100000")) > 0) return "vip3";
if (amount.compareto(new bigdecimal("50000")) > 0) return "vip2";
if (amount.compareto(new bigdecimal("10000")) > 0) return "vip1";
return "普通用户";
}
}// 自定义代理工厂，提供更灵活的延迟加载
@component
public class lazyserviceproxyfactory implements beanfactoryaware {
private beanfactory beanfactory;
public <t> t createlazyproxy(class<t> serviceclass) {
return (t) proxy.newproxyinstance(
serviceclass.getclassloader(),
new class[]{serviceclass},
new lazyserviceinvocationhandler<>(serviceclass, beanfactory)
);
}
@override
public void setbeanfactory(beanfactory beanfactory) throws beansexception {
this.beanfactory = beanfactory;
}
private static class lazyserviceinvocationhandler<t> implements invocationhandler {
private final class<t> serviceclass;
private final beanfactory beanfactory;
private volatile t target;
public lazyserviceinvocationhandler(class<t> serviceclass, beanfactory beanfactory) {
this.serviceclass = serviceclass;
this.beanfactory = beanfactory;
}
@override
public object invoke(object proxy, method method, object[] args) throws throwable {
if (target == null) {
synchronized (this) {
if (target == null) {
target = beanfactory.getbean(serviceclass);
}
}
}
return method.invoke(target, args);
}
}
}// 使用自定义代理的服务
@service
public class userservicewithcustomproxy implements userservice {
private final lazyserviceproxyfactory proxyfactory;
private final orderservice orderservice; // 使用代理对象
private final userrepository userrepository;
public userservicewithcustomproxy(lazyserviceproxyfactory proxyfactory,
userrepository userrepository) {
this.proxyfactory = proxyfactory;
this.orderservice = proxyfactory.createlazyproxy(orderservice.class);
this.userrepository = userrepository;
}
@override
@transactional
public void updateuser(long userid, userupdatedto userdata) {
user user = userrepository.findbyid(userid)
.orelsethrow(() -> new usernotfoundexception("用户不存在"));
system.out.println("更新用户信息: " + userid);
// 更新用户信息
if (userdata.getviplevel() != null) {
user.setviplevel(userdata.getviplevel());
}
userrepository.save(user);
// 代理对象会在第一次调用时才真正初始化orderservice
if (userdata.getviplevel() != null) {
orderservice.updateordersforuser(userid, userdata.getviplevel());
}
}
@override
public user getuserbyid(long userid) {
return userrepository.findbyid(userid)
.orelsethrow(() -> new usernotfoundexception("用户不存在"));
}
@override
public string getuserviplevel(long userid) {
return getuserbyid(userid).getviplevel();
}
}实战说明：在我处理的一个微服务项目中，订单服务和库存服务存在严重的循环依赖问题。通过使用spring的objectprovider和自定义代理模式，我们实现了真正的按需加载，服务只有在真正被调用时才会被初始化，彻底避免了启动时的循环依赖问题。这种方案特别适合于大型微服务架构，其中服务间的依赖关系复杂，但又必须保持解耦。
四、面试回答技巧
4.1 面试官提问时的标准回答结构
面试官：你遇到过循环依赖吗？是怎么解决的？
标准回答：
"是的，我在实际开发中确实遇到过循环依赖问题。让我从三个方面来回答：
第一，我遇到的循环依赖场景：
在我之前负责的spring boot电商项目中，用户服务(userservice)和订单服务(orderservice)存在循环依赖。用户vip等级变化需要更新订单优惠策略，而订单总额变化又要影响用户vip等级。这导致了spring容器启动时出现’bean currently in creation’的错误。
第二，我的解决思路和方案：
我采用了spring applicationevent事件驱动架构来解决这个问题的。具体做法是：
- 定义了userupdatedevent和orderupdatedevent领域事件
- 使用applicationeventpublisher发布事件，而不是直接调用其他服务
- 创建了对应的事件监听器处理跨服务业务逻辑
- 配置了异步执行器(@async)提高系统性能
第三，解决后的效果：
- 消除了循环依赖，spring容器可以正常启动
- 提高了系统的可扩展性，后续其他服务也可以订阅这些事件
- 降低了耦合度，各服务可以独立测试和部署
- 通过异步处理提升了系统的响应速度"
4.2 体现技术深度的回答要点
1. 展现理论深度：
“循环依赖本质上是违反了依赖倒置原则，高层模块不应该依赖低层模块，两者都应该依赖抽象。在spring生态中，我们可以通过多种技术手段来解决：@lazy延迟加载、applicationevent事件驱动、objectprovider延迟注入、aop切面处理、以及协调者模式等。关键是要理解spring容器的bean生命周期和依赖注入机制。”
2. 展现实践经验：
"在spring boot项目中，我处理过几种不同的循环依赖场景：
- 服务层循环依赖：使用@lazy注解或事件驱动解决
- 实体类双向关联：使用@jsonignore避免序列化问题，或者使用dto模式
- 控制器层循环依赖：通过协调者模式重构，将业务逻辑下沉到服务层
- 跨模块循环依赖：引入领域事件和事件总线，实现模块解耦
每种场景都有最适合的解决方案，关键是要根据具体的业务需求和技术架构来选择。"
3. 展现架构思维：
"预防循环依赖比解决更重要。在spring项目设计阶段，我会：
- 遵循ddd领域驱动设计，按业务边界划分限界上下文
- 建立清晰的依赖关系图，确保依赖方向是单向的
- 使用spring boot actuator的beans端点监控bean依赖关系
- 在ci/cd流程中加入依赖关系检查
- 团队代码审查时重点关注模块间依赖设计
我习惯用archunit这样的架构测试工具来确保架构规则的执行。"
4.3 可能的追问及回答
追问：如果业务逻辑必须要有循环依赖怎么办？
回答：
"这种情况下，我会根据spring框架的特性来处理：
- 重新审视业务流程：看看是否可以通过调整业务逻辑来避免，比如引入最终一致性概念
- 使用spring技术解耦：
- @lazy延迟加载解决服务层循环依赖
- applicationevent事件驱动实现异步解耦
- @transactionaleventlistener确保事务一致性
- objectprovider实现延迟注入
- 协调者模式：引入businessprocesscoordinator统一管理复杂业务流程
- 分布式事务处理：如果是微服务场景，考虑使用saga模式或tcc模式
关键是要将循环依赖的控制权收归到一个协调者手中，让各个spring bean都依赖这个协调者，而不是互相依赖。"
追问：如何预防循环依赖的产生？
回答：
"我会在几个方面着手，特别是在spring boot项目中：
- 架构设计阶段：
- 使用ddd划分限界上下文，确保依赖方向正确
- 绘制spring bean依赖关系图，确保没有环形依赖
- 定义清晰的分层架构：controller → service → repository
- 代码规范阶段：
- 建立团队代码规范，禁止@service层之间的直接依赖
- 要求使用接口编程，面向抽象而非具体实现
- 工具支持：
- 使用archunit编写架构测试，自动检测循环依赖
- 配置ide插件（如sonarlint）实时检查依赖关系
- 使用spring boot actuator的/beans端点监控bean依赖
- 持续监控：
- 在ci/cd流程中加入依赖关系检查
- 定期使用jdeps或类似工具分析项目依赖
- 使用maven/gradle的依赖分析插件"
4.4 体现解决问题能力的回答模板
"遇到spring循环依赖问题时，我的解决思路是：分析问题根源 → 设计解决方案 → 实施改造 → 验证效果。
在之前的spring boot电商项目中，我不仅解决了用户服务和订单服务的循环依赖问题，还做了以下系统性改进：
- 建立spring依赖管理规范：制定了@service层依赖规范，要求使用接口编程和@lazy注解
- 引入架构测试：使用archunit编写自动化测试，防止新的循环依赖产生
- 完善监控体系：配置spring boot actuator，定期检查bean依赖关系
- 团队培训：组织spring最佳实践分享，提升团队整体架构意识
这种系统性的问题解决思路，让我在后续项目中能够更好地规避技术债务，确保spring应用的健康性和可维护性。"
总结
循环依赖是软件开发中常见但严重的问题。通过合理的设计模式选择、架构重构和技术手段应用，我们不仅可以解决已有的循环依赖问题，更重要的是从源头上预防这类问题的产生。在实际项目中，要根据具体的业务场景和技术栈选择最适合的解决方案，并建立长期的管理机制来维护代码库的健康度。
到此这篇关于spring boot java循环依赖详解的文章就介绍到这了,更多相关spring boot java循环依赖内容请搜索代码网以前的文章或继续浏览下面的相关文章希望大家以后多多支持代码网！
发表评论