Spring Integration, comment puis-je passer entrant requête http via la passerelle sortante?

Je suis en train de mettre en œuvre une sorte de proxy dans le cadre de mon flux de données, je veux recevoir une http-request sur mon entrant passerelle et le passer à travers sortant de la passerelle. Je veux conserver tous les paramètres de chaîne de requête. Mon passerelles configuration est la suivante:

<int:channel id="searchRequestChannel" />
<int:channel id="searchReplyChannel" />

<int-http:inbound-gateway id="searchRequestInboundGateway"      
    supported-methods="GET" 
    request-channel="searchRequestChannel"
    reply-channel="searchReplyChannel"      
    path="/services/normalization"
    reply-timeout="50000"
/>

<int-http:outbound-gateway id="searchServiceGateway"
    http-method="GET"
    request-channel="searchRequestChannel"
    url="http://localhost:8080/query"
    extract-request-payload="false"
    expected-response-type="java.lang.String"
    reply-timeout="50000"
    charset="UTF-8"
/>

J'attendais qu'il travail comme suit:

Client, envoyez une demande à la passerelle entrante /services/normalisation:
OBTENIR /services/normalisation q=cat&exclude=noir
Passerelle entrante reçoit la demande et l'envoyer par searchRequestChannel à la sortant passerelle.
Sortant de la passerelle envoie toute la demande pour le service externe:
OBTENIR /de la requête q=cat&exclude=noir

Mais sur la pratique, sortant de la passerelle envoie vide demande qui ne contient pas de n'importe quelle requête arguments:

GET /query

Donc ma question, quelle est la façon la plus simple pour envoyer le http-demande qui a été acceptée sur la passerelle entrante par le biais de la passerelle sortante. En d'autres termes comment puis-je mettre en œuvre simple proxy par le printemps des outils d'intégration?

OriginalL'auteur masted | 2013-05-07

spring spring-integration

4

C'est un peu de bidouille, mais fonctionne; la DispatcherServlet lie la demande pour le fil...
```
<int-http:inbound-gateway id="searchRequestInboundGateway"      
    supported-methods="GET" 
    request-channel="searchRequestEnricherChannel"
    reply-channel="searchReplyChannel"      
    path="/services/normalization{queryString}"
    reply-timeout="50000"
/>

<int:header-enricher input-channel="searchRequestEnricherChannel" output-channel="searchRequestChannel">
    <int:header name="queryString" 
        expression="T(org.springframework.web.context.request.RequestContextHolder).requestAttributes.request.queryString" />
</int:header-enricher>
```
et puis au départ, l'utilisation
```
<int-http:outbound-gateway id="searchServiceGateway"
    http-method="GET"
    request-channel="searchRequestChannel"
    url="http://localhost:8080/query?{queryString}"
    encode-uri="false"
    extract-request-payload="false"
    expected-response-type="java.lang.String"
    reply-timeout="50000"
    charset="UTF-8">
    <uri-variable name="queryString" expression="headers.queryString" />
</int-http:outbound-gateway>
```
Toutefois, cela ne fonctionne pas avec 2.2.x et versions antérieures, car la chaîne de requête est codé sur le départ (foo=bar&baz=qux devient foo%3Dbar%26baz%3Dqux). Dans la version 3.0, nous avons ajouté la possibilité de ne pas encoder les URI à l'aide d'un attribut à l'aide de encode-uri="false". Ce n'est pas encore disponible dans une version, mais il est disponible en 3.0.0.BUILD-SNAPSHOT.

EDIT:

Ci-dessus est une solution globale qui fonctionne pour toutes les chaînes de requête; si vous connaissez les paramètres réels, une autre solution serait d'extraire chaque paramètre séparément et de reconstruire la chaîne de requête sur le départ...
```
<int-http:inbound-gateway ... >
    <int-http:header name="foo" expression="#requestParams.foo.get(0)"/>                          
    <int-http:header name="baz" expression="#requestParams.baz.get(0)"/>
</int-http:inbound-gateway>

<int-http:outbound-gateway request-channel="requestChannel" 
                           url="http://localhost:18080/http/receiveGateway?foo={foo}&amp;baz={baz}"
                           http-method="POST"
                           expected-response-type="java.lang.String">
    <int-http:uri-variable name="foo" expression="headers.foo"/>
    <int-http:uri-variable name="baz" expression="headers.baz"/>
</int-http:outbound-gateway>
```
Sur le trafic côté, il serait mieux si nous avons offert à la chaîne de requête comme une classe de première variable d'expression #queryString.

N'hésitez pas à ouvrir un "Amélioration" JIRA Problème

Hmm. Peut-être que je suis en train de faire quelque chose de mal, mais 'queryString' en-tête du message reçu est vide. J'ai fait inspecter l'objet du message dans le débogueur à la méthode HttpRequestExecutingMessageHandler.handleRequestMessage(Message<?>). Et mon enregistreur de sortie gist.github.com/detsam/5538976
Désolé de mon erreur, je l'ai testé avec une maquette HttpRequest; laissez-moi voir si je peux trouver un autre travail autour.
J'ai mis à jour ma réponse avec une solution générale qui nécessite Printemps Intégration 3.0, et une autre solution si vous connaissez les paramètres de la requête.
Je vous remercie pour votre temps et votre aide! Je n'ai de réponse post avec ma propre solution de rechange. Si vous avez des ajouts ou des suggestions, je serais heureux de les entendre. 🙂 P. s.: Je vais attendre SI 3.0, greate travail, continuez comme ça les gars. 🙂

OriginalL'auteur Gary Russell

Ma propre solution de contournement solution est d'utiliser un transformateur qui transforme les paramètres dans le charge utile du message (carte des paramètres de chaîne de requête) pour préparer les chaîne de requête et l'utilisation d'un url expression dans un sortant de la passerelle pour éviter une chaîne de requête d'encodage:

<bean id="payloadToQueryString" 
    class="com.dph.integration.PayloadToQueryStringTransformer" />

<int-http:inbound-gateway id="searchRequestInboundGateway"      
 supported-methods="GET"
 request-channel="searchRequestChannel"
 path="/services/normalization"
 reply-timeout="50000" />

<int:transformer input-channel="searchRequestChannel" 
     output-channel="searchGatewayChannel" 
     ref="payloadToQueryString" method="transform" />

<int-http:outbound-gateway id="searchServiceGateway"
    http-method="GET"
    request-channel="searchGatewayChannel"
    url-expression="'http://localhost:8080/query?' + payload"
    expected-response-type="java.lang.String"
    reply-timeout="50000"
    charset="UTF-8">
</int-http:outbound-gateway>

PayloadToQueryStringTransformer classe est:

public class PayloadToQueryStringTransformer extends AbstractTransformer {

@Override
protected Object doTransform(final Message<?> message) throws Exception {
    return MessageBuilder
        .withPayload(urlEncodeUTF8(((MultiValueMap) message.getPayload()).toSingleValueMap()))
        .copyHeaders(message.getHeaders())
        .build();
}

private static String urlEncodeUTF8(final String s) {
    try {
        return URLEncoder.encode(s, "UTF-8");
    } catch (final UnsupportedEncodingException e) {
        throw new UnsupportedOperationException(e);
    }
}
private static String urlEncodeUTF8(final Map<?,?> map) {
    final StringBuilder sb = new StringBuilder();
    for (final Map.Entry<?,?> entry : map.entrySet()) {
        if (sb.length() > 0) {
            sb.append("&");
        }
        sb.append(String.format("%s=%s",
                urlEncodeUTF8(entry.getKey().toString()),
                urlEncodeUTF8(entry.getValue().toString())
                ));
    }
    return sb.toString();
}

}

OriginalL'auteur masted

Vous devez vous connecter pour publier un commentaire.