PooledConnectionFactory有兩個屬性maxConnections,maximumActive。咋一看來,用人類的常識理解,maxConnection應(yīng)該表示最大可建的connection數(shù),maximumActive應(yīng)該表示最大活躍的connection數(shù),當pool中的連接數(shù)大于最大活躍數(shù)時,又超過idleTimeout會被回收線程回收到。
如果是這樣理解的,就大錯特錯了。PooledConnetionFactory的這兩個參數(shù)根本不是這個意思。
看一下PooledConnectionFactory的組成結(jié)構(gòu):

注:ConnectionPool其實存儲的就是一個ActivemqConnection,起的名字真是蛋疼。
更糟的是上面兩個屬性也不是我們想的一樣。maxConnections表示的是LinkedList中connection的數(shù)目。maximumActive表示的是SessionPool中session的最大數(shù)目。IdleTime是Connection的回收時間,回收時也不是多線程的,每次getConnection時,都會檢測是否超時,如果超時,就是立即回收,此時立即重建,真蛋疼。SeesionPool是用Commons-pool實現(xiàn)的。
上圖的結(jié)構(gòu)表示的是一個PooledConnetion維護了一個Map,Map的Key可以是由username,password決定的, LinkedList維護了一個循環(huán)鏈表的ActivemqConnection。每次從LinkedList中的頭部取出一個AactivemqConnection,然后再添加到尾部,簡單的輪詢式的負載均衡。而這些ActivemqConnection是可以被多線程重用的。Pool實現(xiàn)中也沒有connection是否inactive的檢測機制,因為ActivemqConnection有自己的heartbeat檢測機制。每次發(fā)送或接收時候先從ConnectionPool中取出一個connection,如果Connection都用光了,就會重用在鏈表頭部的Connection的SessionPool,所以一個Connection可能會被多個線程使用,但一個session只會對應(yīng)一個線程,保證上下文隔離性。多線程同享一個物理信道,這需要Activemq有自己的拆包機制,才不會混亂。而上面提到的負載均衡,也沒考慮到session的使用情況,可能我從頭部拿出的connection的session pool已經(jīng)被耗光,而尾部的connection session pool卻很空閑,這樣就要無辜的阻塞等待session。
這樣看來在我們設(shè)置PooledConnection時,建議有條件的還是需要把maxConnections設(shè)置的大一些。它的默認值是1。maximumActive可以設(shè)的相對小一些,它的默認值是500,這值太大,擔心內(nèi)存溢出。IdleTime有條件的可以設(shè)置的大一些,增加connection的重用時間,默認值是30秒。