要了解 connection 和 session 的概念，可以先從 ConnectionState 和 SessionState 入手：

// 省略部分代碼 public class ConnectionState {ConnectionInfo info;private final ConcurrentHashMap<TransactionId, TransactionState> transactions = new ConcurrentHashMap<TransactionId, TransactionState>();private final ConcurrentHashMap<SessionId, SessionState> sessions = new ConcurrentHashMap<SessionId, SessionState>();private final List<DestinationInfo> tempDestinations = Collections.synchronizedList(new ArrayList<DestinationInfo>());private final AtomicBoolean shutdown = new AtomicBoolean(false);private boolean connectionInterruptProcessingComplete = true;private HashMap<ConsumerId, ConsumerInfo> recoveringPullConsumers;public ConnectionState(ConnectionInfo info) {this.info = info;// Add the default session id.addSession(new SessionInfo(info, -1));} }

從代碼可以看出，連接里有事務集合、會話集合、臨時隊列集合等，這說明：
1. 事務屬于一個連接； 2. 會話屬于一個連接； 3. 臨時隊列的生存期是連接的有效期

?

// 省略部分代碼 public class SessionState {final SessionInfo info;private final Map<ProducerId, ProducerState> producers = new ConcurrentHashMap<ProducerId, ProducerState>();private final Map<ConsumerId, ConsumerState> consumers = new ConcurrentHashMap<ConsumerId, ConsumerState>();private final AtomicBoolean shutdown = new AtomicBoolean(false);public SessionState(SessionInfo info) {this.info = info;} }

從上面能看出，producer 和 consumer 是屬于某個會話的，producer 和 consumer 都有唯一的 ID 。

?

// 省略部分代碼 public class ProducerState {final ProducerInfo info;private TransactionState transactionState; }public class ConsumerState { final ConsumerInfo info; }

ProducerState 和 ConsumerState 只是做了簡單的封裝。

其中 ConnectionInfo, SessionInfo, ProducerInfo, ConsumerInfo 都是消息類型，均繼承自 BaseCommand 接口。

轉載于:https://www.cnblogs.com/allenwas3/p/8934336.html

總結

以上是生活随笔為你收集整理的ActiveMQ 的连接和会话的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。