Мул против верблюда

• приложение принимает входящие GET-запросы по адресу http://localhost:8080/test
• в качестве входной информации сервер принимает query параметр «id», т.е. каждый запрос выглядит как http://localhost:8080/test?id=1234
• на каждый входящий запрос приложение делает GET-запрос в сторонний REST-сервис по адресу https://restservice:9999/booking при условиях:
  • протокол взаимодействия HTTPS
  • каждый запрос должен содержать кастомный HTTP header "Source-Sytem: mule/camel"
  • значение из query параметра «id» передается как URL параметр, т.е. запрос выглядит как https://restservice:9999/booking/1234
  • используется Basic Authentication
  • доступ к сервису происходит через NTLM proxy
• ответ от REST-сервиса отправляется без измений как ответ на исходный входящий запрос

Интеграция с помощью Apache Camel

Исходя из постановки задачи, мы понимаем, что нам нужно как минимум два ключевых компонента:

• HTTP сервер, который будет слушать входящие запросы на порту 8080
• HTTP клиент, который будет запрашивать информацию у стороннего сервера https://restservice:9999

Смотрим список доступных компонент и находим, что для сервера нам подойдет Jetty, а для клиента подойдет HTTP. Запустить HTTP сервер без всяких наворотов с помощью Jetty компонента оказывается совершенно просто. Это делается в одну строку:

from("jetty:http://0.0.0.0:8080/test")

С клиентом будет посложнее, так как мы хотим использовать прокси и аутентификацию. Внимательно вкуриваем документацию и обнаруживаем, что обе фичи уже поддерживается HTTP компонентом. Выглядеть это должно примерно так:

to("https://restservice:9999/booking/" +
                        "?bridgeEndpoint=true" +
                        "&proxyAuthMethod=NTLM" +
                        "&proxyAuthHost=proxy_host" +
                        "&proxyAuthPort=proxy_port" +
                        "&proxyAuthScheme=http" +
                        "&proxyAuthUsername=proxy_username" +
                        "&proxyAuthPassword=proxy_password" +
                        "&proxyAuthDomain=proxy_domain" +
                        "&authenticationPreemptive=true" +
                        "&authMethod=Basic" +
                        "&authMethodPriority=Basic" +
                        "&authUsername=username" +
                        "&authPassword=password")

Как видно, мы специфицируем прокси парамтеры и параметры базовой аутентификации. При этом с TLS не делаем ничего особенного, кроме указания протокола HTTPS.

И последний трюк — это трансформация входящего query параметра «id» в URL параметр. В camel это можно сделать с помощью манипуляций с exchange’s headers. Camel API предлагает делать это с помощью методов setHeader и removeHeader.

В итоге у меня получился довольно сжатый и лаконичный код:

import org.apache.camel.main.Main;
import org.apache.camel.Exchange;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.component.http.HttpMethods;


public class TestApp extends RouteBuilder {

    public static void main(String... args) throws Exception {
        Main main = new Main();
        main.configure().addRoutesBuilder(new TestApp());
        main.run(args);
    }

    public void configure() {
        from("jetty:http://0.0.0.0:8080/test")
                .setHeader(Exchange.HTTP_METHOD, constant(HttpMethods.GET))
                .setHeader("Source-System", constant("camel"))
                .setHeader(Exchange.HTTP_PATH, simple("${header.id}"))
                .removeHeader(Exchange.HTTP_QUERY)
                .to("https://restservice:9999/booking/" +
                        "?bridgeEndpoint=true" +
                        "&proxyAuthMethod=NTLM" +
                        "&proxyAuthHost=proxy_host" +
                        "&proxyAuthPort=proxy_port" +
                        "&proxyAuthScheme=http" +
                        "&proxyAuthUsername=proxy_username" +
                        "&proxyAuthPassword=proxy_password" +
                        "&proxyAuthDomain=proxy_domain" +
                        "&authenticationPreemptive=true" +
                        "&authMethod=Basic" +
                        "&authMethodPriority=Basic" +
                        "&authUsername=username" +
                        "&authPassword=password");
    }
}

Из непонятных трюков в этом коде я вижу две вещи. Во-первых, в параметрах HTTP компонента я использовал bridgeEndpoint=true, который как раз предусмотрен для подобных кейсов, когда запрос перенаправляется с одного эндпойнта на другой. В документации bridgeEndpoint описан так, что никогда не догадаешься, зачем он нужен, но если его убрать, то получим ошибку с полезным сообщением вида:

java.lang.IllegalArgumentException: Invalid uri: /test/123. 
If you are forwarding/bridging http endpoints, 
then enable the bridgeEndpoint option on the endpoint:
https://restservice:9999/booking/?

Во-вторых, то как происходит транформация query параметра в URl параметр:

.setHeader(Exchange.HTTP_PATH, simple("${header.id}"))
.removeHeader(Exchange.HTTP_QUERY)

Jetty компонент автоматически копирует query параметры в exchange’s header. С помощью simple("${header.id}") мы получаем значение хэдора с именем «id». С помощью setHeader(Exchange.HTTP_PATH, simple("${header.id}")) мы говорим, что значение хэдора «id» должно использоваться как URL параметр, то есть добавляться в path. И в завершеннии понадобилось удалить все хэдоры, пришедшие как query параметры от Jetty, с помощью removeHeader(Exchange.HTTP_QUERY). Если этого не сделать,то они автоматически добавятся как query параметры в запрос HTTP клиента.

Интеграция с помощью Mule

Работа с mule начинается с установки Anypoint Studio. Без Anypoint Studio разработка mule приложения будет мучительной и малопродуктивной.

Итак, поставили и запустили Anypoint Studio, создали новый Mule Project. В Mule Palette находим два компонента Listener(HTTP) и Request (HTTP). C помощью Listener(HTTP) мы создалим HTTP сервер. С помощью Request(HTTP) мы создадим HTTP клиент. Драг-анд-дропом создаем флоу. Должно получиться такое простое флоу:

Это, конечно же, еще не все. Нужно специфицировать наши сервер и клиент. Начнем с Listener. Находим Connector configuration в параметрах Listener и кликаем плюсик. Появляется диалог, в котором мы можем специфицировать конфигурацию HTTP Listener

После того, как прописали порт и базовый путь, в xml файле можно подглядеть, что получилось. Должно выглядеть примерно так:

<http:listener-config name="HTTP_Listener_config"
	                      doc:name="HTTP Listener config">
   <http:listener-connection host="0.0.0.0 port="8080" 
basePath="/test"/>
</http:listener-config>

<flow name="integrationFlow">
   <http:listener doc:name="Listener"
		               config-ref="HTTP_Listener_config"
		               path="/" />
</flow>

Не одна строка как в Camel, но тоже довольно просто и интуитивно понятно.

Теперь разберемся с Request(HTTP). Находим configuration в параметрах Request(HTTP) и кликаем плюсик. Получаем диалог, в котором можем настроить все необходимые нам параметры, включая TLS, прокси и аутентификацию.

После вдумчивой настройки параметров в xml файле должно получиться примерно так:

<http:request-config	name="HTTP_Request_configuration"	doc:name="HTTP Request configuration">
	<http:request-connection host="restservice" port="9999" protocol="HTTPS">
		<tls:context>
			<tls:trust-store insecure="true" />
		</tls:context>
		<http:proxy-config>
			<http:ntlm-proxy 
ntlmDomain="proxy_domain"	
host="proxy_host"	
port="proxy_port"	
username="proxy_username"	
password="proxy_password" />
		</http:proxy-config>
		<http:authentication>
			<http:basic-authentication	
username="username"	
password="password" />
		</http:authentication>
	</http:request-connection>
</http:request-config>

<flow name="integrationFlow">

	<http:request method="GET"
		              doc:name="Request"
		              config-ref="HTTP_Request_configuration"
		              path="/booking/{id}">
	</http:request>
</flow>

Здесь нужно отметить, что для TLS нужно поставить галку insecure, иначе mule будет пытаться проверить SSL-сертификат сервера restservice на валидность, а нам это не нужно.

И последний штрих — передача входного query параметра «id». Опять смотрим на параметры Request(HTTP) и находим закладку URI Parameters, где мы должны прописать имя URI параметра и его значение id=attributes.queryParams.id

Также заглянем в закладку Headers и добавим хэдер Source-Sytem=mule

Окончательный вид нашего xml будет такой:

<mule xmlns:sockets="http://www.mulesoft.org/schema/mule/sockets"
      xmlns:tls="http://www.mulesoft.org/schema/mule/tls"
      xmlns:http="http://www.mulesoft.org/schema/mule/http"
      xmlns="http://www.mulesoft.org/schema/mule/core"
      xmlns:doc="http://www.mulesoft.org/schema/mule/documentation"
      xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
      xsi:schemaLocation="http://www.mulesoft.org/schema/mule/core http://www.mulesoft.org/schema/mule/core/current/mule.xsd
	http://www.mulesoft.org/schema/mule/http http://www.mulesoft.org/schema/mule/http/current/mule-http.xsd
	http://www.mulesoft.org/schema/mule/tls http://www.mulesoft.org/schema/mule/tls/current/mule-tls.xsd
	http://www.mulesoft.org/schema/mule/sockets http://www.mulesoft.org/schema/mule/sockets/current/mule-sockets.xsd">

	<http:listener-config name="HTTP_Listener_config"
	                      doc:name="HTTP Listener config">
		<http:listener-connection host="0.0.0.0"		                         
		                          port="8080" 
					  basePath="/test"/>
	</http:listener-config>

	<http:request-config
			name="HTTP_Request_configuration"
			doc:name="HTTP Request configuration">
		<http:request-connection
				host="restservice"
				port="9999"
				protocol="HTTPS">
			<tls:context>
				<tls:trust-store insecure="true" />
			</tls:context>
			<http:proxy-config>
				<http:ntlm-proxy 
						ntlmDomain="proxy_domain"
						host="proxy_host"
						port="proxy_port"
						username="proxy_username"
						password="proxy_password" />
			</http:proxy-config>
			<http:authentication>
				<http:basic-authentication
						username="username"
						password="password" />
			</http:authentication>
		</http:request-connection>
	</http:request-config>

	<flow name="integrationFlow">
		<http:listener doc:name="Listener"
		               config-ref="HTTP_Listener_config"
		               path="/" />

		<http:request method="GET"
		              doc:name="Request"
		              config-ref="HTTP_Request_configuration"
		              path="/booking/{id}">
			<http:headers><![CDATA[#[output application/java
---
{
	"Source-Sytem" : "mule"
}]]]></http:headers>
			<http:uri-params ><![CDATA[#[output application/java
---
{
	"id" : attributes.queryParams.id
}]]]></http:uri-params>
		</http:request>

	</flow>
</mule>

На первый вгляд выглядит очень многословно по сравнению с Camel. Однако несомненный плюс mule в том, что многие вещи можно делать интуитивно не заглядывая в в документацию.