PROSAGA码农传奇-springcloud-如何在任何时候存储有效负载以便以后使用它

<div class =“post-text”itemprop =“text”>
  
    从您的通用描述中不清楚最佳方法是什么。有两种选择：
  
  <OL>
    <LI>
      
        扇动到获取和发布
      
      
         <code>
 http | groovy-transform > :request
 </code>
         
         <code>
 :request > httpclient-get |log
 </code>
         
         <code>
 :request > httpclient-post|log
 </code>
      
    </LI>
  </醇>
  
    流可以连接：
  
   <pre>
 <code>
 http | groovy-transform > :request 
 :request > httpclient-get > :response 
 :request > httpclient-post > :response
 :response > log

</code>
 </pre>
  <ol start =“2”>
    <LI>
      用一个
      <a href =“https://github.com/spring-cloud-stream-app-starters/header-enricher/blob/master/spring-cloud-starter-stream-processor-header-enricher/README.adoc"rel =“nofollow noreferrer”>
        标题更丰富
      </A>
       处理器将原始有效负载添加为标头以及一些代码以提取httpclient_post中的标头。
    </LI>
  </醇>
  
    请注意，如果您使用kafka绑定器和kafka＆lt; 0.11客户端，需要明确启用
    <a href="https://docs.spring.io/spring-cloud-stream/docs/current/reference/htmlsingle/#_kafka_binder_properties" rel="nofollow noreferrer">
      自定义标题
    </A>
    ： 例如：
  
   <pre>
 <code>
 stream create hetest --definition "time | header-enricher --headers=foo='bar' | log --expression=headers" 
stream deploy hetest --properties "app.*.spring.cloud.stream.kafka.binder.headers=foo"

</code>
 </pre>
</DIV>