Есть ли хорошие уроки или примеры использования Java ObjectPool/pool?

Question

Я пытаюсь создать пул каналов / подключений к серверу очередей и пытаюсь использовать ObjectPool, но у меня возникают проблемы при использовании его из примера на их сайте.

Пока у меня есть потоки, которые работают, но я хочу, чтобы каждый из них захватил канал из пула и затем возвратил его. Я понимаю, как его использовать (loanObject/returnObjects), но не уверен, как создать первоначальный пул.

Вот как каналы сделаны в rabbitmq:

ConnectionFactory factory = new ConnectionFactory();
    factory.setHost("localhost");
    Connection connection = factory.newConnection();
    Channel channel = connection.createChannel();

и мой код просто использует канал, чтобы делать вещи. Я запутался, потому что единственный пример, который я смог найти (на их сайте), запускает его так:

private ObjectPool<StringBuffer> pool;

    public ReaderUtil(ObjectPool<StringBuffer> pool) { 
        this.pool = pool;
    }

Что не имеет смысла для меня. Я понял, что это обычное явление для установления соединений с базой данных, поэтому я попытался найти учебники с использованием баз данных и ObjectPool, но они, похоже, используют DBCP, который специфичен для баз данных (и я не могу использовать логику для своего сервера очередей).

Любые предложения о том, как его использовать? Или есть другой подход, используемый для пулов в Java?

Answer 1

Они создают класс, который создает объекты и знает, что делать, когда они возвращаются. Это может быть что-то вроде этого для вас:

public class PoolConnectionFactory extends BasePoolableObjectFactory<Connection> { 

    private final ConnectionFactory factory;
    public PoolConnectionFactory() {
        factory = new ConnectionFactory();
        factory.setHost("localhost");
    }

    // for makeObject we'll simply return a new Connection
    public Connection makeObject() { 
        return factory.newConnection();
    } 

    // when an object is returned to the pool,  
    // we'll clear it out 
    public void passivateObject(Connection con) { 
        con.I_don't_know_what_to_do(); 
    } 

    // for all other methods, the no-op  
    // implementation in BasePoolableObjectFactory 
    // will suffice 
}

теперь вы создаете ObjectPool<Connection> где-то:

ObjectPool<Connection> pool = new StackObjectPool<Connection>(new PoolConnectionFactory());

тогда вы можете использовать pool внутри ваших тем, как

Connection c = pool.borrowObject();
c.doSomethingWithMe();
pool.returnObject(c);

Строки, которые не имеют смысла для вас, являются способом передачи объекта пула в другой класс. Смотрите последнюю строку, они создают пул при создании ридера.

new ReaderUtil(new StackObjectPool<StringBuffer>(new StringBufferFactory()))

Answer 2

Вам потребуется специальная реализация PoolableObjectFactory для создания, проверки и уничтожения объектов, которые вы хотите объединить. Затем передайте экземпляр вашей фабрики в конструктор ObjectPool, и вы готовы начать заимствовать объекты.

Вот пример кода. Вы также можете посмотреть исходный код для commons-dbcp, который использует commons-pool.

import org.apache.commons.pool.BasePoolableObjectFactory;
import org.apache.commons.pool.ObjectPool;
import org.apache.commons.pool.PoolableObjectFactory;
import org.apache.commons.pool.impl.GenericObjectPool;

public class PoolExample {
    public static class MyPooledObject {
        public MyPooledObject() {
            System.out.println("hello world");
        }

        public void sing() {
            System.out.println("mary had a little lamb");
        }

        public void destroy() {
            System.out.println("goodbye cruel world");
        }
    }

    public static class MyPoolableObjectFactory extends BasePoolableObjectFactory<MyPooledObject> {
        @Override
        public MyPooledObject makeObject() throws Exception {
            return new MyPooledObject();
        }

        @Override
        public void destroyObject(MyPooledObject obj) throws Exception {
            obj.destroy();
        }
        // PoolableObjectFactory has other methods you can override
        // to valdiate, activate, and passivate objects.
    }

    public static void main(String[] args) throws Exception {
        PoolableObjectFactory<MyPooledObject> factory = new MyPoolableObjectFactory();
        ObjectPool<MyPooledObject> pool = new GenericObjectPool<MyPooledObject>(factory);

        // Other ObjectPool implementations with special behaviors are available;
        // see the JavaDoc for details

        try {
            for (int i = 0; i < 2; i++) {
                MyPooledObject obj;

                try {
                    obj = pool.borrowObject();
                } catch (Exception e) {
                    // failed to borrow object; you get to decide how to handle this
                    throw e;
                }

                try {
                    // use the pooled object
                    obj.sing();

                } catch (Exception e) {
                    // this object has failed us -- never use it again!
                    pool.invalidateObject(obj);
                    obj = null; // don't return it to the pool

                    // now handle the exception however you want

                } finally {
                    if (obj != null) {
                        pool.returnObject(obj);
                    }
                }
            }
        } finally {
            pool.close();
        }
    }
}