キュー方式または個別DB接続？

Question

私はdatabaseQueue.add(message);を経由してキューにデータを送信するソケット接続を持っています。次に、DatabaseProcessorクラスは、開始時にスレッドとして開始され、単一のデータベース接続が行われます。接続はdatabaseQueue.take();でメッセージを受け取り、処理します。この部分の良い点は、データベース接続が1つしかないことです。突発的にデータが急増しているときに問題が発生します。もう一つの方法は、受け取った各データに対して、私はメソッドを開いて閉じます。ここに行く最善の方法である重い荷物のためのあなたの経験に基づいていますか？

私のコードの一部抜粋。

class ConnectionHandler implements Runnable { 
    ConnectionHandler(Socket receivedSocketConn1) { 
     this.receivedSocketConn1=receivedSocketConn1; 
    } 


     // gets data from an inbound connection and queues it for databse update 

     public void run() { 
      databaseQueue.add(message); // put to db queue 

     } 
} 
class DatabaseProcessor implements Runnable { 
public void run() 
     { 
     // open database connection 
     createConnection(); 
      while (true) 
      { 
        message = databaseQueue.take(); // keep taking message from the queue add by connectionhandler and here I will have a number of queries to run in terms of select,insert and updates. 
        } 
     } 

void createConnection() 
{ 
    System.out.println("Crerate Connection"); 
    connCreated = new Date(); 
    try 
    { 
    dbconn = DriverManager.getConnection("jdbc:mysql://localhost:3306/test1?"+"user=user1&password=*******"); 
    dbconn.setAutoCommit(false); 

    } 
    catch(Throwable ex) 
    { 
     ex.printStackTrace(System.out); 
    } 

} 
} 

public void main() 
{ 
new Thread(new DatabaseProcessor()).start(); //calls the DatabaseProcessor 
//initiate the socket 

} 

Answer 1

あなたがキューを介してメッセージを送受信するクライアント - サーバーソケット接続を管理していることは理解できます。私もそれが正しいとすれば、キュー上の新しいメッセージごとにスレッドを作成しています。

多くのメッセージが送信され、読み込まれることを考慮して、スレッドSynchronizedにメソッドを宣言することをお勧めします。データを受信するたびにストリームを開いたり閉じたりする必要はありません。あなたの2番目のアプローチへ）。同期メソッドは通常、スレッドによって同時に変更できる共通データのサージを処理するための最良の方法です。

Answer 2

あなたは両方の長所を取得するには、接続プーリングを使用することができます：あなたは、単一のスレッドに限定されるものではなく、あなたはまた、要求ごとに接続を開く必要はありません。 Apache DBCPをご覧ください。

Answer 3

このアプローチは罰金です。あなたはc3poを使用してDBプールを作成することができます。また、スレッドプールを管理するために、threadPoolエグゼキュータを使用してください。