IT干货网

PI-Custom adapter module

qq123 2022年03月09日 SAP 158 0

PI自定义适配器模块

1.开发EJB项目

1.1Eclipse创建EJB项目

参考:IT虾米网

1.2类方法ChgRestFormat.java

  1 package com.sap.pi.geely.custom; 
  2  
  3 import java.io.ByteArrayInputStream; 
  4 import java.io.ByteArrayOutputStream; 
  5 import java.io.IOException; 
  6 import java.io.InputStream; 
  7 import java.rmi.RemoteException; 
  8 import java.security.KeyStore; 
  9 import java.security.KeyStoreException; 
 10 import javax.annotation.PostConstruct; 
 11 import javax.annotation.PreDestroy; 
 12 import javax.ejb.Local; 
 13 import javax.ejb.LocalHome; 
 14 import javax.ejb.Remote; 
 15 import javax.ejb.RemoteHome; 
 16 import javax.ejb.Stateless; 
 17 import javax.naming.InitialContext; 
 18 import javax.naming.NamingException; 
 19 import com.sap.aii.af.lib.mp.module.Module; 
 20 import com.sap.aii.af.lib.mp.module.ModuleContext; 
 21 import com.sap.aii.af.lib.mp.module.ModuleData; 
 22 import com.sap.aii.af.lib.mp.module.ModuleException; 
 23 import com.sap.aii.af.lib.mp.module.ModuleHome; 
 24 import com.sap.aii.af.lib.mp.module.ModuleLocal; 
 25 import com.sap.aii.af.lib.mp.module.ModuleLocalHome; 
 26 import com.sap.aii.af.lib.mp.module.ModuleRemote; 
 27 import com.sap.engine.interfaces.messaging.api.Message; 
 28 import com.sap.engine.interfaces.messaging.api.MessageKey; 
 29 import com.sap.engine.interfaces.messaging.api.PublicAPIAccessFactory; 
 30 import com.sap.engine.interfaces.messaging.api.auditlog.AuditAccess; 
 31 import com.sap.engine.interfaces.messaging.api.auditlog.AuditLogStatus; 
 32 import com.sap.engine.interfaces.messaging.api.exception.InvalidParamException; 
 33  
 34 /** 
 35  * Session Bean implementation class ChgRestFormat 
 36  */ 
 37 @Stateless(name = "ChgRestFormatBean") 
 38 @Local(value = { ModuleLocal.class }) 
 39 @Remote(value = { ModuleRemote.class }) 
 40 @LocalHome(value = ModuleLocalHome.class) 
 41 @RemoteHome(value = ModuleHome.class) 
 42 public class ChgRestFormat implements Module{ 
 43     /** 
 44      * Default constructor.  
 45      */     
 46     @Override 
 47     public ModuleData process(ModuleContext moduleContext, ModuleData inputModuleData) throws ModuleException { 
 48         // TODO Auto-generated method stub 
 49         AuditAccess audit     = null; 
 50         Message     msg        = null; 
 51         MessageKey     msgKey    = null; 
 52         byte[]         content    = null; 
 53         String        contstr    = null; 
 54         String         fldNode    = null; 
 55         String        msgType = null; 
 56         String        dataFormat    = null; 
 57         String        nameSpace    = null; 
 58         String        fullpload    = null; 
 59          
 60         try { 
 61  
 62             //Load message: 
 63             msg = (Message) inputModuleData.getPrincipalData(); 
 64             msgKey = new MessageKey(msg.getMessageId(),msg.getMessageDirection());    //msg.getMessageKey(); 
 65              
 66             audit = PublicAPIAccessFactory.getPublicAPIAccess().getAuditAccess(); 
 67             audit.addAuditLogEntry(msgKey, AuditLogStatus.SUCCESS, 
 68                     "Edit by rico | Custom-Java-Adapter-Module (localejbs/ChgRestFormat)"); 
 69  
 70             //Loads the contents of the incoming message:  
 71             content = msg.getDocument().getContent(); 
 72             contstr = new String(msg.getDocument().getContent()); 
 73             audit.addAuditLogEntry(msgKey, AuditLogStatus.SUCCESS, 
 74                     "Edit by rico | ChgRestFormat | Document-Content:" + contstr); 
 75  
 76             fullpload = new String(msg.getMainPayload().getContent()); 
 77             audit.addAuditLogEntry(msgKey, AuditLogStatus.SUCCESS, 
 78                     "Edit by rico | ChgRestFormat | Payload-Content:" + fullpload); 
 79              
 80             //Load configuration parameters: 
 81             fldNode = (String) moduleContext.getContextData("fldNode"); 
 82             audit.addAuditLogEntry(msgKey, AuditLogStatus.SUCCESS, 
 83                     "Edit by rico | ChgRestFormat | input-fldNode:" + fldNode); 
 84  
 85             msgType = (String) moduleContext.getContextData("msgType"); 
 86             audit.addAuditLogEntry(msgKey, AuditLogStatus.SUCCESS, 
 87                     "Edit by rico | ChgRestFormat | input-msgType:" + msgType); 
 88  
 89             nameSpace = (String) moduleContext.getContextData("nameSpace"); 
 90             audit.addAuditLogEntry(msgKey, AuditLogStatus.SUCCESS, 
 91                     "Edit by rico | ChgRestFormat | input-nameSpace:" + nameSpace); 
 92              
 93             dataFormat = (String) moduleContext.getContextData("dataFormat"); 
 94             audit.addAuditLogEntry(msgKey, AuditLogStatus.SUCCESS, 
 95                     "Edit by rico | ChgRestFormat | input-nameSpace:" + dataFormat); 
 96              
 97             //convert content to specify format(JSON or XML) 
 98             if(dataFormat.equals("XML")==true) { 
 99                 contstr = "<"+fldNode+">"+contstr+"</"+fldNode+">"; 
100                  
101                 if((msgType != null && !msgType.isEmpty()) && (nameSpace != null && !nameSpace.isEmpty())) { 
102                     String stacd = "<?xml version=\"1.0\" encoding=\"UTF-8\"?>"+"<ns0:"+msgType+" xmlns:ns0=\""+nameSpace+"\">"; 
103                     String endcd = "</ns0:"+msgType+">"; 
104                     contstr = stacd + contstr + endcd; 
105                 }             
106             }else if(dataFormat.equals("JSON")==true) { 
107                 contstr = "{\""+fldNode+"\":\""+contstr+"\"}"; 
108                  
109                 if((msgType != null && !msgType.isEmpty()) && (nameSpace != null && !nameSpace.isEmpty())) { 
110                     String stajs = "\""+msgType+"\":"+contstr; 
111                     contstr = "{"+stajs+"}"; 
112                 } 
113             } 
114              
115             audit.addAuditLogEntry(msgKey, AuditLogStatus.SUCCESS, 
116                     "Edit by rico | ChgRestFormat | Trans-Content:" + contstr); 
117              
118             //Transform string to array 
119             byte convert[] = contstr.getBytes("UTF-8"); 
120              
121             //ByteArrayInputStream byteArr= new ByteArrayInputStream(content); 
122              
123             //Update output: 
124             try { 
125                 msg.getDocument().setContent(convert); 
126             } catch (InvalidParamException e) { 
127                 audit.addAuditLogEntry(msgKey, AuditLogStatus.ERROR, e.getMessage()); 
128                 throw new ModuleException(e.getMessage(), e); 
129             } 
130              
131             inputModuleData.setPrincipalData(msg); 
132      
133             } catch (Exception e) { 
134                 ModuleException me = new ModuleException(e); 
135                 throw me; 
136         } 
137          
138         return inputModuleData; 
139     } 
140      
141 }
View Code

1.3配置META-INF: ejb-j2ee-engine.xml

 

1.4配置EAR:application-j2ee-engine.xml

 1 <?xml version="1.0" encoding="UTF-8"?> 
 2 <application-j2ee-engine xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:noNamespaceSchemaLocation="application-j2ee-engine.xsd"> 
 3     <reference reference-type="hard"> 
 4         <reference-target target-type="service" provider-name="sap.com">engine.security.facade</reference-target> 
 5     </reference> 
 6     <reference reference-type="hard"> 
 7         <reference-target target-type="library" provider-name="sap.com">engine.j2ee14.facade</reference-target> 
 8     </reference> 
 9     <reference reference-type="hard"> 
10         <reference-target target-type="service" provider-name="sap.com">com.sap.aii.af.svc.facade</reference-target> 
11     </reference> 
12     <reference reference-type="hard"> 
13         <reference-target target-type="interface" provider-name="sap.com">com.sap.aii.af.ifc.facade</reference-target> 
14     </reference> 
15     <reference reference-type="hard"> 
16         <reference-target target-type="library" provider-name="sap.com">com.sap.aii.af.lib.facade</reference-target> 
17     </reference> 
18     <reference reference-type="hard"> 
19         <reference-target target-type="library" provider-name="sap.com">com.sap.base.technology.facade</reference-target> 
20     </reference> 
21     <fail-over-enable xsi:type="fail-over-enableType_disable" 
22         mode="disable" /></application-j2ee-engine>
View Code

1.5发布

1.5.1可手工导出导入:

 

 1.5.2通过SERVER发布

 

 PI服务器实例编码

 

 确认后输入登录信息即可发布到PI。

发布成功后进入PI首页查看EJB Explorer

 

2.PI配置

2.1ESR-Message Mapping

 2.2Communication Channel

 

 

 

 

3.测试

3.1Postman发送

 3.2PI消息


评论关闭
IT干货网

微信公众号号:IT虾米 (左侧二维码扫一扫)欢迎添加!

PI-S4 Proxy相关配置