Spring + Hibernate + Redis 的分布式锁

Question

我一直在开发一个使用 Spring mvc + Hibernate 和 redis 进行缓存存储的多线程 Web 应用程序。我正在寻找一种将锁应用于控制器或服务的方法。

我无法使用 Hibernate 提供的锁定机制，因为它旨在应用于数据库级别。

这是一个例子：

@RestController
@RequestMapping(RestConstants.BASE_PATH + "/campaigns")
Class CampaignController  {

    @RequestMapping(value = "/{id}", method = RequestMethod.GET)
    public ApiResponse<?> findOne(@PathVariable Integer id) {
        Campaign campaign = repo.findOne(id);
        return toResponse(campaign);
    }

    @RequestMapping(value = "", method = RequestMethod.POST)
    public create(@RequestBody Campaign campaign) {
        //create an campaign here
    }

    @RequestMapping(value = "/{id}", method = RequestMethod.PATCH)
    public update(@RequestBody Campaign campaign) {
        //update an campaign here
    }
}

@RestController
@RequestMapping(RestConstants.BASE_PATH + "/bulkCampaigns")
Class CampaignBulkController {
    @RequestMapping(value = "/upload", method = RequestMethod.POST)
    public create(@RequestPart MultipartFile data) {
        /* 
        Data contains a list of campaigns with their details, 
         controller will iterate through the list and create all the campaigns.

         */
    }
}

在处理映射到 CampaignBulkController 中的 create 方法的请求时，无法处理对活动的所有其他写入，但允许读取。也就是说，应删除更新或创建活动/活动的请求。

有多个服务器，每个服务器都是多线程的。

我是 Spring 和 Hibernate 的新手，任何想法或建议都将不胜感激！

Answer 1

我将在这里概述一个初步的答案，可能供以后修改。

如果您使用共享的ReadWriteLock 并为常规操作使用读锁，您可以让您的特权操作使用写锁来阻止常规操作。

// Regular operation tries to lock, if not successful a privileged operation is happening
if(!lock.readLock().tryLock())
    return cannotProcessResponse;

performRegularOperation();
lock.readLock().unlock();

---

// Privileged operation always waits for lock
lock.writeLock().lock();
performPrivilegedOperation();
lock.writeLock().unlock();

现在这种方法存在一些问题。如果使用单个共享锁，则一次只能运行一个特权操作。如果这是一个问题，可以使用多个锁并将它们的读锁锁定在一起（这可能容易出现死锁，因此必须小心）。还应考虑锁公平性。