资讯详情

深入了解 · 专业解读

ABAP原生对接RabbitMQ实战：HTTP REST方案详解

发布时间：2026/9/16 4:25:29
ABAP原生对接RabbitMQ实战：HTTP REST方案详解 1. 项目概述为什么ABAP要主动“推”消息给RabbitMQ在SAP系统里我们习惯把数据“拉”出来——用RFC调外部接口、用IDoc做系统间集成、用BAPI封装业务逻辑。但现实里越来越多的场景要求SAP“主动发声”比如采购订单创建后立刻通知仓储系统启动上架流程财务凭证过账完成实时触发风控模型扫描异常交易生产工单状态变更同步推送至IoT平台控制设备启停。这些不是等别人来查而是SAP自己判断时机、打包信息、精准投递——这就是本项目的核心ABAP原生实现向RabbitMQ发送消息。关键词“ABAP”“SAP”“RabbitMQ”不是简单堆砌而是指向一个真实存在的技术断层SAP标准功能不直接支持AMQP协议ABAP NetWeaver也未内置RabbitMQ客户端库。这意味着你不能像Java里写connectionFactory.newConnection()那样一行代码搞定。必须靠ABAP底层能力HTTP/HTTPS、SOCKET、RFC搭桥再结合RabbitMQ的REST API或AMQP 0.9.1协议手动组包、签名、重试、监控。这不是炫技而是解决实际问题的刚需——我去年在一家汽车零部件厂落地时就靠这套方案把SAP PP模块的工单状态变更延迟从平均47秒压到800毫秒内产线看板实时性直接翻了6倍。适合谁参考如果你正面临以下任一场景这篇就是为你写的需要将SAP事件如MM01创建物料、VL01N生成交货单实时同步至微服务架构的后端系统现有ESB或PI/PO中间件已下线急需轻量级替代方案客户明确要求用RabbitMQ而非IBM MQ或Solman你手头只有ABAP开发权限无法在应用服务器上部署Java代理或Python脚本。别被“ABAP发送消息”这六个字骗了——它背后是协议选型博弈、错误容忍设计、性能压测实录以及踩过至少三次连接池泄漏后的血泪总结。接下来我会把整套方案拆成可复用的模块连调试时抓包看到的HTTP Header字段都给你标清楚。2. 整体架构设计与协议选型逻辑2.1 为什么放弃AMQP协议直连选择HTTP REST API刚接触这个需求时我第一反应是用ABAP SOCKET直连RabbitMQ的5672端口走AMQP 0.9.1协议。毕竟AMQP是RabbitMQ的原生语言理论上效率最高。但实测三天后彻底放弃原因很现实ABAP SOCKET的致命短板NetWeaver 7.5及之前版本的CL_HTTP_CLIENT不支持SSL/TLS双向认证mTLS而生产环境RabbitMQ集群强制开启mTLS。你用SOCKET_OPEN硬连会卡在SSL handshake failed且ABAP没有暴露SSL_CTX_set_verify这类底层控制权AMQP协议解析成本过高AMQP帧结构包含type/channel/size/payload四段二进制头ABAP处理二进制流需大量XSTRING转换和位运算一个basic.publish方法调用就要写200行代码且极易因字节序错位导致消息被RabbitMQ静默丢弃运维黑洞当消息堆积时AMQP连接需要手动管理prefetch_count和ack机制ABAP没有类似JavaChannel.basicQos()的封装全靠开发者手写ACK确认逻辑线上曾因此出现过37%的消息重复消费。转而采用RabbitMQ官方提供的HTTP REST API端口15672优势立现ABAP的CL_HTTP_CLIENT对HTTPS支持成熟证书校验、Basic Auth、JSON Payload全部开箱即用REST API返回标准HTTP状态码201 Created表示成功404表示Exchange不存在错误定位比AMQP的channel error直观十倍所有操作声明Exchange、创建Queue、绑定Routing Key、发布消息均通过HTTP POST/PUT完成无需维护长连接天然适配ABAP的短连接特性。提示REST API的性能损耗其实极小。我们用/api/exchanges/{vhost}/{exchange}/publish接口压测单节点RabbitMQ每秒稳定处理1200条消息远超SAP常规业务单据的峰值采购订单日均峰值约800单/小时。真正瓶颈在ABAP端的HTTP请求构造耗时而非网络传输。2.2 架构分层如何让ABAP代码具备生产级鲁棒性直接在报表程序里写cl_http_clientcreate_by_url( )发消息这是测试环境能跑通上线必跪的写法。真正的生产方案必须分三层层级模块核心职责关键设计点接入层ZCL_RMQ_SENDER对外统一入口提供send_message( )方法强制校验消息体JSON Schema自动添加timestamp和source_system字段协议层ZCL_RMQ_HTTP_ADAPTER封装HTTP通信细节实现连接池复用避免每次新建HTTP Client、自动重试3次指数退避、失败消息本地落库ZRMQ_LOG配置层ZRMQ_CONFIG全局参数管理RabbitMQ地址、虚拟主机、用户名密码、超时时间默认5000ms、重试间隔初始500ms这种分层不是为了炫技而是解决三个实际痛点配置热更新当RabbitMQ集群IP变更时只需改ZRMQ_CONFIG里的SERVER_URL所有调用方无感故障隔离若HTTP Adapter层因网络抖动失败接入层可捕获异常并降级为本地文件写入OPEN DATASET避免阻塞主业务审计溯源每条消息在ZRMQ_LOG表中记录MSG_IDUUID、PAYLOAD截断前200字符、STATUSSENT/FAILED/RETRIED、ERROR_TEXT审计时直接查表不用翻SM21日志。2.3 虚拟主机vhost与权限模型的ABAP映射RabbitMQ的vhost不是简单的路径前缀而是独立的权限沙箱。很多开发者卡在401 Unauthorized其实是ABAP传的Authorization: Basic xxxBase64编码里用户名拼错了vhost。正确格式是 错误写法用户名rmq_user密码123456 → 编码后发送 正确写法用户名rmq_user/prod注意符号和vhost名 DATA: lv_auth TYPE string. lv_auth |{ rmq_user/prod }:{ 123456 }|. CALL METHOD cl_http_utilityencode_base64 EXPORTING unencoded lv_auth RECEIVING encoded lv_auth_b64.为什么必须带/prod因为RabbitMQ的REST API鉴权逻辑是解析Basic Auth头提取username:password将username按分割前是登录名后是vhost若无则默认vhost为/检查该用户是否对指定vhost有configure/write权限。我们在ZRMQ_CONFIG里专门加了VHOST字段ABAP在构造Authorization头时自动拼接避免手工拼错。这个细节看似微小但上线前80%的连接失败都源于此。3. 核心细节解析与实操要点3.1 消息体JSON Schema的ABAP强校验RabbitMQ不校验消息内容但下游消费者会。如果ABAP发过去一个缺字段的JSON比如{order_id:1001}少了create_date下游Java服务反序列化直接抛JsonMappingException。所以ZCL_RMQ_SENDER在send_message( )入口必须做Schema校验。我们没引入第三方JSON Schema库ABAP里没有成熟的而是用ABAP内置的cl_fdt_json_sax_handler做轻量级校验METHOD validate_payload. DATA: lo_parser TYPE REF TO cl_fdt_json_sax_handler, lt_errors TYPE fdt_json_parse_error_tab. TRY. lo_parser cl_fdt_json_sax_handlercreate( ). lo_parser-parse( iv_json iv_payload it_errors lt_errors ). CATCH cx_fdt_json_parse_error INTO DATA(lx_err). RAISE EXCEPTION TYPE zcx_rmq_validation EXPORTING textid zcx_rmq_validationinvalid_json. ENDTRY. 检查必填字段order_id, create_date, source_system DATA: lo_json TYPE REF TO cl_fdt_json_sax_handler, lv_order_id TYPE string, lv_create_date TYPE string. lo_json cl_fdt_json_sax_handlercreate( ). lo_json-parse( iv_json iv_payload ). 从JSON中提取字段简化版实际用cl_fdt_json_sax_handler的回调 CALL FUNCTION ECATT_JSON_GET_VALUE EXPORTING json_string iv_payload path /order_id IMPORTING value lv_order_id. IF lv_order_id IS INITIAL. RAISE EXCEPTION TYPE zcx_rmq_validation EXPORTING textid zcx_rmq_validationmissing_field msgv1 order_id. ENDIF. ENDMETHOD.这个校验逻辑带来两个收益提前拦截错误在HTTP请求发出前就发现JSON格式或字段缺失避免无效网络调用标准化消息契约所有发往RabbitMQ的消息必须符合预定义Schema下游系统开发时可直接基于此生成DTO类。注意ECATT_JSON_GET_VALUE函数模块在NetWeaver 7.4及以上版本可用。若你的系统是7.02需改用cl_jsondeserialize( )反序列化为data对象再取值但性能略低每次反序列化耗时约3ms。3.2 HTTP连接池的ABAP手写实现ABAP没有现成的HTTP连接池组件但CL_HTTP_CLIENT对象本身支持复用。关键在于不要每次发消息都CREATE OBJECT新实例而是用静态属性缓存已创建的Client。ZCL_RMQ_HTTP_ADAPTER的连接池核心代码CLASS-DATA: go_pool TYPE REF TO zcl_rmq_http_pool. METHOD get_client. IF go_pool IS NOT BOUND. CREATE OBJECT go_pool. ENDIF. 从连接池获取可用Client rv_client go_pool-get_available_client( iv_server_url iv_server_url iv_timeout iv_timeout ). IF rv_client IS NOT BOUND. 池中无可用Client新建一个 cl_http_clientcreate_by_url( EXPORTING url iv_server_url ssl_id ANONYM IMPORTING client rv_client EXCEPTIONS argument_not_found 1 plugin_not_active 2 internal_error 3 OTHERS 4 ). ENDIF. ENDMETHOD. 连接池类ZCL_RMQ_HTTP_POOL CLASS zcl_rmq_http_pool DEFINITION. PUBLIC SECTION. METHODS: get_available_client IMPORTING iv_server_url TYPE string iv_timeout TYPE i RETURNING VALUE(rv_client) TYPE REF TO if_http_client, return_client IMPORTING iv_client TYPE REF TO if_http_client. PRIVATE SECTION. TYPES: BEGIN OF ty_client_item, client TYPE REF TO if_http_client, used_time TYPE timestampl, url TYPE string, END OF ty_client_item. TYPES: ty_client_table TYPE STANDARD TABLE OF ty_client_item WITH EMPTY KEY. CLASS-DATA: mt_clients TYPE ty_client_table. ENDCLASS.这个池子的关键设计点空闲超时回收每个Client记录used_timeget_available_client( )方法会遍历mt_clients剔除超过5分钟未使用的Client调用client-close( )URL隔离不同RabbitMQ集群如DEV/PROD的URL分开缓存避免混用线程安全ABAP中静态属性天然线程安全每个对话进程有独立内存空间无需额外锁机制。实测效果未用连接池时1000次消息发送耗时23.6秒每次新建Client约22ms启用后降至11.2秒性能提升52.5%。3.3 失败消息的本地持久化与重试策略网络抖动、RabbitMQ临时不可用、HTTP 503 Service Unavailable——这些在生产环境必然发生。我们的策略是失败消息先落库再由后台作业定时重发。ZRMQ_LOG表结构设计字段类型说明MSG_IDCHAR(32)UUID主键PAYLOADCHAR(1000)JSON消息体截断存储避免大字段影响性能EXCHANGE_NAMECHAR(50)目标Exchange名ROUTING_KEYCHAR(100)Routing KeySTATUSCHAR(10)PENDING/SENT/FAILED/RETRIEDRETRY_COUNTINT2当前重试次数最大3次LAST_ERRORCHAR(200)最近一次错误文本CREATED_ATTIMESTAMP创建时间UPDATED_ATTIMESTAMP更新时间重试作业ZRMQ_RETRY_JOB逻辑 查找待重试消息STATUS PENDING 或 FAILED且RETRY_COUNT 3 SELECT * FROM zrmq_log INTO TABLE lt_pending WHERE status IN (PENDING, FAILED) AND retry_count 3 AND created_at sy-datum - 1. 只重试1天内的消息避免积压 LOOP AT lt_pending ASSIGNING FIELD-SYMBOL(ls_msg). TRY. 调用发送逻辑 zcl_rmq_sendersend_message( iv_exchange_name ls_msg-exchange_name iv_routing_key ls_msg-routing_key iv_payload ls_msg-payload ). 发送成功更新状态 ls_msg-status SENT. ls_msg-updated_at sy-datum. MODIFY zrmq_log FROM ls_msg. CATCH zcx_rmq_send_error INTO DATA(lx_err). 发送失败更新重试次数和错误信息 ls_msg-retry_count ls_msg-retry_count 1. ls_msg-last_error lx_err-get_text( ). ls_msg-status FAILED. ls_msg-updated_at sy-datum. MODIFY zrmq_log FROM ls_msg. ENDTRY. ENDLOOP.这个设计解决了三个关键问题不阻塞主流程业务程序调用send_message( )时若HTTP失败立即返回异常由后台作业异步兜底可控重试RETRY_COUNT限制为3次避免死循环created_at sy-datum - 1确保只处理近期消息历史积压消息需人工介入可追溯每条失败消息在ZRMQ_LOG中留痕LAST_ERROR字段直接存ABAP异常文本排查时不用查ST22。4. 实操过程与核心环节实现4.1 RabbitMQ服务端配置从零开始搭建验证环境别跳过这步很多ABAP开发者卡在第一步不是代码问题而是RabbitMQ没配对。以下是我在SAP DEV系统旁部署的最小可行环境Docker Compose# docker-compose.yml version: 3.8 services: rabbitmq: image: rabbitmq:3.12-management container_name: rmq-dev environment: RABBITMQ_DEFAULT_USER: rmq_user RABBITMQ_DEFAULT_PASS: rmq_pass RABBITMQ_DEFAULT_VHOST: /dev ports: - 5672:5672 # AMQP端口 - 15672:15672 # Management UI端口 - 25672:25672 # Erlang distribution端口 volumes: - ./data:/var/lib/rabbitmq启动后访问http://localhost:15672用rmq_user/rmq_pass登录。重点配置三处创建vhostAdmin→Virtual Hosts→Add a virtual host→ 输入/dev→Add virtual host分配用户权限Admin→Users→rmq_user→Set permission→Virtual host选/dev→Configure regexp填^.*$→Write regexp填^.*$→Read regexp填^.*$→Set permission声明ExchangeExchanges→Add Exchange→Name填sap_orders→Type选topic→Add Exchange。提示ABAP代码里/devvhost必须和这里完全一致包括开头的/。曾有同事漏掉/ABAP发消息时HTTP返回404查了两天才发现是vhost名不匹配。4.2 ABAP端完整发送代码从配置到调用现在把所有模块串起来给出一个可直接运行的完整示例。假设我们要在MM01创建物料后向RabbitMQ发送物料主数据变更消息。第一步配置ZRMQ_CONFIG事务码SE11建表ZRMQ_CONFIG字段CLIENTCLNT客户端号VHOSTCHAR50/devSERVER_URLCHAR200https://192.168.1.100:15672/api/USERNAMECHAR50rmq_user/devPASSWORDCHAR50rmq_passTIMEOUTINT45000第二步编写发送逻辑ZMM_RMQ_MATERIAL_SENDREPORT zmm_rmq_material_send. PARAMETERS: p_matnr TYPE mara-matnr OBLIGATORY. START-OF-SELECTION. DATA: lo_sender TYPE REF TO zcl_rmq_sender, lv_payload TYPE string, lv_error TYPE string. 构造消息体 lv_payload |{ | matnr: { p_matnr }, | mtart: FERT, | ersda: { sy-datum }, | source_system: SAP_MM, | timestamp: { sy-uzeit } |}|. TRY. 初始化发送器 CREATE OBJECT lo_sender. 发送消息 lo_sender-send_message( EXPORTING iv_exchange_name sap_orders iv_routing_key material.created iv_payload lv_payload ). WRITE: / 消息发送成功. CATCH zcx_rmq_send_error INTO DATA(lx_err). lv_error lx_err-get_text( ). WRITE: / 发送失败, lv_error. ENDTRY.第三步ZCL_RMQ_SENDER核心方法CLASS zcl_rmq_sender DEFINITION. PUBLIC SECTION. METHODS: send_message IMPORTING iv_exchange_name TYPE string iv_routing_key TYPE string iv_payload TYPE string RAISING zcx_rmq_send_error. ENDCLASS. CLASS zcl_rmq_sender IMPLEMENTATION. METHOD send_message. 1. 校验消息体 me-validate_payload( iv_payload ). 2. 获取配置 DATA: ls_config TYPE zrmq_config. SELECT SINGLE * FROM zrmq_config INTO ls_config WHERE client sy-mandt. IF sy-subrc 0. RAISE EXCEPTION TYPE zcx_rmq_send_error EXPORTING textid zcx_rmq_send_errorconfig_missing. ENDIF. 3. 构造HTTP请求URL DATA: lv_url TYPE string. lv_url |{ ls_config-server_url }exchanges/{ ls_config-vhost }/{ iv_exchange_name }/publish|. 4. 构造Authorization头 DATA: lv_auth TYPE string. lv_auth |{ ls_config-username }:{ ls_config-password }|. CALL METHOD cl_http_utilityencode_base64 EXPORTING unencoded lv_auth RECEIVING encoded lv_auth_b64. 5. 构造JSON BodyRabbitMQ REST API要求 DATA: lv_body TYPE string. lv_body |{ | properties: {}, | routing_key: { iv_routing_key }, | payload: { iv_payload }, | payload_encoding: string |}|. 6. 发送HTTP POST DATA: lo_client TYPE REF TO if_http_client. TRY. cl_http_clientcreate_by_url( EXPORTING url lv_url ssl_id ANONYM IMPORTING client lo_client EXCEPTIONS argument_not_found 1 plugin_not_active 2 internal_error 3 OTHERS 4 ). IF sy-subrc 0. RAISE EXCEPTION TYPE zcx_rmq_send_error EXPORTING textid zcx_rmq_send_errorhttp_client_failed. ENDIF. lo_client-request-set_method( if_http_requestco_request_method_post ). lo_client-request-set_header_field( name Authorization value |Basic { lv_auth_b64 }| ). lo_client-request-set_header_field( name Content-Type value application/json ). lo_client-request-set_cdata( lv_body ). lo_client-send( ). lo_client-receive( ). 7. 检查HTTP响应 DATA: lv_status TYPE i, lv_status_text TYPE string. lo_client-response-get_status( IMPORTING code lv_status reason lv_status_text ). IF lv_status 201. RAISE EXCEPTION TYPE zcx_rmq_send_error EXPORTING textid zcx_rmq_send_errorhttp_error msgv1 |HTTP { lv_status } { lv_status_text }|. ENDIF. CATCH cx_root INTO DATA(lx_root). 记录到ZRMQ_LOG并重试 INSERT zrmq_log FROM VALUE #( msg_id cl_system_uuidcreate_uuid_x16( ) payload iv_payload exchange_name iv_exchange_name routing_key iv_routing_key status PENDING retry_count 0 last_error lx_root-get_text( ) created_at sy-datum updated_at sy-datum ). RAISE EXCEPTION TYPE zcx_rmq_send_error EXPORTING textid zcx_rmq_send_errorpersist_failed. ENDTRY. ENDMETHOD. ENDCLASS.这段代码已通过SAP NetWeaver 7.52 SP04实测。关键点payload_encoding必须设为string若设为base64RabbitMQ会尝试解码导致JSON乱码properties字段留空{}即可不需要填delivery_mode等RabbitMQ REST API会自动设为2持久化lo_client-send( )和lo_client-receive( )必须成对出现否则HTTP连接不释放连接池会枯竭。4.3 生产环境压测与性能调优实录在客户现场我们用ZMM_RMQ_MATERIAL_SEND模拟高并发场景测试工具ABAP Unit Test cl_abap_unit_assert循环调用1000次硬件SAP应用服务器4核8GRabbitMQ单节点4核16GSSD结果并发数平均耗时ms失败率CPU占用101280%12%501420%28%1001890.3%45%2003122.1%76%失败率飙升的根因是ABAP HTTP Client的默认超时60秒太长200并发时大量请求排队等待DNS解析。优化措施缩短超时在ZRMQ_CONFIG中将TIMEOUT从5000ms改为2000ms失败率降至0.2%DNS预解析在ZCL_RMQ_HTTP_ADAPTER初始化时用cl_http_clientcreate_by_url( )预连一次RabbitMQ触发DNS缓存连接池扩容将连接池最大Client数从默认5个调至20个100并发时耗时稳定在150ms内。最终上线参数TIMEOUT 2000MAX_POOL_SIZE 20RETRY_COUNT 3RETRY_INTERVAL 1000首次重试间隔1秒后续指数增长5. 常见问题与排查技巧实录5.1 HTTP 401 Unauthorized90%的坑都在这里这是最常遇到的错误表面是认证失败根源有四个现象根本原因排查命令/步骤解决方案401 Unauthorized用户名未带vhost后缀在ZRMQ_CONFIG中检查USERNAME字段是否为rmq_user/dev修改配置确保/vhost格式401 UnauthorizedRabbitMQ用户无vhost权限登录Management UI →Admin→Users→rmq_user→Permissions→ 检查/dev行的Configure/Write列是否为^.*$点击Set permission填入正则^.*$401 Unauthorized密码含特殊字符未URL编码若密码为pssw0rd!Base64编码后可能含或/某些ABAP版本会截断密码避免使用/或改用cl_http_utilityescape_url( )编码401 UnauthorizedSSL证书不信任ABAP客户端拒绝自签名证书在STRUST中导入RabbitMQ的CA证书或临时设ssl_id ANONYM仅测试实操心得写个快速诊断程序ZRMQ_DIAGNOSE输入vhost和用户名自动调用/api/users/{user}接口查权限比人工点UI快10倍。5.2 HTTP 404 Not FoundExchange或vhost不存在错误日志里看到404别急着改代码先确认服务端状态检查vhost是否存在curl -u rmq_user:rmq_pass https://192.168.1.100:15672/api/vhosts返回JSON中必须有/dev检查Exchange是否存在curl -u rmq_user:rmq_pass https://192.168.1.100:15672/api/exchanges/%2Fdev%2F是/的URL编码返回中必须有name:sap_orders检查URL拼写ABAP中lv_url变量打印出来确认是https://.../api/exchanges/%2Fdev/sap_orders/publish不是/api/exchange/...少s或/api/exchanges/dev/...漏%2F。5.3 消息发送成功但消费者收不到Routing Key陷阱RabbitMQ的topic Exchange对Routing Key敏感。常见错误大小写混淆ABAP发routing_key Material.Created但消费者监听material.createdtopic Exchange默认区分大小写通配符误用消费者绑定material.*但ABAP发material.created.v2*只匹配单级#才匹配多级JSON字段名冲突消息体里routing_key:material.created但RabbitMQ REST API的routing_key字段是HTTP Body的一部分不是消息内容消费者收到的是纯JSON不含Routing Key。解决方案在ZCL_RMQ_SENDER中加日志打印实际发送的iv_routing_key并与消费者代码的绑定Key严格比对。5.4 连接池耗尽ABAP内存泄漏预警现象运行几小时后SM50里看到大量CL_HTTP_CLIENT对象未释放内存占用持续上涨。根因是cl_http_clientcreate_by_url( )创建的对象未显式free( )。修复代码METHOD return_client. 重置Client状态 IF iv_client IS BOUND. iv_client-close( ). 关闭连接 iv_client-free( ). 释放对象 ENDIF. ENDMETHOD.并在ZCL_RMQ_HTTP_ADAPTER的send_message( )末尾调用 发送完成后归还Client me-return_client( iv_client lo_client ).5.5 生产环境监控如何一眼看出消息积压光靠ZRMQ_LOG表不够需结合RabbitMQ自身指标。我们在ZRMQ_MONITOR报表中集成ABAP侧SELECT COUNT(*) FROM zrmq_log WHERE status PENDINGRabbitMQ侧调用/api/queues/%2Fdev/sap_orders接口解析messages_ready字段阈值告警当PENDING 100或messages_ready 500时邮件通知运维。这个监控在客户上线首周就捕获到一次RabbitMQ磁盘不足disk_free_limit触发避免了消息丢失。6. 扩展可能性与经验延伸6.1 从“发送”到“双向通信”ABAP消费RabbitMQ消息本项目聚焦发送但实际中常需ABAP作为消费者。方案有两种轮询模式ABAP后台作业定时调用/api/queues/{vhost}/{queue}/getcount1取一条acktrue确认。优点是ABAP可控缺点是实时性差轮询间隔最低1秒Webhook模式RabbitMQ插件rabbitmq_web_stomp启用STOMP协议ABAP用CL_HTTP_CLIENT连接WebSocket需NetWeaver 7.52实现服务端推送。实时性达毫秒级但配置复杂。我推荐轮询模式因它不依赖新协议所有NetWeaver版本都支持且ZRMQ_LOG表可复用为消费日志。6.2 与SAP标准功能的深度集成别只在报表里调用要嵌入业务流程增强MM01在EXIT_SAPMM01E_001中调用zcl_rmq_sendersend_message( )物料创建即发消息增强VL01N在USEREXIT_SAVE_DOCUMENT_PREPARE中发交货单消息增强F-02在BADI_FI_DOCUMENT_CHECK中发财务凭证消息。关键点增强点必须在COMMIT WORK之后用CALL FUNCTION BAPI_TRANSACTION_COMMIT否则事务回滚时消息已发造成数据不一致。6.3 安全加固生产环境必须做的三件事密码加密存储ZRMQ_CONFIG的PASSWORD字段用cl_sec_sso2encrypt_password( )加密读取时解密IP白名单在RabbitMQ的advanced.config中配置{tcp_listeners, [{127.0.0.1, 5672}]}只允许本地ABAP访问对外暴露的1

相关新闻