Spring Boot - WebFlux - Video Streaming example

Hello everyone, today I am going to show you how to stream a video using Spring Boot + WebFlux. 
Streaming means the continuous transmission of video files from a server to a client. You can download the source code from our Github repository.

User Interface


Project Structure



Gradle Build(build.gradle) 

plugins {
   id 'org.springframework.boot' version '2.5.4'
id 'io.spring.dependency-management' version '1.0.11.RELEASE'
id 'java'
}

group = 'com.knf.demo'
version = '0.0.1-SNAPSHOT'
sourceCompatibility = '11'

repositories {
mavenCentral()
}

dependencies {
implementation 'org.springframework.boot:spring-boot-starter-webflux'
testImplementation 'org.springframework.boot:spring-boot-starter-test'
testImplementation 'io.projectreactor:reactor-test'
}

test {
useJUnitPlatform()
}

Controller(VideoStreamingController.class)

package com.knf.demo.controller;

import com.knf.demo.service.VideoStreamingService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.core.io.Resource;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestHeader;
import org.springframework.web.bind.annotation.RestController;
import reactor.core.publisher.Mono;
@RestController
public class VideoStreamingController {

@Autowired
private VideoStreamingService service;

@GetMapping(value = "video/{name}", produces = "video/mp4")
public Mono<Resource> getVideo(@PathVariable String title,
                              @RequestHeader("Range") String range) {
return service.getVideo(title);
}
}

Service(VideoStreamingService.class)

package com.knf.demo.service;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.core.io.Resource;
import org.springframework.core.io.ResourceLoader;
import org.springframework.stereotype.Service;
import reactor.core.publisher.Mono;

@Service
public class VideoStreamingService {

private static final String FORMAT = "classpath:mp4/%s.mp4";

@Autowired
private ResourceLoader resourceLoader;

public Mono<Resource> getVideo(String title) {
return Mono.fromSupplier(() -> this.resourceLoader.
                                   getResource( String.format(FORMAT, title)));
}

}

Configuration(EndPointConfig.class)

package com.knf.demo.config;
import com.knf.demo.service.VideoStreamingService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.core.io.Resource;
import org.springframework.http.MediaType;
import org.springframework.web.reactive.function.server.RouterFunction;
import org.springframework.web.reactive.function.server.RouterFunctions;
import org.springframework.web.reactive.function.server.ServerRequest;
import org.springframework.web.reactive.function.server.ServerResponse;
import reactor.core.publisher.Mono;

@Configuration
public class EndPointConfig {
@Autowired
private VideoStreamingService service;

@Bean
public RouterFunction<ServerResponse> router(){
return RouterFunctions.route()
.GET("video/{name}", this::videoHandler)
.build();
}

private Mono<ServerResponse> videoHandler(ServerRequest serverRequest){
String title = serverRequest.pathVariable("name");
return ServerResponse.ok()
.contentType(MediaType.valueOf("video/mp4"))
.body(this.service.getVideo(title), Resource.class);
}

}

Main Class(SpringWebfluxVideoStreamingExampleApplication.class)

package com.knf.demo;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication
public class SpringWebfluxVideoStreamingExampleApplication {

public static void main(String[] args) {
SpringApplication.
                run(SpringWebfluxVideoStreamingExampleApplication.class, args);
}

}

index.html

<!doctype html>
<html lang="en">
<head>
<meta charset="utf-8">
<meta name="viewport" content="width=device-width, initial-scale=1">
<link href="https://cdn.jsdelivr.net/npm/bootstrap@4.6.0/
                                                   dist/css/bootstrap.min.css">

<title>Spring WebFlux Video Streaming</title>
</head>
<body>

<div class="container">
<h2>Spring WebFlux Video Streaming Example</h2>
<video src="video/sample_960x540" width="750px"
                                  height="500px" controls preload="none">

</video>
</div>
<script src="https://ajax.googleapis.com/ajax/libs/jquery/
                                                  3.5.1/jquery.min.js"></script>
<script src="https://cdn.jsdelivr.net/npm/bootstrap@4.6.0/dist/
                                            js/bootstrap.bundle.min.js" ></script>

</body>
</html>

Run - Spring Boot Application


Download Source code: https://github.com/knowledgefactory4u/KnowledgeFactory


More Topics:

Java - Angular - VueJS - ReactJS

 

NodeJS - Angular - VueJS - ReactJS

Popular posts from this blog

Spring boot video streaming example-HTML5

DataTable-Pagination example with Spring boot, jQuery and ajax

10 Best Job Posting Sites 2021-2022

Spring boot web project free download:User Registration System

Spring Boot + JPA/Hibernate One to Many mapping example

5 Hardest Puzzle,100% fail answers

Java security AES,SHA256,SHA512,MD5-Spring Boot Project Free Download

Spring Boot-AngularJS-Bootstrap-JPA-CRUD

ReactJS - Bootstrap - Buttons

Spring Boot file upload/download example