activemq插件在eos中的开发

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

在进行activemq插件开发之前我们需要有以下几个操作：

<1>activemq-cpp的安装

activemq-cpp的编译依赖libuuid，apr,apr-util,apr-iconv,openssl几个库,目前库资源比较难找，附上自己使用的资源一份。下载地址：https://pan.baidu.com/s/1AdXdKsr1NwJRzkyD2gXjhg

1.1 安装apr

解压 tar -xf apr-1.4.6tar.gz

配置apr源码，并指定路径 ./configure --prefix=/usr/local/apr

安装 sudo make & make install

1.2安装apr-iconv

解压 tar -xf apr-iconv-1.2.1.tar

配置源码，并指定路径 ./configure --prefix=/usr/local/apr-iconv --with-apr=/usr/local/apr

安装 sudo make & make install

1.3安装apr-util

解压 tar -xf apr-util-1.4.1.tar.gz

配置源码，并指定路径 ./configure --prefix=/usr/local/apr-util --with-apr=/usr/local/apr

安装 sudo make & make install

1.4 安装activemq-cpp

解压 tar -xf activemq-cpp.tar.gz

配置源码，并指定路径  ./configure --prefix=/usr/local/activemq-cpp --with-apr=/usr/local/apr/ --with-openssl=/usr/local/openssl

安装 sudo make & make install

安装完成，不想编译源码的可以下载我整理好的动态库https://pan.baidu.com/s/1AymD_IlazGUPppjsXqwtsA

然后在

/etc/ld.so.conf中加入/usr/local/lib這一行

执行 /sbin/ldconfig -v     调用这些动态库就可以了

 

<2>eos中添加activemq插件

首先每个plugin都只初始化一次，其次因为都在app中注册过，大家互相是可以调用的

2.1添加所需头文件

除了需要向eos中做一些注册和订阅通知意以外

activemq的创建，存取数据都可参照activemq-cpp中example实例

#include <decaf/lang/Thread.h>
#include <decaf/lang/Runnable.h>
#include <decaf/util/concurrent/CountDownLatch.h>
#include <decaf/lang/Long.h>
#include <decaf/util/Date.h>
#include <activemq/core/ActiveMQConnectionFactory.h>
#include <activemq/util/Config.h>
#include <activemq/library/ActiveMQCPP.h>
#include <cms/Connection.h>
#include <cms/Session.h>
#include <cms/TextMessage.h>
#include <cms/BytesMessage.h>
#include <cms/MapMessage.h>
#include <cms/ExceptionListener.h>
#include <cms/MessageListener.h>

#include <decaf/lang/System.h>
#include <decaf/lang/Integer.h>
#include <cms/Destination.h>
#include <cms/MessageProducer.h>

using namespace activemq;　　　　//使用
using namespace activemq::core;
using namespace decaf;
using namespace decaf::lang;
using namespace decaf::util;
using namespace decaf::util::concurrent;
using namespace cms;
using namespace std;

 

class activemq_plugin : public plugin<activemq_plugin> {
public:
APPBASE_PLUGIN_REQUIRES((activemq_plugin))      //在application单例中注册当前插件类
activemq_plugin();
virtual ~activemq_plugin();

 

void plugin_initialize(const variables_map& options);　　   //初始化连接mq设置

void sendTxtMsg(const string& textMsg);　　　　　　　　//发送消息

}

　　

2.2线程共享数据加密

eos中大量采用boost中的算法，线程数据加锁采用pthread_mutex_t ，所有异步或同步线程中对内存数据同时存在读写的都得使用锁

pthread_mutex_t       m_mutex;　　　　　　//锁定义

pthread_mutex_init(&m_mutex, NULL);　　  //初始化锁

pthread_mutex_lock(&m_mutex);　　　　    //加锁
pthread_mutex_unlock(&m_mutex);　　　　//解锁

boost::thread m_thread(threadfunc);      　　//初始化线程

2.3eos每个plugin之间得互相访问

app().get_plugin<pluginA>()获取pluginA实例进行访问

<3>编译当前plugin

编写CMakeLists，make运行就完成了

file(GLOB HEADERS "include/eosio/activemq_plugin/*.hpp")
add_library( activemq_plugin
             activemq_plugin.cpp
             IniParser.cpp
             ${HEADERS} )

include_directories(
  ./
  /usr/local/include/activemq-cpp-3.10.0/
  /diskwork/work/activemq-cpp/activemq-cpp/src/main/
  /usr/local/apr/include/apr-1/
  /home/anlg/opt/boost/include/
  ./include/eosio/activemq_plugin/
  ${CMAKE_CURRENT_SOURCE_DIR}/../chain_plugin/include
)
link_directories(
  ./
  /usr/local/lib/
)
target_link_libraries( activemq_plugin  chain_plugin activemq-cpp appbase)
target_include_directories( activemq_plugin PUBLIC "${CMAKE_CURRENT_SOURCE_DIR}/include" 
"${CMAKE_CURRENT_SOURCE_DIR}/../chain_interface/include" 
"${CMAKE_CURRENT_SOURCE_DIR}/../../libraries/appbase/include" )