第 149 章 HL7 DataFormat
从 Camel 版本 2.0 开始提供
HL7 组件用于使用 HL7 MLLP 协议和 HL7 v2 消息,使用 HAPI 库。
这个组件支持以下组件:
- 用于 Mina的 HL7 MLLP codec
- HL7 MLLP codec for Netty4 from Camel 2.15 wards
- 类型 Converter from/to HAPI 和 String
- HL7 DataFormat 使用 HAPI 库
- 更加易用,因为它与 camel-mina2 组件集成。
Maven 用户需要将以下依赖项添加到此组件的 pom.xml
中:
<dependency> <groupId>org.apache.camel</groupId> <artifactId>camel-hl7</artifactId> <version>x.x.x</version> <!-- use the same version as your Camel core version --> </dependency>
149.1. HL7 MLLP 协议
HL7 通常与 HL7 MLLP 协议一起使用,它是基于文本的 TCP 套接字协议。此组件附带一个符合 MLLP 协议的 Mina 和 Netty4 Codec,以便您可以轻松地公开接受 TCP 传输层的 HL7 请求的 HL7 侦听器。要公开 HL7 侦听器服务,camel-mina2 或 camel-netty4 组件与 HL7MLLPCodec
(mina2)或 HL7MLLPNettyDecoder/HL7MLLPNettyEncoder
(Netty4)一起使用。
HL7 MLLP codec 可以配置如下:
Name | 默认值 | 描述 |
---|---|---|
|
| 跨越 HL7 有效负载的开始字节。 |
|
| 跨越 HL7 有效负载的第一个结束字节。 |
|
| 跨越 HL7 有效负载的第 2 个结束字节。 |
| JVM 默认值 | 用于 codec 的编码(费用名称)。如果没有提供,Camel 将使用 JVM 默认 Charset。 |
|
| (Camel 2.14.1)如果为 true,则 codec 会使用定义的 charset 创建一个字符串。如果为 false,则 codec 会将普通字节数组发送到路由,以便 HL7 数据格式可以决定 HL7 消息内容中的实际 charset。 |
|
|
将 |
149.1.1. 使用 Mina 公开 HL7 侦听器
在 Spring XML 文件中,我们将 mina2 端点配置为使用 TCP 在端口 8888
上侦听 HL7 请求:
<endpoint id="hl7MinaListener" uri="mina2:tcp://localhost:8888?sync=true&codec=#hl7codec"/>
sync=true 表示此监听器是同步的,因此会将 HL7 响应返回给调用者。HL7 codec 使用 codec=#hl7codec 设置。请注意,hl7codec
只是一个 Spring bean ID,因此它可以命名为 mygreatcodecforhl7
或 any。codec 也在 Spring XML 文件中设置:
<bean id="hl7codec" class="org.apache.camel.component.hl7.HL7MLLPCodec"> <property name="charset" value="iso-8859-1"/> </bean>
然后,端点 hl7MinaLlistener 可以在路由中使用,因为此 Java DSL 示例所示:
from("hl7MinaListener") .bean("patientLookupService");
这是一个非常简单的路由,它将侦听 HL7,并将其路由到名为 patient LookupService 的服务。这也是 Spring bean ID,在 Spring XML 中配置,如下所示:
<bean id="patientLookupService" class="com.mycompany.healthcare.service.PatientLookupService"/>
业务逻辑可以在不依赖于 Camel 的 POJO 类中实施,如下所示:
import ca.uhn.hl7v2.HL7Exception; import ca.uhn.hl7v2.model.Message; import ca.uhn.hl7v2.model.v24.segment.QRD; public class PatientLookupService { public Message lookupPatient(Message input) throws HL7Exception { QRD qrd = (QRD)input.get("QRD"); String patientId = qrd.getWhoSubjectFilter(0).getIDNumber().getValue(); // find patient data based on the patient id and create a HL7 model object with the response Message response = ... create and set response data return response }
149.1.2. 使用 Netty 公开 HL7 侦听器(从 Camel 2.15 开始可用)
在 Spring XML 文件中,我们将 netty4 端点配置为使用 TCP 在端口 8888
上侦听 HL7 请求:
<endpoint id="hl7NettyListener" uri="netty4:tcp://localhost:8888?sync=true&encoder=#hl7encoder&decoder=#hl7decoder"/>
sync=true 表示此监听器是同步的,因此会将 HL7 响应返回给调用者。HL7 codec 使用 encoder=#hl7encoder*and*decoder=#hl7decoder 设置。请注意,hl7encoder
和 hl7decoder
只是 bean ID,因此它们可以被不同命名。Bean 可以在 Spring XML 文件中设置:
<bean id="hl7decoder" class="org.apache.camel.component.hl7.HL7MLLPNettyDecoderFactory"/> <bean id="hl7encoder" class="org.apache.camel.component.hl7.HL7MLLPNettyEncoderFactory"/>
然后,端点 hl7NettyListener 可用作消费者的路由,如 Java DSL 示例所示:
from("hl7NettyListener") .bean("patientLookupService");