Spring weblux how to share data from Controller to Filter using Context
<div class="votecell post-layout--left">
<div class="js-voting-container d-flex jc-center fd-column ai-stretch gs4 fc-black-200"></div>
</div>
<div class="postcell post-layout--right">
<div class="s-prose js-post-body">
<p>
</p>
<p>
In controller I need to share some data to WebFilter (I don't want to use <code>ServerWebExchange.getAttributes().put("KEY", "VALUE")</code>, and my boss either), this is my current implemetation:
</p>
<pre class="lang-java s-code-block"><code><span>@Component</span>
<span>public</span> <span>class</span> <span>RequestFilter</span> <span>implements</span> <span>WebFilter</span> {
<span>@Override</span>
<span>public</span> Mono<Void> <span>filter</span><span>(ServerWebExchange exchange, WebFilterChain chain)</span> {
exchange.getResponse().beforeCommit(() -> Mono.deferWithContext(c -> {
<span>//I CHECK WHETHER DATA SHARED FROM CONTROLLER EXIST OR NOT</span>
System.out.println(c.hasKey(<span>"abc"</span>));
<span>Context</span> <span>innerContext</span> <span>=</span> c.get(<span>"CONTEXT"</span>);
System.out.println(innerContext.hasKey(<span>"abc"</span>));
<span>return</span> Mono.empty();
}));
<span>ServerHttpRequest</span> <span>request</span> <span>=</span> exchange.getRequest();
<span>BodyCaptureExchange</span> <span>bodyCaptureExchange</span> <span>=</span> <span>new</span> <span>BodyCaptureExchange</span>(exchange);
<span>return</span> chain.filter(bodyCaptureExchange).subscriberContext(context -> {
<span>//HERE I PUT CONTEXT TO ITSELF</span>
context = context.put(<span>"CONTEXT"</span>, context);
<span>return</span> context;
});
}
}</code>
Here is my controller method:</pre>
<pre class="lang-java s-code-block"><code><span>public</span> Mono<ResponseEntity<Response>> <span>post</span><span>(<span>@RequestBody</span> Mono<Request> request)</span> {
Mono<ResponseEntity<Response>> responseEntityMono = request.flatMap(
rq -> service.requestProcess(rq).map(res -> ResponseEntity.ok().body(res))
).subscriberContext(c -> {
<span>//HERE I GET THE INNER CONTEXT FROM ABOVE FILTER</span>
<span>Context</span> <span>innerContext</span> <span>=</span> c.get(<span>"CONTEXT"</span>);
<span>//PUT DATA TO IT</span>
c = c.put(<span>"CONTEXT"</span>, innerContext.put(<span>"abc"</span>, <span>"abc"</span>));
<span>//ALSO PUT DATA TO PARENT</span>
c = c.put(<span>"abc"</span>, <span>"abc"</span>);
<span>return</span> c;
});
<span>return</span> responseEntityMono;
}</code>
</pre>
<p>
The System.out.println in RequestFilter print:
</p>
<pre class="lang-java s-code-block"><code><span>false</span>
<span>false</span>
</code></pre>
<p>
Means that data I put from controller are lost when it come to Filter. Please correct me if I'm wrong somewhere. I really need your help
</p>
<p>
</p>
<p>
Reactor version: 3.3.14
</p>
<p>
</p>
<p>
Spring boot stater webflux: 2.3.9.RELEASE
</p>
<p>
</p>
</div>
</div>
