commit

Author: faizakram

pom.xml

@@ -60,7 +60,11 @@
     		<artifactId>spring-security-taglibs</artifactId>
     		<version>${springsecurity.version}</version>
 		</dependency>
-
+		<dependency>
+			<groupId>ch.rasc</groupId>
+			<artifactId>sse-eventbus</artifactId>
+			<version>1.1.3</version>
+		</dependency>
 
 		<!-- Hibernate -->
 		<dependency>

src/main/java/com/faizakram/springmvc/configuration/AppConfig.java

@@ -7,6 +7,7 @@
 import org.springframework.context.annotation.Configuration;
 import org.springframework.context.support.ResourceBundleMessageSource;
 import org.springframework.format.FormatterRegistry;
+import org.springframework.scheduling.annotation.EnableScheduling;
 import org.springframework.web.servlet.config.annotation.EnableWebMvc;
 import org.springframework.web.servlet.config.annotation.PathMatchConfigurer;
 import org.springframework.web.servlet.config.annotation.ResourceHandlerRegistry;
@@ -17,7 +18,10 @@
 
 import com.faizakram.springmvc.converter.RoleToUserProfileConverter;
 
+import ch.rasc.sse.eventbus.config.EnableSseEventBus;
 
+@EnableScheduling
+@EnableSseEventBus
 @Configuration
 @EnableWebMvc
 @ComponentScan(basePackages = "com.faizakram.springmvc")

src/main/java/com/faizakram/springmvc/configuration/HibernateConfiguration.java

@@ -18,7 +18,7 @@
 
 @Configuration
 @EnableTransactionManagement
-@ComponentScan({ "com.faizakram.springmvc.configuration" })
+@ComponentScan({ "com.faizakram.springmvc" })
 @PropertySource(value = { "classpath:application.properties" })
 public class HibernateConfiguration {
 

src/main/java/com/faizakram/springmvc/controller/AppController.java

@@ -63,6 +63,11 @@ public String listUsers(ModelMap model) {
 		model.addAttribute("loggedinuser", getPrincipal());
 		return "userslist";
 	}
+	
+	@RequestMapping(value = "/notification", method = RequestMethod.GET)
+	public String notification(ModelMap model) {
+		return "notification";
+	}
 
 	/**
 	 * This method will provide the medium to add a new user.

src/main/java/com/faizakram/springmvc/controller/SseController.java

@@ -0,0 +1,40 @@
+package com.faizakram.springmvc.controller;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.RequestHeader;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestMethod;
+import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.servlet.mvc.method.annotation.SseEmitter;
+
+import com.faizakram.springmvc.service.DataEmitterService;
+
+import ch.rasc.sse.eventbus.SseEvent;
+import ch.rasc.sse.eventbus.SseEventBus;
+
+@RestController
+public class SseController {
+	@Autowired
+	private SseEventBus eventBus;
+	
+	@Autowired
+	private DataEmitterService dataEmitterService;
+	
+	/*public SseController(SseEventBus eventBus) {
+		this.eventBus = eventBus;
+	}*/
+	
+	@RequestMapping(value = "/register/{id}",method = RequestMethod.GET)
+	public SseEmitter register(@PathVariable("id") String id, @RequestHeader(value = "User-Agent") String userAgent) {
+		dataEmitterService.addListInfo(id);
+		System.out.println("TEST");		
+		if (userAgent.contains("Edge/")) {
+			return this.eventBus.createSseEmitter(id, 180_000L, false, true, SseEvent.DEFAULT_EVENT);
+		}
+		return this.eventBus.createSseEmitter(id, SseEvent.DEFAULT_EVENT);
+	}
+	
+	
+
+}

src/main/java/com/faizakram/springmvc/service/DataEmitterService.java

@@ -0,0 +1,61 @@
+package com.faizakram.springmvc.service;
+
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Random;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.context.ApplicationEventPublisher;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Service;
+
+import ch.rasc.sse.eventbus.SseEvent;
+import ch.rasc.sse.eventbus.SseEvent.Builder;
+
+@Service
+public class DataEmitterService {
+
+	@Autowired
+	private ApplicationEventPublisher eventPublisher;
+	private List<String> list = new ArrayList<String>();
+	private final static Random random = new Random();
+
+	public void addListInfo(String id) {
+		list.add(id);
+	}
+
+	private String randomData() {
+		StringBuilder sb = new StringBuilder("[");
+		for (int i = 0; i < 5; i++) {
+			sb.append(random.nextInt(31));
+			sb.append(",");
+		}
+		sb.replace(sb.length() - 1, sb.length(), "]");
+		return sb.toString();
+	}
+
+	@Scheduled(initialDelay = 2000, fixedRate = 5_000)
+	public void sendData() {
+
+		for (String str : list) {
+			if (list.indexOf(str) == 0) // this will help different Client
+
+				// this.eventPublisher.publishEvent(SseEvent.builder().addClientId(str).event("DataOnline").data("Goa").build());//
+				// You Call also pass with event name
+
+				this.eventPublisher.publishEvent(SseEvent.builder().addClientId(str).data(randomData()).build()); // Default
+																								// Event
+			// name
+			// (message)
+			else
+				// this.eventPublisher.publishEvent(SseEvent.builder().addClientId(str).event("DataOnline").data("Goa").build());//
+				// You Call also pass with event name
+				this.eventPublisher.publishEvent(SseEvent.builder().addClientId(str).data(randomData()).build()); // Default
+																													// Event
+			// name
+			// (message)
+		}
+
+	}
+
+}

src/main/java/com/faizakram/springmvc/service/UserProfileServiceImpl.java

@@ -10,7 +10,7 @@
 import com.faizakram.springmvc.model.UserProfile;
 
 
-@Service("userProfileService")
+@Service
 @Transactional
 public class UserProfileServiceImpl implements UserProfileService{
 

src/main/webapp/WEB-INF/views/notification.jsp

@@ -0,0 +1,30 @@
+<!DOCTYPE html>
+<html>
+<head>
+<title>sse-eventbus-demo with echarts</title>
+
+<style>
+  body div {
+	  padding: 5px; 
+      display: inline-block; 
+      height: 150px; 
+      width: 230px;
+      border: 1px solid lightgrey;
+  }
+</style>
+</head>
+
+<body style="padding: 40px">
+	<div id="chart1"></div>
+	<div id="chart2"></div>
+	<div id="chart3"></div>
+	<div id="chart4"></div>
+	<div id="chart5"></div>
+	
+	<script src="https://static.rasc.ch/echarts.min.js"></script>
+	<script src="static/js/eventsource.js"></script>
+	<script src="static/js/uuid.js"></script>
+	<script src="static/js/app.js"></script>
+</body>
+
+</html>

src/main/webapp/static/js/app.js

@@ -0,0 +1,96 @@
+function getChartOption(name, threshold) {
+	return {
+		series: [ {
+			startAngle: 180,
+			endAngle: 0,
+			center: [ '50%', '90%' ],
+			radius: 100,
+			min: 0,
+			max: 30,
+			name: 'Serie',
+			type: 'gauge',
+			splitNumber: 3,
+			data: [ {
+				value: 16,
+				name: name
+			} ],
+			title: {
+				show: true,
+				offsetCenter: [ '-100%', '-90%' ],
+				textStyle: {
+					color: '#333',
+					fontSize: 15
+				}
+			},
+			axisLine: {
+				lineStyle: {
+					color: [ [ threshold, '#ff4500' ], [ 1, 'lightgreen' ] ],
+					width: 8
+				}
+			},
+			axisTick: {
+				length: 11,
+				lineStyle: {
+					color: 'auto'
+				}
+			},
+			splitLine: {
+				length: 15,
+				lineStyle: {
+					color: 'auto'
+				}
+			},
+			detail: {
+				show: true,
+				offsetCenter: [ '100%', '-100%' ],
+				textStyle: {
+					color: 'auto',
+					fontSize: 25
+				}
+			}
+
+		} ]
+
+	};
+}
+
+var names = ['s1', 's2', 's3', 's4', 's5'];
+var threshold = [0.1, 0.2, 0.7, 0.5, 0.9];
+var gauges = [];
+
+for (let i = 0; i < names.length; i++) {
+	var chart = echarts.init(document.getElementById('chart'+(i+1)));
+	chart.setOption(getChartOption(names[i], threshold[i]));
+	gauges.push(chart);
+}
+
+var uuid = uuid.v4();
+
+var eventSource;
+
+window.onbeforeunload = () => {
+  if (eventSource) {
+    eventSource.close();
+  }
+}
+
+eventSource = new EventSource(`/SpringMVCHibernateWithSpringSecurity/register/${uuid}`);
+eventSource.addEventListener('message', response => {
+	for (let line of response.data.split('\n')) {
+		console.log(line);
+		handleResponse(JSON.parse(line));
+	}
+}, false);
+
+function handleResponse(data) {
+	for (let i = 0; i < 5; i++) {
+		gauges[i].setOption({
+			series: {
+				data: [ {
+					name: names[i],
+					value: data[i]
+				} ]
+			}
+		});
+	}
+}