All and Sundry: Spring Cloud Zuul
Spring Cloud projects to work with Zuul and other Netflix OSS projects for development.
Join the DZone community and get the full member experience.
Join For FreeNetflix OSS project Zuul serves as a gateway to backend services and provides support for adding in edge features like security and routing. In the Zuul world, specific edge features are provided by components called the Zuul Filter, and writing such a filter for a Spring Cloud-based project is very simple. A good reference for adding a filter is here. Here, I wanted to demonstrate two small features — deciding whether a filter should act on a request and adding a header before forwarding the request.
Writing a Zuul Filter
Writing a Zuul Filter is very easy for Spring Cloud. All we need to do is to add a Spring bean which implements the ZuulFilter, so for this example, it would look something like this:
import com.netflix.zuul.ZuulFilter;
import com.netflix.zuul.context.RequestContext;
import org.springframework.stereotype.Service;
@Service public class PayloadTraceFilter extendsZuulFilter{
private static final String HEADER="payload.trace";
@Override public String filterType(){
return"pre";
}
@Override public int filterOrder(){
return 999;
}
@Override public boolean shouldFilter() { .... }
@Override public Object run() { .... }
}
Some high-level details of this implementation — this has been marked as a "Filter type" of "pre" which means that this filter would be called before the request is dispatched to the backend service. FilterOrder determines when this specific filter is called in the chain of filters. Should Filter determines if this filter is invoked at all for this request, and run contains the logic for the filter.
So to my first consideration, whether this filter should act on the flow at all (this can be done on a request-by-request basis, my logic is very simple) — if the request URI starts with /samplesvc, then this filter should act on the request.
@Override public boolean shouldFilter(){
RequestContext ctx = RequestContext.getCurrentContext();
String requestUri = ctx.getRequest().getRequestURI();
returnrequestUri.startsWith("/samplesvc");
}
And the second consideration on modifying the request headers to the backend service:
@Override public Object run(){
RequestContext ctx = RequestContext.getCurrentContext();
ctx.addZuulRequestHeader("payload.trace", "true");
return null;
}
A backing service getting such a request can look for the header and act accordingly, say in this specific case looking at the "payload.trace" header and deciding to log the incoming message:
@RequestMapping(value = "/message", method = RequestMethod.POST)
public Resource<MessageAcknowledgement>
pongMessage(@RequestBodyMessage input, @RequestHeader("payload.trace") boolean tracePayload){
if(tracePayload){
LOGGER.info("Received Payload: {}", input.getPayload());
}
....
Conclusion
As demonstrated here, Spring Cloud really makes it simple to add in Zuul filters for any edge needs. If you want to explore this sample a little further, I have sample projects available in my GitHub repo.
Published at DZone with permission of Biju Kunjummen, DZone MVB. See the original article here.
Opinions expressed by DZone contributors are their own.
Comments