PrimetonESB

Appearance

03 ESB Studio使用指南/3.5 服务开发示例/3.5.7 CUST协议穿透/3.5.7.2 CUST自定义协议（以Primeton MQ为例）

本节讲述了CUST自定义协议（以Primeton MQ为例）穿透场景的创建过程，包括创建ESB项目、创建CUST协议相关的服务、部署、监控和运行。通过本节你将了解到如下内容：

  1. 如何创建CUST（Primeton MQ为例）协议穿透场景；
  2. 如何在Studio中测试运行开发的业务逻辑；
  3. 如何通过APIGateway Console部署Primeton MQ相关的Module；

穿透说明 ​

本穿透主要内容是：在APIGateway中以队列的形式接收一条来自Primeton MQ中队列q_receive中的TextMessage类型的消息，穿透APIGateway后，再发送到Primeton MQ中队列q_send。

创建ESB项目 ​

  1. 打开ESB Studio，在资源管理器中，点击右键，选择"创建->ESB项目"菜单项，创建ESB项目，如下图所示。

  1. 在项目创建向导中，填写项目的基本信息，如项目名称等，如下图所示。

  2. 点击【下一步】，设置项目的引用库，这里使用缺省设置，如下所示。

  3. 点击【完成】按钮，完成创建ESB项目。创建ESB项目后，资源管理器如下所示。

至此，ESB项目创建完毕。

创建公共Module ​

  1. 在资源管理器中，选中project，点击右键，选择"创建->公共Module"菜单项，创建公共Module，如下图所示。

创建CUST Transport ​

1.在资源管理器中，选择"Transport->创建"菜单项，选中"CUST类型Transport"，如下图所示。

2.修改Cust Transport 扩展配置信息，如下图所示。

  • 选择协议类型为: PMQ；
  • 扩展实现不做任何改变；

扩展属性配置如下：

属性标识属性名称属性值属性描述
属性标识属性名称属性值属性描述
brokerUrl服务器地址tcp://192.168.80.106:61616PMQ所在服务器tcp协议传输地址
username用户名adminMQ授权用户名
password密码adminMQ授权密码
messageModel消息模式P2P只能填写(发布订阅模型PUBSUB或点对点模型P2P),默认是P2P
destination目标q_receive队列或者主题名称
acknowledge消息应答方式AUTO_ACKNOWLEDGE自动应答: AUTO_ACKNOWLEDGE(默认)
客户端手动应答: CLIENT_ACKNOWLEDGE
重复消息应答: DUPS_OK_ACKNOWLEDGE

创建CUST Endpoint ​

1.在资源管理器中，选择"Endpoint->创建"菜单项，如下图所示。

2.修改Cust Endpoint 扩展配置信息，如下图所示。

  • 选择协议类型为: PMQ；
  • 扩展实现不做任何改变；

扩展属性配置如下：

属性标识属性名称属性值属性描述
brokerUrl服务器地址tcp://192.168.80.106:61616PMQ所在服务器tcp协议传输地址
username用户名adminMQ授权用户名
password密码adminMQ授权密码
messageModel消息模式P2P只能填写(发布订阅模型PUBSUB或点对点模型P2P),默认是P2P
destination目标q_send队列或者主题名称
acknowledge消息应答方式AUTO_ACKNOWLEDGE自动应答: AUTO_ACKNOWLEDGE(默认)
客户端手动应答: CLIENT_ACKNOWLEDGE
重复消息应答: DUPS_OK_ACKNOWLEDGE

创建业务Module ​

  1. 在资源管理器中，选中project，点击右键，选择"创建->业务Module"菜单项，创建业务Module，如下图所示。

  2. 在"业务Module"向导中，输入业务Module的相关信息，点击【完成】按钮，创建业务Module，如下图所示。

  3. 业务Module创建完毕，展开新创建的业务Module，如下所示。

创建CUST业务服务 ​

  1. 在资源管理器中，选中新建的业务Module"com.primeton.esb.project.restaurant"，点击右键，选择"创建->CUST业务服务"菜单项，创建CUST业务服务，如下图所示。

  2. 在"创建CUST业务服务"向导中，输入相应的信息，点击【完成】按钮，完成CUST业务服务的创建，如下图所示。

  3. 编辑生成的CUST业务服务的文件。如下所示。

    说明

  • 这里Endpoint选择刚才建立的名为：com.primeton.esb.project.common.endpoint 的 CUST Endpoint。
  • 这里协议类型选择：PMQ

创建CUST代理服务 ​

  1. 在资源管理器中，选中新建的业务Module代理服务项，点击右键，选择"创建->CUST代理服务"菜单项，创建CUST代理服务，如下图所示。

  2. 在"创建CUST代理服务"向导中，输入相应的信息，点击【完成】按钮，完成CUST代理服务的创建，如下图所示。

  3. 编辑生成的CUST代理服务的文件。如下所示。

    说明

  • 这里Transport选择刚才所创建的名为：com.primeton.esb.project.common.transport 的CUST Transport；
  • 这里关联服务类型选择：业务服务；
  • 这里服务名称选择刚才所创建的名为：com.primeton.esb.project.restaurant.bs.pmq.bizService的业务服务；
  • 这里协议类型选择：PMQ

点击保存按钮即可。

导出部署包 ​

  1. 在资源管理器中选中"project"项目，点击右键，点击"导出(O)..."菜单项，准备导出该项目，如下图所示。

  2. 在"导出"窗口中，选择"ESB->导出部署包"，点击【下一步】按钮，如下图所示。

  3. 在弹出的"导出部署包"窗口中选择这两个Module，并指定"保存位置"，将部署包命名为CUSTDemo.ecd，点击【下一步】按钮，如下图所示。

  4. 点击【完成】按钮，会弹出"提示"窗口，显示"导出成功"，表明已经成功导出这两个Module。

部署 ​

  1. 使用开发账户登录开发门户，单击左侧导航树上的 “模型部署 >新建部署” ，弹出 “新建部署” 界面。

  2. 单击“新建部署“，显示新建部署页面，选取文件。

  3. 勾选“服务器”，点击“部署”，将模型部署到服务器。

  4. 部署成功后会显示相应信息，如下图所示。

发送消息 ​

可编写Java方法来发送消息，java 方法如下： MsgSender .java

java
public class MsgSender {
    private static String url = "tcp://192.168.80.106:61616";
    private static String queueName = "q_receive";
    private static ConnectionFactory connectionFactory;
    private static Connection connection;
    private static Session session;
    private static Destination destination;
    private static MessageProducer producter;
    private static String text = "Hello , ESB";

    public static void main(String[] args) {
        init();
        sendMessage(text);
        close();
    }

    /**
     * 初始化
     */
    public static void init() {
        connectionFactory = new PMQConnectionFactory(url);
        try {
            connection = connectionFactory.createConnection();
            connection.start();
            session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
            destination = session.createQueue(queueName);
            producter = session.createProducer(destination);
        } catch (JMSException e) {
            e.printStackTrace();
        }
    }

    public static void close() {
        try {
            if (producter != null) {
                producter.close();
                producter = null;
            }
            if (session != null) {
                session.close();
                session = null;
            }
            if (connection != null) {
                connection.close();
                connection = null;
            }
        } catch (JMSException e) {
            e.printStackTrace();
        }
    }

    /**
     * 发送消息
     *
     * @param text 消息体
     */
    public static void sendMessage(String text) {
        try {
            Message message = session.createTextMessage(text);
            producter.send(message);
            System.out.println("发送消息 : " + text);
        } catch (JMSException e) {
            e.printStackTrace();
        }
    }
}

说明

结果 ​

使用运维账户登录运维门户，可通过governor的“监控统计>资源监控>队列监控“查看q_send队列中是否有一条"Hello , ESB"的消息，如果有，则说明成功地从队列q_receive接收到了一条消息，经过APIGateway后，再发送到了队列q_send中。

也可以设置ESB Server的日志等级(ESB Server安装路径/EOS/_srv/config/log4j-trace.xml)，这样消息成功穿透APIGateway并发送后，ESB Server将会在后台打如下印出信息。