7

キュー サーバーへのチャネル/接続のプールを作成しようとしており、ObjectPool を使用しようとしていましたが、サイトの例からそれを使用するのに問題があります。

これまでのところ、機能するスレッドがありますが、それぞれがプールからチャネルを取得してから返すようにしたいと考えています。使用方法 (borrowObject/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のプールに使用される別のアプローチはありますか?

4

2 に答える 2

4

オブジェクトを作成し、返されたときに何をすべきかを知っているクラスを作成します。それはあなたにとって次のようなものかもしれません：

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()))
于 2012-04-28T23:35:37.263 に答える
3

プールするオブジェクトを作成、検証、および破棄するには、PoolableObjectFactory のカスタム実装が必要です。次に、ファクトリのインスタンスを ObjectPool のコンストラクタに渡すと、オブジェクトの借用を開始する準備が整います。

ここにいくつかのサンプルコードがあります。commons-pool を使用する commons-dbcp のソース コードも参照できます。

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();
        }
    }
}
于 2012-04-28T23:57:07.043 に答える