エンドポイントの作成

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 com.volkruss.flextest.service.StreamingService;

import reactor.core.publisher.Mono;

@Configuration
public class VideoEndPoint {
	
	@Autowired
	private StreamingService service;
	
	@Bean
	public RouterFunction<ServerResponse> route(){
		return RouterFunctions.route()
				.GET("/video/{title}",this::handler)
				.build();	
	}
	
	private Mono<ServerResponse> handler(ServerRequest request){
		String title = request.pathVariable("title");
		return ServerResponse.ok()
				.contentType(MediaType.valueOf("video/mp4"))
				.body(this.service.get(title), Resource.class);
	}
}

/video/titleにアクセスした時にtitleの個所が、pathVariableにて取得できる
contentTypeをmp4にする
- Content-Type
bodyはこの後作成するサービスクラスから取得した動画(Resource)

動画ファイルの読み込み

次にStreamingServiceクラスを作成します

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.core.io.Resource;
import org.springframework.core.io.ResourceLoader;
import org.springframework.stereotype.Component;

import reactor.core.publisher.Mono;

@Component
public class StreamingService {
	
	private static final String FORMAT="classpath:videos/%s.mp4";
	
	@Autowired
	private ResourceLoader loader;
	
	public Mono<Resource> get(String title) {
		return Mono.fromSupplier( () -> this.loader.getResource(String.format(FORMAT, title)));
	}
}

ResourceLoaderを利用して動画ファイルを取得します
- ResourceLoader
fromSupplierメソッドでMonoを作成します
- やってることはResourceオブジェクトを取得しているだけです

動画の再生

以下にgacha.mp4という動画ファイルを置いています

ブラウザで/video/gachaにアクセスすると動画が再生されます。

HTMLとかで動画を再生させる時は、動画のダウンロードが終わってから再生が始まるので待ち時間が発生しますが、これは待ち時間が発生していません。

private Mono<ServerResponse> handler(ServerRequest request){
	System.out.println("range in bytes : " + request.headers().header("Range"));
	String title = request.pathVariable("title");
	return ServerResponse.ok()
			.contentType(MediaType.valueOf("video/mp4"))
			.body(this.service.get(title), Resource.class);
}

範囲リクエスト

動画のシークバーを動かすと、そのシークバーの位置を起点にした特定のバイト範囲のリクエストを送ります。

以下のようにログを出力する記載をして確認します

private Mono<ServerResponse> handler(ServerRequest request){
	System.out.println("range in bytes : " + request.headers().header("Range"));
	String title = request.pathVariable("title");
	return ServerResponse.ok()
			.contentType(MediaType.valueOf("video/mp4"))
			.body(this.service.get(title), Resource.class);
}

シークバーを動かして再生するたびに範囲に関するリクエストが行われていることがわかります

range in bytes : []

range in bytes : [bytes=0-]

range in bytes : [bytes=138248192-]

range in bytes : [bytes=65536-]

range in bytes : [bytes=28835840-]

range in bytes : [bytes=113410048-]

range in bytes : [bytes=458752-]

とはいっても私は詳しくなく、Rangeってなんですか？って感じなのでHTTP 範囲リクエストをご参照ください。

とりあえずシークバーを動かす度に部分的なバイト範囲に対するリクエストが送信されていることがわかります。

当然ですがシークバーを動かさなくてもこのリクエストは行われています。

このようにWebFluxを使うことでストリーミング再生も簡単に実装することができました。

参考

Spring Boot WebFlux – Video Streaming Example | JavaTechie

Spring Boot | WebFluxで動画をストリーミング再生する