如何使用REST API或Java SDK创建IBM MQ主题

IBM MQ的Java客户端可通过PCF（Programmable Command Format）命令执行管理操作，包括创建Topic，具体实现如下：

1. 引入依赖
   确保项目包含IBM MQ Java客户端依赖，Maven坐标示例：

<dependency>
    <groupId>com.ibm.mq</groupId>
    <artifactId>com.ibm.mq.allclient</artifactId>
    <version>9.3.3.0</version> <!-- 使用最新稳定版本 -->
</dependency>

2. 编写创建Topic的代码
   通过PCFMessageAgent连接队列管理器，发送MQCMD_CREATE_TOPIC命令完成创建：

import com.ibm.mq.MQException;
import com.ibm.mq.pcf.PCFMessage;
import com.ibm.mq.pcf.PCFMessageAgent;

public class MQTopicCreator {
    public static void main(String[] args) {
        String qmgrName = "YOUR_QMGR_NAME";
        String topicName = "MY.TOPIC";
        String topicString = "MY/TOPIC/STRING";

        try (PCFMessageAgent agent = new PCFMessageAgent(qmgrName)) {
            PCFMessage request = new PCFMessage(com.ibm.mq.constants.MQConstants.MQCMD_CREATE_TOPIC);
            
            // 设置Topic核心属性
            request.addParameter(com.ibm.mq.constants.MQConstants.MQCA_TOPIC_NAME, topicName);
            request.addParameter(com.ibm.mq.constants.MQConstants.MQCA_TOPIC_STRING, topicString);
            request.addParameter(com.ibm.mq.constants.MQConstants.MQCA_TOPIC_DESC, "Created via Java SDK");
            request.addParameter(com.ibm.mq.constants.MQConstants.MQDEF_PERSISTENCE, com.ibm.mq.constants.MQConstants.MQPER_PERSISTENT);

            PCFMessage[] responses = agent.send(request);
            
            // 校验创建结果
            for (PCFMessage response : responses) {
                int completionCode = response.getIntParameterValue(com.ibm.mq.constants.MQConstants.MQIACF_COMPLETION_CODE);
                if (completionCode == com.ibm.mq.constants.MQConstants.MQCC_OK) {
                    System.out.println("Topic " + topicName + " created successfully");
                } else {
                    int reasonCode = response.getIntParameterValue(com.ibm.mq.constants.MQConstants.MQIACF_REASON_CODE);
                    System.err.println("Create failed. Reason code: " + reasonCode);
                }
            }
        } catch (MQException e) {
            System.err.println("MQ Exception: " + e.getMessage());
            e.printStackTrace();
        }
    }
}

注意：运行代码的用户需具备队列管理器的管理权限（如mqm组权限），否则会因权限不足失败。

IBM MQ提供REST API（需提前启用），可通过HTTP请求创建Topic，步骤如下：

1. 启用MQ REST服务
   通过runmqsc命令配置队列管理器，启用REST服务：

ALTER QMGR RESTENABLED(YES)
REFRESH SECURITY TYPE(CONNAUTH)

（注：CHLAUTH配置需根据实际安全需求调整，示例中未强制开启）

2. 发送POST请求创建Topic
   调用/admin/qmgr/{qmgrName}/topics端点完成创建：

• 请求URL：http://<mq-rest-host>:<port>/ibmmq/rest/v1/admin/qmgr/{qmgrName}/topics
• 请求方法：POST
• 请求头：
  • Content-Type: application/json
  • Authorization: Basic <base64编码的用户名:密码>
• 请求体（JSON格式）：

{
  "name": "MY.TOPIC",
  "topicString": "MY/TOPIC/STRING",
  "description": "Created via REST API",
  "persistence": "PERSISTENT"
}

3. 响应示例
   成功创建时返回201 Created状态码，响应体示例：

{
  "name": "MY.TOPIC",
  "topicString": "MY/TOPIC/STRING",
  "description": "Created via REST API",
  "persistence": "PERSISTENT",
  "created": "2024-05-20T10:30:00Z"
}

注意：REST API默认端口为1414（非SSL）或9443（SSL），需根据实际配置调整；请求用户需具备队列管理器管理权限。

内容的提问来源于stack exchange，提问作者Shiva Subramaniam