Home  >  Spring 4

Spring 4 + Reactor Integration Example

By Arvind Rai, December 30, 2014
Reactor is a framework to make event driven programming much easier. This is based on Reactor Design Pattern. Reactor is good for asynchronous applications on the JVM. Here we will create asynchronous and event driven application using Spring 4 and Reactor. Reactor uses Selectors, Consumers and Events as core module. Consumer is event consumer which needs to be notified for the event. Reactor is event gateway where event consumers are registered with a notification key. Selector is an abstraction to find consumer by invoking event. Find the example for detailed understanding.

Software Required to Run Example

To run the example we need the following software.
1. JDK 6
2. Gradle
3. Eclipse

Project Structure in Eclipse

Find our demo project structure in eclipse.
Spring 4 + Reactor Integration Example

Java Class for JSON

For the event driven example, we have created sample page that will return the JSON as below.
To get this output we are using local URL as http://localhost:8080/empdata.jsp
To consume the JSON, we have two classes as below.
package com.concretepage.reactor;
import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
public class Employee {
	private Integer id;
	private String name;
	public Integer getId() { 
		return id;
	public void setId(Integer id) {
		this.id = id; 
	public String getName() {
		return name;
	public void setName(String name) {
		this.name = name;
Find the EmployeeResource.java.
package com.concretepage.reactor;
public class EmployeeResource {
        private String result;
        private Employee employee;
	public String getResult() {
		return result;
	public void setResult(String result) {
		this.result = result;
	public Employee getEmployee() {
		return employee;
	public void setEmployee(Employee employee) {
		this.employee = employee;

Create Consumer using reactor.function.Consumer

To create the consumer, our class must implement reactor.function.Consumer. We need to override accept method which has the argument as reactor.event.Event. To get the event data we can use the method as Event.getData. Here in this method, we are accessing a REST URL that will return the JSON data.
package com.concretepage.reactor;
import java.util.concurrent.CountDownLatch;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.client.RestTemplate;
import reactor.event.Event;
import reactor.function.Consumer;
public class MessageConsumer implements Consumer<Event<Integer>> {
    CountDownLatch latch;
    RestTemplate restTemplate = new RestTemplate();
    public void accept(Event<Integer> event) {
	EmployeeResource  empResource = restTemplate.getForObject("http://localhost:8080/empdata.jsp", EmployeeResource.class);
        System.out.println("Employee " + event.getData() + ":" + empResource.getEmployee().getName());

Create Producer

In the producer class, we are notifying consumer with a key and an event that is ready to be processed.
package com.concretepage.reactor;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.atomic.AtomicInteger;
import org.springframework.beans.factory.annotation.Autowired;
import reactor.core.Reactor;
import reactor.event.Event;
public class MessageProducer {
    Reactor reactor;
    CountDownLatch latch;
    public void publishEmployee(int numberOfEmp) throws InterruptedException {
        AtomicInteger counter = new AtomicInteger(1);
        for (int i=0; i < numberOfEmp; i++) {
            reactor.notify("employees", Event.wrap(counter.getAndIncrement()));

Configuration Class for Reactor

We need to create a reactor.core.Reactor bean that needs reactor.core.Environment as an argument.
package com.concretepage.reactor;
import java.util.concurrent.CountDownLatch;
import org.springframework.boot.autoconfigure.EnableAutoConfiguration;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import reactor.core.Environment;
import reactor.core.Reactor;
import reactor.core.spec.Reactors;
public class ReactorConfig {
    private static final int NUMBER_OF_EMP = 5;
    Environment env() {
        return new Environment();
    Reactor reactor(Environment env) {
        return Reactors.reactor()
    MessageConsumer consumer(){
    	return new MessageConsumer();
    MessageProducer producer(){
    	return new MessageProducer();
    public CountDownLatch latch() {
        return new CountDownLatch(NUMBER_OF_EMP);

Main Class to Run Example

Find the main class to run the example. Reactor provides Selectors to run our asynchronous and event-driven application. Here we using $ selector. Reactor.on method registers a consumer that is triggered when notification matches the given selector.
package com.concretepage.reactor;
import static reactor.event.selector.Selectors.$;
import org.springframework.context.annotation.AnnotationConfigApplicationContext;
import reactor.core.Reactor;
public class Main {
    public static void main(String[] args) throws InterruptedException {
       final int NUMBER_OF_EMP = 5;
       AnnotationConfigApplicationContext ctx = new AnnotationConfigApplicationContext();
       Reactor reactor = (Reactor)ctx.getBean("reactor");
       MessageConsumer consumer = (MessageConsumer)ctx.getBean("consumer");
       MessageProducer publisher = (MessageProducer)ctx.getBean("producer");
       reactor.on($("employees"), consumer);
Find the output.
Employee 2:Ram
Employee 4:Ram
Employee 3:Ram
Employee 5:Ram
Employee 1:Ram

Gradle for Spring and Reactor JAR Depedency

Find the gradle file to resolve the JAR dependency.
apply plugin: 'java'
apply plugin: 'eclipse'
archivesBaseName = 'Concretepage'
version = '1.0-SNAPSHOT' 
repositories {
    maven { url "https://repo.spring.io/libs-release" }
dependencies {
 	compile 'org.springframework.boot:spring-boot-starter:1.2.0.RELEASE'
 	compile 'org.projectreactor.spring:reactor-spring-context:1.1.3.RELEASE'
 	compile 'org.springframework:spring-web:4.1.3.RELEASE'
 	compile 'com.fasterxml.jackson.core:jackson-databind:2.5.0-rc1'
 	compile 'org.springframework.data:spring-data-commons:1.9.1.RELEASE'
 	compile 'org.springframework.boot:spring-boot-starter-security:1.2.0.RELEASE'
Now we are done. Enjoy Learning.

Download Source Code

comments powered by Disqus

Copyright ©2017 concretepage.com, all rights reserved |Privacy Policy | Contact Us