Как внедрить слой «Lock» в существующую структуру сервиса - PullRequest
Новая
       24

Как внедрить слой «Lock» в существующую структуру сервиса

1 голос
/ 28 февраля 2011

текущая ситуация: у меня есть служба с несколькими типичными методами, такими как create (), remove (), findXy () и т. Д. Теперь я хочу предотвратить два разных вызова службы одновременно, то есть хочу заблокируйте мой сервисный вызов, после ввода его в первый раз, так что второй клиент (или тот же клиент снова) будет вводить метод только после завершения первого клиента.

Для целей блокировки мы обычно используем ReentrantLocks. Они отлично работают. Но теперь я сомневаюсь, как реализовать эти ReentrantLocks, так как я не хочу вставлять их в каждый метод. Более того, наши сервисные слои уже сами определяют свой контекст транзакции, что означает, что когда я интегрирую их в сам метод, транзакция уже начинается до того, как произойдет блокировка. 

public class WorkerServiceServerImpl implements WorkerServiceRemote
{
  private static final ReentrantLock workerLock = new ReentrantLock( true );

  @Autowired
  private WorkerDao                 workerDao;

  @Override
  @Transactional
  public int createWorker( int projectId ) throws RemoteException
  {
    workerLock.lock();//NO GOOD! Transaction already started!

    try
    {
      workerDao.create( projectId );

      //Do some more stuff...
    }
    finally
    {
      workerLock.unlock();//Unlock, next request can be handled!
    }
  }

  ...
}

Конечно, я мог бы создать ServiceLayer над этим классом WorkerServiceImpl и просто перенаправить вызовы на исходный сервис, но, поскольку у меня около 30 сервисов, мне интересно, есть ли какие-либо глобальные решения для решения этой проблемы. Или возможно создать собственную аннотацию, которая срабатывает до начала транзакции?

Любые идеи приветствуются, заранее спасибо! ymene

РЕДАКТИРОВАТЬ: я выбираю методы CRUD для простоты. Конечно, эти сервисные вызовы намного сложнее и могут вызывать разные CRUD-методы в пределах одного вызова.

Ответы [ 2 ]

2 голосов
/ 28 февраля 2011

В отношении этого дизайна можно сделать несколько замечаний:

  • Необходимость применения блокировок к методам обслуживания выглядит странно. Если у вас есть проблемы с параллельным выполнением методов обслуживания, возможно, было бы лучше решить их путем правильной настройки транзакций при доступе к базовой базе данных.

  • unlock() должен вызываться внутри блока finally.

  • Если ваш сервис одноразовый, использование ReentrantLock эквивалентно маркировке ваших методов synchronized.

  • Вы можете создать аспект для применения синхронизации к вашим методам. Смотри 7. Аспектно-ориентированное программирование с пружиной , особенно 7.2.4.7 Упорядочивание рекомендаций .

1 голос
/ 28 февраля 2011

Поскольку вы, похоже, используете Spring, вы можете определить одноэлементный LockInterceptor и поместить его в свой стек перехватчиков перед перехватчиком транзакции. Этот перехватчик будет очень простым: 

import org.aopalliance.intercept.*;
public class LockInterceptor implements MethodInterceptor {

    @Override
    public synchronized Object invoke(MethodInvocation mi) throws Throwable {
        return mi.proceed();
    }
}
...