11장. 메시지 가로채기
AMQ Broker를 사용하면 브로커를 입력하거나 종료하는 패킷을 인터셉트할 수 있으므로 패킷을 감사하거나 메시지를 필터링할 수 있습니다. 인터셉터는 가로채는 패킷을 변경할 수 있으므로 강력하고 잠재적으로 위험할 수 있습니다.
비즈니스 요구 사항에 맞게 인터셉터를 개발할 수 있습니다. 인터셉터는 프로토콜마다 다르며 적절한 인터페이스를 구현해야 합니다.
인터셉터는 부울 값을 반환하는 intercept()
메서드를 구현해야 합니다. 값이 true
이면 메시지 패킷은 계속됩니다. false
인 경우 프로세스가 중단되고 다른 인터셉터가 호출되지 않으며 메시지 패킷은 더 이상 처리되지 않습니다.
11.1. 인터셉터 생성 링크 복사링크가 클립보드에 복사되었습니다!
직접 들어오고 나가는 인터셉터를 만들 수 있습니다. 모든 인터셉터는 프로토콜별로 다르며 각각 서버를 입력하거나 종료하는 모든 패킷에 대해 호출됩니다. 이를 통해 인터셉터를 생성하여 패킷 감사와 같은 비즈니스 요구 사항을 충족할 수 있습니다. 인터셉터는 가로채는 패킷을 변경할 수 있습니다. 이렇게하면 잠재적으로 위험 할 수 있으므로 신중하게 사용하십시오.
인터셉터와 해당 종속 항목을 브로커의 Java 클래스 경로에 배치해야 합니다. 기본적으로 classpath의 일부이므로 < broker_instance_dir> /lib
디렉터리를 사용할 수 있습니다.
절차
다음 예제에서는 전달된 각 패킷의 크기를 확인하는 인터셉터를 생성하는 방법을 보여줍니다. 예제에서는 각 프로토콜에 대해 특정 인터페이스를 구현합니다.
적절한 인터페이스를 구현하고
intercept()
메서드를 덮어씁니다.AMQP 프로토콜을 사용하는 경우
org.apache.activemq.artemis.protocol.amqp.broker.AmqpInterceptor
인터페이스를 구현합니다.Copy to Clipboard Copied! Toggle word wrap Toggle overflow 코어 프로토콜을 사용하는 경우 인터셉터는
org.apache.artemis.activemq.api.core.Interceptor
인터페이스를 구현해야 합니다.Copy to Clipboard Copied! Toggle word wrap Toggle overflow MQTT 프로토콜을 사용하는 경우
org.apache.activemq.artemis.core.protocol.mqtt.MQTTInterceptor
인터페이스를 구현합니다.Copy to Clipboard Copied! Toggle word wrap Toggle overflow STOMP 프로토콜을 사용하는 경우
org.apache.activemq.artemis.core.protocol.stomp.StompInterceptor
인터페이스를 구현합니다.Copy to Clipboard Copied! Toggle word wrap Toggle overflow