Кластерный общий кэш [закрывается]

Question

Кластерный общий кэш [закрывается]

COM поддерживает вызовы метода интерфейса для двух разных потоков, двух разных процессов или двух разных машин. Это называется маршалинг . Два разных потока - наиболее распространенный случай, COM-сервер часто не является потокобезопасным. COM реализует поточную безопасность для таких однопоточных коклассов, направляя вызов из «неправильного» потока в поток, создавший сервер. Маршалинг между процессами происходит, когда вы пишете внепроцессный сервер. Между разными машинами в сети это называется DCOM.

Это реализуется путем создания экземпляра интерфейса, который выглядит точно как оригинал. Но все методы интерфейса на самом деле являются заменителями, которые выполняют маршалинг вызова. Это прокси. На другом конце провода есть замена, которая выглядит точно как интерфейс, но выполняет противоположную работу. Это заглушка. Прокси и заглушка работают вместе, создавая иллюзию, что вы делаете простой вызов метода в вашей программе.

Основная задача прокси-сервера заключается в сериализации аргументов вызова метода в буфер памяти или сетевой пакет. Это может быть довольно нетривиальным, особенно когда вы используете указатели на структуры переменного размера. COM нуждается в помощи, чтобы понять это правильно, и это работа вашего проекта FooPS. Когда вы запускаете midl.exe для вашего .idl-файла, midl автоматически генерирует код из определений интерфейса для реализации прокси и заглушки. Это довольно часто достаточно хорошо, но вам может понадобиться реализовать свои собственные, если встроенных ключевых слов в midl недостаточно для описания ваших данных.

Наконец, что не менее важно, Windows предоставляет стандартный маршаллер, который может маршалировать простые интерфейсы. Разработан для поддержки подмножества COM, определенного COM Automation. Другими словами, интерфейсы, которые являются производными от IDispatch и используют только типы, совместимые с Automation. Вам нужно только получить правильные записи в реестре, чтобы включить его, и в противном случае не нужен прокси / заглушка, сгенерированный midl. И, конечно, если вы выполняете простые внутрипроцессные вызовы только в одном потоке, он вам тоже не понадобится. Это довольно часто.

26

java caching distributed-computing cluster-computing

задан Amro 2 July 2012 в 06:55

7 ответов

Как насчет этого?

Сделайте локальный ConcurrentHashMap в качестве локального кеша. Создайте распределенную карту / кеш Hazelcast. Начните прислушиваться к событиям распределенной карты и обновите локальную ConcurrentHashMap.

Теперь локальные кэши на каждом члене будут одинаковыми. Автосинхронизация.

import com.hazelcast.core.IMap; 
import com.hazelcast.core.Hazelcast;
import com.hazelcast.core.EntryListener;
import com.hazelcast.core.EntryEvent; 
import java.util.concurrent.ConcurrentHashMap;

public class Sample implements EntryListener {
        Map localCache = new ConcurrentHashMap ();

        public static void main(String[] args) { 
                Sample sample = new Sample();
                IMap   map    = Hazelcast.getMap("default"); 

                //Listen for all added/updated/removed entries
                map.addEntryListener(sample, true);  
        }

        public void entryAdded(EntryEvent event) {
             localCache.put(event.getKey(), event.getValue());            
        }

        public void entryRemoved(EntryEvent event) {
             localCache.remove(event.getKey());            
        }

        public void entryUpdated(EntryEvent event) {
             localCache.put(event.getKey(), event.getValue());            
        }
}

13