大家好，又见面了，我是全栈君，今天给大家准备了Idea注册码。

　　在介绍ActiveMQ-CP之前，先介绍下CMS（C++ Messaging Service），CMS是C++程序与消息中间件进行通信的一种标准接口，可以通过CMS接口与类似ActiveMQ这样的消息中间件进行通信，它能够让C++程序与消息中间件之间的交互更加优雅和便捷。

　　ActiceMQ-CPP是CMS的一种实现，是一个能够与ActiveMQ进行通信的C++客户端库，ActiveMQ-CPP的架构设计能够支持可插拨的传输协议和消息封装格式，并且支持客户端容量，能够与ActiveMQ高效和便捷地进行通信，并且提供一系列跨平台的类Java API的特性，如多线程处理、I/O、sockets等。

1. ActiveMQ-CPP安装

　　ActiveMQ-CPP的编译依赖libuuid、apr、apr-util、apr-iconv、openssl几个库，如果需要跑CppUnit编写的test，还依赖于cppunit，因此在安装使用ActiveMQ-CPP之前，至少得安装libuuid、apr、apr-util、apr-iconv、openssl几个库。

1.1 安装libuuid

　　util-linux-ng在2.15.1版本以后，已经将libuuid作为一部分包含进来，因此，只需要安装util-linux-ng即可

（1）查询系统是否安装util-linux-ng

　　 ActiveMQ之ActiveMQ-CPP安装及测试

（2）若没有安装的话安装正常流程:

　　下载

　　解压

　　指定目录安装：./configure –without-ncurses –prefix=/usr/local/util-linux-ng

　　编译安装：make

　　sudo make install

1.2 安装apr

（1）下载apr：http://archive.apache.org/dist/apr/

（2）解压

　　tar -xf apr-1.4.8.tar.gz

（3）配置apr源码，并指定路径

　　./configure –prefix=/usr/local/apr

（4）编译安装

　　make

　　sudo make install

1.3 安装apr-iconv

（1）下载apr-iconv：http://archive.apache.org/dist/apr/

（2）解压

　　tar -xf apr-iconv-1.2.1.tar.gz

（3）配置源码，指定路径/usr/local/apr-iconv，并且指定apr的安装

　　./configure –prefix=/usr/local/apr-iconv –with-apr=/usr/local/apr

（4）编译安装

　　make

　　sudo make install

1.4 安装openssl

　　在安装openssl的过程中发现系统中已经安装了openssl，查找安装目录：

　　 ActiveMQ之ActiveMQ-CPP安装及测试

　　lib的安装目录很重要，后面安装ActiveMQ-CPP时需要

　　若系统中没有安装openssl，则按照正常流程安装

（1）下载：openssl-1.0.1e.tar.gz

（2）解压：tar -xf openssl-1.0.1e.tar.gz

（3）配置源码，并指定路径

　　./configure –prefix=/usr/local/openssl

（4）编译安装

　　make

　　sudo make install

1.5 安装ActiveMQ-CPP

（1）下载：http://activemq.apache.org/cms/activemq-cpp-381-release.html

（2）解压

　　tar -xf activemq-cpp-library-3.8.1-src.tar.gz

（3）配置源码，指定apr、openssl安装路径，以及ActiveMQ-CPP将要安装的路径

　　./configure –prefix=/usr/local/activemq-cpp –with-apr=/usr/local/apr/ –with-openssl=/usr/local/openssl

（4）编译安装

　　make

　　sudo make install

2. CMS应用程序接口

（1）ConnectionFactory

　　用户用来创建到JMS提供者的连接的被管对象。JMS客户通过可移植的接口访问连接，这样当下层的实现改变时，代码不需要进行修改。管理员

在JNDI名字空间中配置连接工厂，这样，JMS客户才能够查找到它们。根据消息类型的不同，用户将使用队列连接工厂，或者主题连接工厂。

#ifndef _CMS_CONNECTIONFACTORY_H_
#define _CMS_CONNECTIONFACTORY_H_

#include <cms/Config.h>
#include <cms/CMSException.h>

#include <string>

namespace cms {

    class Connection;
    class ExceptionListener;
    class MessageTransformer;

    class CMS_API ConnectionFactory {
    public:
        virtual ~ConnectionFactory();
        virtual cms::Connection* createConnection() = 0;
        virtual cms::Connection* createConnection(const std::string& username, const std::string& password) = 0;
        virtual cms::Connection* createConnection(const std::string& username, const std::string& password, const std::string& clientId) = 0;
        virtual void setExceptionListener(cms::ExceptionListener* listener) = 0;
        virtual cms::ExceptionListener* getExceptionListener() const = 0;
        virtual void setMessageTransformer(cms::MessageTransformer* transformer) = 0;
        virtual cms::MessageTransformer* getMessageTransformer() const = 0;

    public:
        static cms::ConnectionFactory* createCMSConnectionFactory(const std::string& brokerURI);

    };

}
#endif /*_CMS_CONNECTIONFACTORY_H_*/

（2）Connection

　　连接代表了应用程序和消息服务器之间的通信链路。在获得了连接工厂后，就可以创建一个与JMS提供者的连接。根据不同的连接类型，连接允许用户创建会话，以发送和接收队列和主题到目标。

#ifndef _CMS_CONNECTION_H_
#define _CMS_CONNECTION_H_

#include <cms/Config.h>
#include <cms/Startable.h>
#include <cms/Stoppable.h>
#include <cms/Closeable.h>
#include <cms/Session.h>
#include <cms/ConnectionMetaData.h>

namespace cms {
    class ExceptionListener;
    class MessageTransformer;

    class CMS_API Connection : public Startable, public Stoppable, public Closeable {
    public:

        virtual ~Connection();
        virtual void close() = 0;
        virtual const ConnectionMetaData* getMetaData() const = 0;
        virtual Session* createSession() = 0;
        virtual Session* createSession(Session::AcknowledgeMode ackMode) = 0;
        virtual std::string getClientID() const = 0;
        virtual void setClientID(const std::string& clientID) = 0;
        virtual ExceptionListener* getExceptionListener() const = 0;
        virtual void setExceptionListener(ExceptionListener* listener) = 0;
        virtual void setMessageTransformer(cms::MessageTransformer* transformer) = 0;
        virtual cms::MessageTransformer* getMessageTransformer() const = 0;
    };
}
#endif /*_CMS_CONNECTION_H_*/

（3）Session

　　表示一个单线程的上下文，用于发送和接收消息。由于会话是单线程的，所以消息是连续的，就是说消息是按照发送的顺序一个一个接收的。会话的好处是它支持事务。如果用户选择了事务支持，会话上下文将保存一组消息，直到事务被提交才发送这些消息。在提交事务之前，用户可以使用回滚操作取消这些消息。一个会话允许用户创建消息生产者来发送消息，创建消息消费者来接收消息。

namespace cms { class MessageTransformer; class CMS_API Session : public Closeable, public Startable, public Stoppable { public: enum AcknowledgeMode { AUTO_ACKNOWLEDGE, // 使用此确认模式，会话自动进行  DUPS_OK_ACKNOWLEDGE, CLIENT_ACKNOWLEDGE, SESSION_TRANSACTED, INDIVIDUAL_ACKNOWLEDGE }; public: virtual ~Session(); virtual void close() = 0; virtual void commit() = 0; virtual void rollback() = 0; virtual void recover() = 0; virtual MessageConsumer* createConsumer(const Destination* destination) = 0; virtual MessageConsumer* createConsumer(const Destination* destination, const std::string& selector) = 0; virtual MessageConsumer* createConsumer(const Destination* destination, const std::string& selector, bool noLocal) = 0; virtual MessageConsumer* createDurableConsumer(const Topic* destination, const std::string& name, const std::string& selector, bool noLocal = false) = 0; virtual MessageProducer* createProducer(const Destination* destination = NULL) = 0; virtual QueueBrowser* createBrowser(const cms::Queue* queue) = 0; virtual QueueBrowser* createBrowser(const cms::Queue* queue, const std::string& selector) = 0; virtual Queue* createQueue(const std::string& queueName) = 0; virtual Topic* createTopic(const std::string& topicName) = 0; virtual TemporaryQueue* createTemporaryQueue() = 0; virtual TemporaryTopic* createTemporaryTopic() = 0; virtual Message* createMessage() = 0; virtual BytesMessage* createBytesMessage() = 0; virtual BytesMessage* createBytesMessage(const unsigned char* bytes, int bytesSize) = 0; virtual StreamMessage* createStreamMessage() = 0; virtual TextMessage* createTextMessage() = 0; virtual TextMessage* createTextMessage(const std::string& text) = 0; virtual MapMessage* createMapMessage() = 0; virtual AcknowledgeMode getAcknowledgeMode() const = 0; virtual bool isTransacted() const = 0; virtual void unsubscribe(const std::string& name) = 0; virtual void setMessageTransformer(cms::MessageTransformer* transformer) = 0; virtual cms::MessageTransformer* getMessageTransformer() const = 0; }; } #endif /*_CMS_SESSION_H_*/

（4）Destination

　　目标是一个包装了消息目标标识符的被管对象，消息目标是指消息发布和接收的地点，或者是队列，或者是主题。JMS管理员创建这些对象，然后用户通过JNDI发现它们。和连接工厂一样，管理员可以创建两种类型的目标，点对点模型的队列，以及发布者／订阅者模型的主题。

namespace cms { class CMS_API Destination { public: enum DestinationType { TOPIC, QUEUE, TEMPORARY_TOPIC, TEMPORARY_QUEUE }; public: virtual ~Destination(); virtual DestinationType getDestinationType() const = 0; virtual cms::Destination* clone() const = 0; virtual void copy(const cms::Destination& source) = 0; virtual bool equals(const cms::Destination& other) const = 0; virtual const CMSProperties& getCMSProperties() const = 0; }; }

class CMS_API Queue : public Destination

class CMS_API Topic : public Destination

（5）MessageConsumer

　　由会话创建的对象，用于接收发送到目标的消息。消费者可以同步地（阻塞模式），或异步（非阻塞）接收队列和主题类型的消息。

namespace cms { class MessageTransformer; class CMS_API MessageConsumer : public Closeable, public Startable, public Stoppable { public: virtual ~MessageConsumer(); virtual Message* receive() = 0; virtual Message* receive(int millisecs) = 0; virtual Message* receiveNoWait() = 0; virtual void setMessageListener(MessageListener* listener) = 0; virtual MessageListener* getMessageListener() const = 0; virtual std::string getMessageSelector() const = 0; virtual void setMessageTransformer(cms::MessageTransformer* transformer) = 0; virtual cms::MessageTransformer* getMessageTransformer() const = 0; virtual void setMessageAvailableListener(cms::MessageAvailableListener* listener) = 0; virtual cms::MessageAvailableListener* getMessageAvailableListener() const = 0; }; }

（6）MessageProducer

　　由会话创建的对象，用于发送消息到目标。用户可以创建某个目标的发送者，也可以创建一个通用的发送者，在发送消息时指定目标。

namespace cms { class MessageTransformer; class CMS_API MessageProducer : public Closeable { public: virtual ~MessageProducer(); virtual void send(Message* message) = 0; virtual void send(Message* message, AsyncCallback* onComplete) = 0; virtual void send(Message* message, int deliveryMode, int priority, long long timeToLive) = 0; virtual void send(Message* message, int deliveryMode, int priority, long long timeToLive, AsyncCallback* onComplete) = 0; virtual void send(const Destination* destination, Message* message) = 0; virtual void send(const Destination* destination, Message* message, AsyncCallback* onComplete) = 0; virtual void send(const Destination* destination, Message* message, int deliveryMode, int priority, long long timeToLive) = 0; virtual void send(const Destination* destination, Message* message, int deliveryMode, int priority, long long timeToLive, AsyncCallback* onComplete) = 0; virtual void setDeliveryMode(int mode) = 0; virtual int getDeliveryMode() const = 0; virtual void setDisableMessageID(bool value) = 0; virtual bool getDisableMessageID() const = 0; virtual void setDisableMessageTimeStamp(bool value) = 0; virtual bool getDisableMessageTimeStamp() const = 0; virtual void setPriority(int priority) = 0; virtual int getPriority() const = 0; virtual void setTimeToLive(long long time) = 0; virtual long long getTimeToLive() const = 0; virtual void setMessageTransformer(cms::MessageTransformer* transformer) = 0; virtual cms::MessageTransformer* getMessageTransformer() const = 0; }; }

（7）Message

　　是在消费者和生产者之间传送的对象，也就是说从一个应用程序创送到另一个应用程序。一个消息有三个主要部分：消息头（必须）：包含用于识别和为消息寻找路由的操作设置。一组消息属性（可选）：包含额外的属性，支持其他提供者和用户的兼容。可以创建定制的字段和过滤器（消息选择器）。一个消息体（可选）：允许用户创建五种类型的消息（文本消息，映射消息，字节消息，流消息和对象消息）。消息接口非常灵活，并提供了许多方式来定制消息的内容。

namespace cms { class CMS_API Message { public: static const int DEFAULT_DELIVERY_MODE; static const int DEFAULT_MSG_PRIORITY; static const long long DEFAULT_TIME_TO_LIVE; enum ValueType { NULL_TYPE = 0, BOOLEAN_TYPE = 1, BYTE_TYPE = 2, CHAR_TYPE = 3, SHORT_TYPE = 4, INTEGER_TYPE = 5, LONG_TYPE = 6, DOUBLE_TYPE = 7, FLOAT_TYPE = 8, STRING_TYPE = 9, BYTE_ARRAY_TYPE = 10, UNKNOWN_TYPE = 11 }; public: virtual ~Message(); virtual Message* clone() const = 0; virtual void acknowledge() const = 0; virtual void clearBody() = 0; virtual void clearProperties() = 0; virtual std::vector<std::string> getPropertyNames() const = 0; virtual bool propertyExists(const std::string& name) const = 0; virtual ValueType getPropertyValueType(const std::string& name) const = 0; virtual bool getBooleanProperty(const std::string& name) const = 0; virtual unsigned char getByteProperty(const std::string& name) const = 0; virtual double getDoubleProperty(const std::string& name) const = 0; virtual float getFloatProperty(const std::string& name) const = 0; virtual int getIntProperty(const std::string& name) const = 0; virtual long long getLongProperty(const std::string& name) const = 0; virtual short getShortProperty(const std::string& name) const = 0; virtual std::string getStringProperty(const std::string& name) const = 0; virtual void setBooleanProperty(const std::string& name, bool value) = 0; virtual void setByteProperty(const std::string& name, unsigned char value) = 0; virtual void setDoubleProperty(const std::string& name, double value) = 0; virtual void setFloatProperty(const std::string& name, float value) = 0; virtual void setIntProperty(const std::string& name, int value) = 0; virtual void setLongProperty(const std::string& name, long long value) = 0; virtual void setShortProperty(const std::string& name, short value) = 0; virtual void setStringProperty(const std::string& name, const std::string& value) = 0; virtual std::string getCMSCorrelationID() const = 0; virtual void setCMSCorrelationID(const std::string& correlationId) = 0; virtual int getCMSDeliveryMode() const = 0; virtual void setCMSDeliveryMode(int mode) = 0; virtual const Destination* getCMSDestination() const = 0; virtual void setCMSDestination(const Destination* destination) = 0; virtual long long getCMSExpiration() const = 0; virtual void setCMSExpiration(long long expireTime) = 0; virtual std::string getCMSMessageID() const = 0; virtual void setCMSMessageID(const std::string& id) = 0; virtual int getCMSPriority() const = 0; virtual void setCMSPriority(int priority) = 0; virtual bool getCMSRedelivered() const = 0; virtual void setCMSRedelivered(bool redelivered) = 0; virtual const cms::Destination* getCMSReplyTo() const = 0; virtual void setCMSReplyTo(const cms::Destination* destination) = 0; virtual long long getCMSTimestamp() const = 0; virtual void setCMSTimestamp(long long timeStamp) = 0; virtual std::string getCMSType() const = 0; virtual void setCMSType(const std::string& type) = 0; }; }

发布者：全栈程序员-用户IM，转载请注明出处：https://javaforall.cn/120087.html原文链接：https://javaforall.cn

【正版授权，激活自己账号】： Jetbrains全家桶Ide使用，1年售后保障，每天仅需1毛

【官方授权正版激活】： 官方授权正版激活支持Jetbrains家族下所有IDE 使用个人JB账号...

ActiveMQ之ActiveMQ-CPP安装及测试

1. ActiveMQ-CPP安装

1.1 安装libuuid

1.2 安装apr

1.3 安装apr-iconv

1.4 安装openssl

1.5 安装ActiveMQ-CPP

2. CMS应用程序接口

（1）ConnectionFactory

（2）Connection

（3）Session

（4）Destination

（5）MessageConsumer

（6）MessageProducer

（7）Message

相关推荐

java遍历数组的各种方法_遍历数组的常用方法「建议收藏」

【图解算法】模板+变式——带你彻底搞懂字典树(Trie树)

Ubuntu安装Jdk环境

【Java-Set转List】

spring 笔记_spring实战pdf

Mysql 查看执行慢的sql语句「建议收藏」

发表回复