SAP PI客户端套接字连接到TCP/IP套接字服务器

这篇博文展示了如何从SAP PI连接到TCP/IP套接字服务器。

高级流：

我使用了Dave Drager在他很棒的博客中提供的基本代码https://systembash.com/a-simple-java-tcp-server-and-tcp-client/。谢谢戴夫。服务器的代码按Dave博客的原样使用，但是客户端代码被修改了一点，以便在PI中使用。

在这里，智能建站软件，我使用NWDI创建了socket服务器，在我的环境中，大数据软件，bi大数据，PI可以连接到公司网络上的笔记本电脑。在您的情况下，有享云商城，您可能必须打开防火墙才能连接到运行测试套接字服务器的系统。

步骤1：创建源和目标数据类型、消息类型和服务接口。

步骤2：使用以下代码创建UDF（本例中为SocClient）。确保包括java.net*在UDF库部分

第3步：启动NWDI中的Socket服务器

第4步：测试PI中的映射

服务器登录NWDI将确认收到的测试消息：

UDF代码：

公共字符串SocClient（String var1，Container Container）抛出StreamTransformationException{

String语句；

String modifiedSentence="；

try

{

InputStream isr=new ByteArrayInputStream（var1.getBytes（））；

BufferedReader infomuser=new BufferedReader（new InputStreamReader（isr））；

Socket clientSocket=new Socket（"xxx.xxx.xxx.xxx"，大数据应用前景，6789）；

DataOutputStream outToServer=新DataOutputStream(clientSocket.getOutputStream（））；

缓冲读取器informserver=new BufferedReader（新InputStreamReader(clientSocket.getInputStream（））；

句子=INFOROMUSER.readLine文件();

outToServer.writeBytes（句+'\n'）；

修饰句=INFORMSERVER.readLine文件();

客户端套接字。关闭（）；

}

catch（UnknownHostException e）

{

e.printStackTrace（）；

}

catch（IOException e）

{

e.printStackTrace（）；

}

return modifiedSentence；

}

这是我的第一个博客，非常感谢反馈。