feat(mcp): webflux support custom http header

Author: SunJiFengPlus

mcp-spring/mcp-spring-webflux/src/main/java/io/modelcontextprotocol/client/transport/WebFluxSseClientTransport.java

@@ -5,6 +5,7 @@
 
 import java.io.IOException;
 import java.util.function.BiConsumer;
+import java.util.function.Consumer;
 import java.util.function.Function;
 
 import com.fasterxml.jackson.core.type.TypeReference;
@@ -16,6 +17,7 @@
 import io.modelcontextprotocol.util.Assert;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
+import org.springframework.http.HttpHeaders;
 import reactor.core.Disposable;
 import reactor.core.publisher.Flux;
 import reactor.core.publisher.Mono;
@@ -235,6 +237,11 @@ else if (MESSAGE_EVENT_TYPE.equals(event.event())) {
 	 */
 	@Override
 	public Mono<Void> sendMessage(JSONRPCMessage message) {
+		return sendMessage(message, httpHeaders -> {
+		});
+	}
+
+	public Mono<Void> sendMessage(JSONRPCMessage message, Consumer<HttpHeaders> mutateHeaders) {
 		// The messageEndpoint is the endpoint URI to send the messages
 		// It is provided by the server as part of the endpoint event
 		return messageEndpointSink.asMono().flatMap(messageEndpointUri -> {
@@ -245,6 +252,7 @@ public Mono<Void> sendMessage(JSONRPCMessage message) {
 				String jsonText = this.objectMapper.writeValueAsString(message);
 				return webClient.post()
 					.uri(messageEndpointUri)
+					.headers(mutateHeaders)
 					.contentType(MediaType.APPLICATION_JSON)
 					.bodyValue(jsonText)
 					.retrieve()