Apache Kafka Streams for building Real Time Data Processing with STOMP over WebSocket using Spring Boot and Angular 8

Introduction In this tutorial I will show you how to work with Apache Kafka Streams for building Real Time Data Processing with STOMP over Websocket using Spring Boot and Angular 8. We will see how to build push notifications using Apache Kafka, Spring Boot and Angular 8. We need to provide some basic things that Kafka Streams requires, such as, the cluster information, application id, the topic to consume, Serdes to use, and so on. I will show you how to build the application using both gradle and maven build…

Continue

WebSocket on Spring MongoDB Reactive Programming

Introduction Here we will see an example on WebSocket on Spring MongoDB Reactive Programming. In past we have see few examples on WebSocket but this example will use Spring WebFlux, i.e., WebSocket on Spring Reactive API. WebFlux includes reactive WebSocket client and server support. Both client and server are supported on the Java WebSocket API (JSR-356), Jetty, Undertow, Reactor Netty, and RxNetty. On the server side, declare a WebSocketHandlerAdapter and then simply add mappings to WebSocketHandler-based endpoints.

Continue

Messaging with STOMP over WebSockets using Spring, Angular 8 and ActiveMQ

Introduction We will create push notify messaging with STOMP over WebSockets using Spring and ActiveMQ. We have seen similar tutorial at link https://roytuts.com/spring-boot-websocket-angularjs-gradle-example/, but we used in-memory message broker but here we will use external message broker – ActiveMQ. We will use Angular 8 for building front end or UI where message will be updated and displayed. We will use the same tutorial with some modification to the existing code.

Continue

Spring Boot WebSocket Angular 8 Gradle Example

Introduction WebSocket is a very thin, lightweight layer above TCP used to build interactive web applications that send messages back and forth between a browser and the server. The best examples are live updates websites, where once user access the website neither user nor browser sends request to the server to get the latest updates. Server only keeps sending the messages to the browser. In this example, I am building a WebSocket application with Spring Boot using STOMP Messaging to provide automatic updates on the greeting message depending on the…

Continue