如何使用camel调用内容类型为X-www-urlencoded的POST api

Question

我尝试将处理器写入如下

    package com.example.demo;

import java.io.ByteArrayInputStream;
import java.io.InputStream;
import java.io.ObjectInputStream;
import java.net.URLEncoder;
import java.util.HashMap;
import java.util.Map;
import java.util.stream.Stream;

import org.apache.camel.Exchange;
import org.apache.camel.Message;
import org.apache.camel.Processor;

import com.fasterxml.jackson.databind.ObjectMapper;

public class TokenProcessor implements Processor {

    @Override
    public void process(Exchange exchange) throws Exception {
        // TODO Auto-generated method stub
        
        exchange.
        System.out.println(exchange.getIn().getBody());
        Message out = exchange.getOut();
            
        Map<String,Object> map=new HashMap<String,Object>();
        map.put(Exchange.HTTP_METHOD,"POST" );
        map.put(Exchange.CONTENT_TYPE,"application/x-www-form-urlencoded" );
    
        TokenInput tokeninput=exchange.getIn().getBody(TokenInput.class);
        System.out.println("Tokeninput="+tokeninput);
//      map.put("client_id",tokeninput.getClient_id());
//      map.put("scope",tokeninput.getScope());
//      map.put("code",tokeninput.getCode());
//      map.put("redirect_uri",tokeninput.getRedirect_uri());
//      map.put("grant_type",tokeninput.getGrant_type());
//      map.put("client_secret",tokeninput.getClient_secret());
        ObjectMapper obj=new ObjectMapper();
        String jsonStr=obj.writeValueAsString(tokeninput);
        //InputStream convertValue = obj.convertValue(tokeninput, Byte.class);
        out.setHeaders(map);
        //String encode = URLEncoder.encode(tokeninput.toString(),"utf-8");
        out.setBody(exchange.getIn().getBody());
    }
}

Gettring错误

NotypeConversionAvailableException：没有类型转换器可用于将类型：com.example.demo.TokenInput转换为所需类型:java.io.InputStream，其值为com.example.demo.TokenInput@ea2c54c at org.apache.camel.impl.converterregistry.mandatoryConvertto(BasetypeConverterRegistry.java:181)~[camel-core-2.12.0.jar:2.12.0]at:2.12.0]在org.apache.camel.processor.convertBodyProcessor.process(convertBodyProcessor.java:78)~[camel-core-2.12.0.jar:2.12.0]

Answer 1

我在camel应用程序中广泛使用它，如下所示。

    .removeHeaders("*")
            .setHeader(Exchange.HTTP_METHOD, constant("POST"))
            .setHeader(Exchange.CONTENT_TYPE, constant("application/x-www-form-urlencoded"))
            .setBody(simple("grant_type=refresh&client_id=1233232&client_secret=mysecret"))
            .to("http://google.com");