HazelcastMailboxPathLocker

문의를 주셔서 남깁니다.

 James에서 기본으로 제공하는 JVMMailboxPathLocker 를 사용한다면 

File repository 를 사용 중인 여러대의 James 라면 uildlist 가 깨질 수 있다.

James 를 hazelcast 로 묶어 수정하려는 MailboxPath 를 LOCK 처리를 한다.

import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.locks.Lock; import java.util.concurrent.locks.ReadWriteLock; import java.util.concurrent.locks.ReentrantReadWriteLock; import org.apache.james.mailbox.MailboxSession; import org.apache.james.mailbox.exception.MailboxException; import org.apache.james.mailbox.model.MailboxPath; import org.apache.james.mailbox.store.AbstractMailboxPathLocker; import com.hazelcast.core.Hazelcast; public class HazelcastMailboxPathLocker extends AbstractMailboxPathLocker { private final ConcurrentHashMap<MailboxPath, ReadWriteLock> paths = new ConcurrentHashMap<MailboxPath, ReadWriteLock>(); private void lock(MailboxSession session, MailboxPath path) throws MailboxException { Lock lock = Hazelcast.getLock(path.toString()); lock.lock(); } private void unlock(MailboxSession session, MailboxPath path) throws MailboxException { Lock lock = Hazelcast.getLock(path.toString()); lock.unlock(); } @Override protected void lock(MailboxSession session, MailboxPath path, boolean writeLock) throws MailboxException { lock(session, path); ReadWriteLock lock = paths.get(path); if (lock == null) { lock = new ReentrantReadWriteLock(); ReadWriteLock storedLock = paths.putIfAbsent(path, lock); if (storedLock != null) { lock = storedLock; } } getLock(lock, writeLock).lock(); } @Override protected void unlock(MailboxSession session, MailboxPath path, boolean writeLock) throws MailboxException { ReadWriteLock lock = paths.get(path); if (lock != null) { getLock(lock, writeLock).unlock(); } unlock(session, path); } private Lock getLock(ReadWriteLock lock, boolean writeLock) { Lock l; if (writeLock) { l = lock.writeLock(); } else { l = lock.readLock(); } return l; } }