資料庫mq

Ⅰ 用java代碼如何設置activemq消息持久化到資料庫中

ActiveMQ持久化消息的二種方式；
1、持久化為文件
這個裝ActiveMQ時默認就是這種，只要設置消息為持久化就可以了。涉及到的配置和代碼有：
<persistenceAdapter>
<kahaDB directory="${activemq.base}/data/kahadb"/>
</persistenceAdapter>
procer.Send(request, MsgDeliveryMode.Persistent, level, TimeSpan.MinValue);

2、持久化為Mysql
首先需要把MySql的驅動放到ActiveMQ的Lib目錄下，我用的文件名字是：mysql-connector-java-5.0.4-bin.jar
接下來修改配置文件
<persistenceAdapter>
<jdbcPersistenceAdapter dataDirectory="${activemq.base}/data" dataSource="#derby-ds"/>
</persistenceAdapter>
在配置文件中的broker節點外增加
<bean id="derby-ds" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close">
<property name="driverClassName" value="com.mysql.jdbc.Driver"/>
<property name="url" value="jdbc:mysql://localhost/activemq?relaxAutoCommit=true"/>
<property name="username" value="activemq"/>
<property name="password" value="activemq"/>
<property name="maxActive" value="200"/>
<property name="poolPreparedStatements" value="true"/>
</bean>
從配置中可以看出資料庫的名稱是activemq，需要手動在MySql中增加這個庫。
然後重新啟動消息隊列，會發現多了3張表
1：activemq_acks
2：activemq_lock
3：activemq_msgs

Ⅱ 如何保證 資料庫成功 mq一定成功

先將數據讀入mq，資料庫從mq里讀數據，然後再寫入資料庫

Ⅲ 怎麼從mqsql數據表讀取數據

打開mysql控制台，並輸入密碼

要進入資料庫 首先得輸入 show databases;

要使用哪個資料庫，必須先輸入 use + 表名 如 use nowasp;

要知道這個資料庫中有哪些表就輸入命令 show + 第三步的資料庫 如
show nowasp;

5
之後就可以大量使用sql語句來操作你所需要的表，達到學習sql語句的目的，如查看錶中的數據 select * from accounts

Ⅳ 在用MQ處理高並發sql時，有什麼方法能得到返回結果么

對於大量並發請求，我們暫且認為這個量已經超過了資料庫正常的處理能力。那麼僅僅通過資料庫層面已經無法解決了。這需要在JAVA程序端通過緩存的方式進行優化。Hibernate本身對OR對象進行了一定程度的緩存處理，但如果這仍不能解決問題，那麼就要考慮從業務層面來定義緩存的粒度。例如:在一個WEB應用中首頁上會有很多需要從資料庫中讀取的內容，但其更新頻率往往很慢，那麼首頁的可以作為緩存的顆粒。 這里介紹一個輕量級的緩存工具OSCache，它既可以在JSP頁面中加入特殊的Tag來進行頁面內容的緩存，也可以在後台邏輯中處理對象級緩存。 還有，對於高並發應用的優化是一個系統工程。上述的緩存技術只是一個方面，還有包括資料庫優化，SQL優化，日誌優化，負載均衡等等方法。這就不是一句兩句能講清楚的了。

Ⅳ 怎樣利用Oracle golden gate 分發資料庫同步消息至ActiveMQ

利用Oracle golden gate 分發資料庫同步消息至ActiveMQ 引言
Oracle golden gate是甲骨文推出的一款資料庫同步軟體，可以實現異構資料庫之間的亞秒級同步，它不僅僅支持Oracle，還支持Mysql和一些業界常用資料庫。Ogg可以自動抽取表級數據的動態變化，直接將同步信息作用於目標資料庫。然而，在某一些場景之中，我們並不需要將同步信息直接作用於目標資料庫，而是將其保存在隊列中，然後在隊列中取出這些信息，完成一些下游系統的業務需求，這樣可以讓增量同步更加靈活。本篇文章主要講述如何，配置Ogg來抽取源表的同步信息生成trail文件（Ogg專屬同步文件），並利用分發器讀取trail文件，適配成可以解析的xml，將其作為消息發送給隊列。本文將不再講訴一下關於安裝的步驟，直接上干貨。
OGG數據同步的重要概念 oracle歸檔和日誌
Oacle歸檔模式是ORACLE熱備份的必要條件，特別是7X24生產的資料庫。可以這么認為：歸檔日誌是增量同步的數據源，因此必須開啟。可以通過下面的的指令查看是否開了歸檔：
SQL> archive log list
Ogg抽取進程
開啟了歸檔和日誌，ogg就有數據源來獲取同步信息。而具體的工作是由Ogg抽取進程

Ⅵ mq是什麼的縮寫

message queuing(消息排隊),是一種應用程序對應用程序的通信方法。通過這種技術的應用，能夠為一個資料庫系統帶來較強的數據處理能力及較高的安全性.
即時通訊軟體MQ,專門為旅遊同行們量身定做的集網上即時通信、業務交易、辦公管理於一體的軟體。您可以使用同業MQ安全、快捷、高效地與各地的旅遊同行像用QQ一樣實時文字聊天、音頻聊天、視頻聊天、傳文件、建討論組、建群，還可以在網上進行旅遊產品在線交易；集旅遊線路、機票、景區、酒店、車隊、旅遊用品、購物點、旅遊供求信息等資源為一體打造旅遊同業資源交流共享！ 另外，所有的交易結果都能通過同業MQ系統自動提醒，全面滿足您推廣業務、交易洽談、交流經驗、廣交朋友的需求。

mq是指那種很活潑的人

非常活潑,很有個性,個性張揚.做起事來我行我素完全不在乎別人怎麼看?具體特徵:可以在公共場合大聲唱歌,大聲講話.並且你的好又經常說的一句話是我不認識這個人(呵呵),那麼你就是新時代的MQ人.

http://ke..com/view/732119.htm 這是網路上的介紹,你看看!

Ⅶ RabbitMQ與redis的區別是什麼呢

首先說RabbitMQ，RabbitMQ是使用Erlang編寫的一個開源的消息隊列，本身支持很多的協議：AMQP，XMPP, SMTP, STOMP，也正因如此，它非常重量級，更適合於企業級的開發。同時實現了Broker構架，這意味著消息在發送給客戶端時先在中心隊列排隊。對路由，負載均衡或者數據持久化都有很好的支持。
其次是Redis，Redis是一個基於Key-Value對的NoSQL資料庫，開發維護很活躍。雖然它是一個Key-Value資料庫存儲系統，但它本身支持MQ功能，所以完全可以當做一個輕量級的隊列服務來使用。對於RabbitMQ和Redis的入隊和出隊操作，各執行100萬次，每10萬次記錄一次執行時間。測試數據分為128Bytes、512Bytes、1K和10K四個不同大小的數據。實驗表明：入隊時，當數據比較小時Redis的性能要高於RabbitMQ，而如果數據大小超過了10K，Redis則慢的無法忍受；出隊時，無論數據大小，Redis都表現出非常好的性能，而RabbitMQ的出隊性能則遠低於Redis。
3.3ZeroMQ
ZeroMQ號稱最快的消息隊列系統，尤其針對大吞吐量的需求場景。ZeroMQ能夠實現RabbitMQ不擅長的高級/復雜的隊列，但是開發人員需要自己組合多種技術框架，技術上的復雜度是對這MQ能夠應用成功的挑戰。ZeroMQ具有一個獨特的非中間件的模式，你不需要安裝和運行一個消息伺服器或中間件，因為你的應用程序將扮演這個伺服器角色。你只需要簡單的引用ZeroMQ程序庫，可以使用NuGet安裝，然後你就可以愉快的在應用程序之間發送消息了。但是ZeroMQ僅提供非持久性的隊列，也就是說如果宕機，數據將會丟失。其中，Twitter的Storm 0.9.0以前的版本中默認使用ZeroMQ作為數據流的傳輸（Storm從0.9版本開始同時支持ZeroMQ和Netty作為傳輸模塊）。
3.4ActiveMQ
ActiveMQ是Apache下的一個子項目。 類似於ZeroMQ，它能夠以代理人和點對點的技術實現隊列。同時類似於RabbitMQ，它少量代碼就可以高效地實現高級應用場景。
3.5Kafka/Jafka
Kafka是Apache下的一個子項目，是一個高性能跨語言分布式發布/訂閱消息隊列系統，而Jafka是在Kafka之上孵化而來的，即Kafka的一個升級版。具有以下特性：快速持久化，可以在O(1)的系統開銷下進行消息持久化；高吞吐，在一台普通的伺服器上既可以達到10W/s的吞吐速率；完全的分布式系統，Broker、Procer、Consumer都原生自動支持分布式，自動實現負載均衡；支持Hadoop數據並行載入，對於像Hadoop的一樣的日誌數據和離線分析系統，但又要求實時處理的限制，這是一個可行的解決方案。Kafka通過Hadoop的並行載入機制統一了在線和離線的消息處理。Apache Kafka相對於ActiveMQ是一個非常輕量級的消息系統，除了性能非常好之外，還是一個工作良好的分布式系統。
上圖中一個topic配置了3個partition。Partition1有兩個offset：0和1。Partition2有4個offset。Partition3有1個offset。副本的id和副本所在的機器的id恰好相同。
如果一個topic的副本數為3，那麼Kafka將在集群中為每個partition創建3個相同的副本。集群中的每個broker存儲一個或多個partition。多個procer和consumer可同時生產和消費數據。

Ⅷ 消息隊列(mq)是什麼

是生產者先將消息投遞一個叫隊列的容器中，然後再從這個容器中取出消息，最後再轉發給消費者。

消息隊列是 Microsoft 的消息處理技術，它在任何安裝 Microsoft Windows 的計算機組合中，為任何應用程序提供消息處理和消息隊列功能，無論這些計算機是否在同一個網路上或者是否同時聯機。

消息隊列網路是能夠相互間來回發送消息的任何一組計算機。網路中的不同計算機在確保消息順利處理的過程中扮演不同的角色。它們中有些提供路由信息以確定如何發送消息，有些保存整個網路的重要信息，而有些只是發送和接收消息。

消息隊列的類型介紹：

消息隊列目前主要有兩種類型：POSIX消息隊列以及系統V消息隊列，系統V消息隊列目前被大量使用。每個消息隊列都有一個隊列頭，用結構struct msg_queue來描述。隊列頭中包含了該消息隊列的大量信息。包括消息隊列鍵值、用戶ID、組ID、消息隊列中消息數目等等。

消息隊列就是一個消息的鏈表，可以把消息看作一個記錄，具有特定的格式以及特定的優先順序。對消息隊列有寫許可權的進程可以向消息隊列中按照一定的規則添加新消息；對消息隊列有讀許可權的進程則可以從消息隊列中讀走消息。消息隊列是隨內核持續的。

Ⅸ MQ一直提示登錄SqlServer資料庫失敗

應該和開機密碼沒關系
看看SQL的用戶名和密碼對不對
ConnStr = "Driver={SQL Server};Server= " & DBServerName & ";DataBase= " & DBName & ";UID= " & DBUid & ";Pwd= " & DBPwd

Ⅹ apache-activemq-5.8.0怎麼連接資料庫

安裝環境：linux rhe
activemq版本：5.8.0
1.從http://activemq.apache.org/download.html地址下載apache-activemq-5.8.0-bin.tar.gz包
2.解壓縮到指定的目錄
Shell代碼
tar zxvf apache-activemq-5.8.0-bin.tar.gz -C /usr/local
解壓縮後會在/usr/local下生成apache-activemq-5.8.0目錄，其中bin目錄下就是activeMQ的執行腳本存在的位置了。
3.如果啟動腳本無法執行，我們需要修改一下許可權

Shell代碼
cd /usr/local/apache-activemq-5.8.0/bin
chmod 775 activemq
4.設置activeMQ配置環境.activemqrc
Shell代碼
bin/activemq setup ~/.activemqrc
5.啟動activeMQ
在activemq主目錄鍵入如下命令：

Shell代碼
bin/activemq start
然後會看到控制台日誌輸出如下：

Shell代碼
INFO: Loading '/home/chenzhou/.activemqrc'
INFO: Using java '/usr/java/jdk1.6.0_03/bin/java'
INFO: Starting - inspect logfiles specified in logging.properties and log4j.properties to get details
INFO: pidfile created : '/usr/local/apache-activemq-5.8.0/data/activemq-localhost.localdomain.pid' (pid '18567')
我們也可以把日誌輸出到指定的日誌文件中

Shell代碼
bin/activemq start > /tmp/smlog 2>&1 &
然後日誌就輸出到/tmp/smlog文件中了
注意：官方文檔中標明了如果按上述的方式啟動後，如果我們把linux終端窗口關閉的話，則服務也會停止