RabbitMQ - 连接RabbitMQ服务

RabbitMQ 是一个实现了高级消息队列协议（AMQP）的开源消息中间，由Pivotal旗下的SpringSource维护（https://www.rabbitmq.com/），RabbitMQ Connector为上层应用场景提供统一的RabbitMQ服务访问和管理。

主要功能

支持RabbitMQ 3.8.5版本的消息队列服务
提供CCAPI封装，方便开发者使用
提供RabbitMQ Producer(向RabbitMQ发送消息)的流程编排服务(Service Task)
支持CC环境变量
支持SLA服务质量监控和告警通知，提供全局requestId
提供访问日志开关

特别说明

使用该应用要求AWS PaaS平台许可支持CC服务
使用该应用要求AWS PaaS平台版本不低于6.4.1

1.配置

基本信息

配置RabbitMQ适配器。

项	说明
名称	RabbitMQ适配器的名称
服务器地址	格式：IP1:PORT1,IP2:PORT2，支持@公式，如@env(xxx)可获取环境中相应变量值
虚拟服务地址	支持@公式，如@env(xxx)可获取环境中相应变量值
用户名	用户名，支持@公式，如@env(xxx)可获取环境中相应变量值
密码	密码，支持@公式，如@env(xxx)可获取环境中相应变量值
描述	适配器描述信息

扩展属性

扩展属性说明详见：https://rabbitmq.github.io/rabbitmq-java-client/api/current/com/rabbitmq/client/ConnectionFactoryConfigurator.html

2.调用

由开发者在Java代码中调用RabbitMQ服务。

获取模型ID

在CC连接列表中可获取适配器模型ID。

API代码示例

在访问前，我们假设已创建了一个CC RabbitMQ技术适配器，其分配的模型Id为00000000

import com.actionsoft.bpms.bpmn.engine.core.delegate.ProcessExecutionContext;
import com.actionsoft.bpms.bpmn.engine.listener.ExecuteListener;
import com.actionsoft.sdk.local.SDK;
import com.actionsoft.sdk.local.api.cc.RabbitmqAPI;
import com.rabbitmq.client.DeliverCallback;

import java.io.IOException;
import java.util.concurrent.TimeoutException;

/**
 * 需要在开发环境中引入AWS PaaS平台以下目录下所有jar包：
 * bin/lib目录下
 * bin/jdbc目录下
 * apps/install/com.actionsoft.apps.cc.connector.rabbitmq/lib目录下
 */
public class RabbitMQAPITest extends ExecuteListener {
    @Override
    public void execute(ProcessExecutionContext processExecutionContext) throws Exception {

        //获得一个RabbitMQ对象
        RabbitmqAPI rt = SDK.getCCAPI().getRabbitmqAPI("00000000");
        try {
            rt.publish("xxx", "hello".getBytes());   //发送消息
        } catch (IOException | TimeoutException e1) {
            e1.printStackTrace();
        }

        DeliverCallback deliverCallback1 = (consumerTag, delivery) -> {
            String message = new String(delivery.getBody(), "UTF-8");
            System.out.println("deliverCallback1 Received '" + message + "'" + delivery.getEnvelope().getDeliveryTag());
        };
        DeliverCallback deliverCallback2 = (consumerTag, delivery) -> {
            String message = new String(delivery.getBody(), "UTF-8");
            System.out.println("deliverCallback2 Received '" + message + "'" + delivery.getEnvelope().getDeliveryTag());
        };

        try {
            rt.consume("xxx", RabbitmqAPI.queue, deliverCallback1);  //设置消费者监听
        } catch (IOException | TimeoutException e) {
            e.printStackTrace();
        }

        // ......
    }
}

RabbitMQAPI JavaDOC https://docs.awspaas.com/api/aws-api-javadoc/com/actionsoft/sdk/local/api/cc/RabbitmqAPI.html

3. 流程编排服务

该应用提供RabbitMQ Producer(向RabbitMQ发送消息)的流程编排服务(Service Task)。进行连接服务发布页签可进行查看。

调用

操作步骤：

创建一个流程模型
拖动一个系统任务至画布
配置系统任务，服务类型为流程服务，选择该流程服务，配置相关信息
完成流程模型的正确设计，创建流程实例，到任务到达系统任务时，即可发送消息

4.日志

当连接器开启记录访问请求到审计日志和记录返回结果到文件日志开关后，调用RabbitmqAPI相关方法时，可记录日志，具体哪些方法会记录日志，请参见javadoc RabbitmqAPI说明。

记录访问请求到审计日志

开启后，将访问请求记录到审计日志，该日志存储在AWS PaaS平台SYS_AUDIT_LOG表中，可在日志页进行查看。

记录返回结果到文件日志

开启后，将请求数据和返回结果记录到文件日志，该日志存储在AWS PaaS平台%AWS_HOME%/logs/目录下，默认每个文件日志最大为20M，最多存储20个文件，超出将自动清除最早日期文件。 log文件个数及单文件最大值可在%AWS_HOME%/bin/conf/aws-log4j.xml文件中配置。