在优锐课的java 分享学习中,讨论关于让我们探索redis的异步,反应式和RxJava2接口。码了很多知识点,分享给大家参考学习。
成都创新互联2013年至今,先为平城等服务建站,平城等地企业,进行企业商务咨询服务。为平城企业网站制作PC+手机+微官网三网同步一站式服务解决您的所有建站问题。
异步,响应式和RxJava2都是Java编程语言中的所有相关编程模型。 但是,它们不能在Redis(用于实现内存中数据存储的开源软件项目)中自动提供。
好消息是,这三种编程模型都可以在Redis中使用Redisson(Redisson)来使用,Redisson是将Redis与Java集成的第三方客户端库。 在本文中,我们将讨论这三种模型中的每一种,以及如何使用Redisson在Redis中部署它们。
Redis的异步接口
异步编程是一种并行编程,其中任务与主应用程序在不同的线程上分别运行。 这允许应用程序在任务执行时继续运行。 一旦任务完成,它将通知主应用程序其成功或失败。
在Redisson中,每个异步方法都返回一个RFuture对象,该对象代表异步计算的结果。 RFuture在Java中实现java.util.concurrent.Future和java.util.concurrent.CompletionStage接口。
下面是一个如何使用RFuture在Redisson中应用异步编程模型的示例:
package redis.demo;
import org.redisson.Redisson;
import org.redisson.api.RBucket;
import org.redisson.api.RFuture;
import org.redisson.api.RMap;
import org.redisson.api.RedissonClient;
public class RedisAsyncTest {
public static void main( String[] args )
{
// connects to 127.0.0.1:6379 by default
RedissonClient redisson = Redisson.create();
// perform operations
RBucket<String> bucket = redisson.getBucket("simpleObject");
RFuture<Void> setFuture = bucket.setAsync("This is object value");
setFuture.onComplete((value, exception) -> {
// on invocation completion
});
RMap<String, String> map = redisson.getMap("simpleMap");
RFuture<String> putFuture = map.putAsync("mapKey", "This is map value");
putFuture.onComplete((value, exception) -> {
System.out.println("previous value: " + value);
});
RFuture<String> getFuture = bucket.getAsync();
getFuture.onComplete((value, exception) -> {
System.out.println("stored object value: " + value);
});
RFuture<String> getMapFuture = map.getAsync("mapKey");
getMapFuture.onComplete((value, exception) -> {
System.out.println("stored map value: " + value);
});
redisson.shutdown();
}
}
Redis的反应式界面
反应式编程模型是在Java 8的Reactor核心库中实现的。反应式流是异步流处理的规范,在该规范中,可以异步产生和使用许多不同的事件。 为了应对这种快速步伐,系统需要产生事件的速度不超过消耗事件的速度。
在Redisson中,每个反应式方法都返回一个react..core.publisher.Mono对象,该对象通过发出一个元素来表示已成功完成计算。
以下代码示例演示了如何在Redisson中使用Mono对象:
package redis.demo;
import org.redisson.Redisson;
import org.redisson.api.RBucketReactive;
import org.redisson.api.RMapReactive;
import org.redisson.api.RedissonReactiveClient;
import reactor.core.publisher.Mono;
public class RedisReactiveTest {
public static void main( String[] args )
{
// connects to 127.0.0.1:6379 by default
RedissonReactiveClient redisson = Redisson.createReactive();
// perform operations
RBucketReactive<String> bucket = redisson.getBucket("simpleObject");
Mono<Void> setMono = bucket.set("This is object value");
setMono.subscribe(value -> {
// on invocation completion
});
RMapReactive<String, String> map = redisson.getMap("simpleMap");
Mono<String> putMono = map.put("mapKey", "This is map value");
putMono.subscribe(value -> {
System.out.println("previous value: " + value);
});
Mono<String> getMono = bucket.get();
getMono.subscribe(value -> {
System.out.println("stored object value: " + value);
});
Mono<String> getMapMono = map.get("mapKey");
getMapMono.subscribe(value -> {
System.out.println("stored map value: " + value);
});
redisson.shutdown();
}
}
用于Redis的RxJava2接口
RxJava2是另一个实现异步和反应式编程的Java范例。 RxJava2的主要区别在于“可观察对象”(侦听发出数据的数据源)和“订户”(侦听一个或多个可观察对象)之间。
在Redisson中,每个RxJava方法都返回以下可观察对象之一:io.reactivex.Completable,io.reactivex.Maybe,io.reactivex.Flowable或io.reactivex.Single。
单一的:可观察的仅发出一个项目或一个值或引发错误。
也许:一个观测值发出零个或一个项目或值或引发错误。
可完成:任务完成时发出或抛出错误的可观察对象。
以下是如何在Redis和Redisson中使用RxJava2编程模型的示例:
package redis.demo;
import org.redisson.Redisson;
import org.redisson.api.RBucketRx;
import org.redisson.api.RMapRx;
import org.redisson.api.RedissonRxClient;
import io.reactivex.Completable;
import io.reactivex.Maybe;
public class RedisRxTest {
public static void main( String[] args )
{
// connects to 127.0.0.1:6379
RedissonRxClient redisson = Redisson.createRx();
// perform operations
RBucketRx<String> bucket = redisson.getBucket("simpleObject");
Completable completable = bucket.set("This is object value");
completable.subscribe(() -> {
// on invocation completion
});
RMapRx<String, String> map = redisson.getMap("simpleMap");
Maybe<String> putMaybe = map.put("mapKey", "This is map value");
putMaybe.subscribe(value -> {
System.out.println("previous value: " + value);
});
Maybe<String> getMaybe = bucket.get();
getMaybe.subscribe(value -> {
System.out.println("stored object value: " + value);
});
Maybe<String> mapGetMaybe = map.get("mapKey");
mapGetMaybe.subscribe(value -> {
System.out.println("stored map value: " + value);
});
redisson.shutdown();
}
}
文章写道这里,如有不足之处,欢迎补充评论。
如果你对java技术很感兴趣也可以一起交流学习,共同学习进步!
最近get了很多新知识,希望能帮到大家。需要详细的java架构思维导图路线也可以评论获取!
标题名称:Redis的异步,响应式和RxJava2接口
URL地址:https://www.cdcxhl.com/article20/igjjjo.html
成都网站建设公司_创新互联,为您提供做网站、服务器托管、定制网站、品牌网站制作、品牌网站建设、小程序开发
声明:本网站发布的内容(图片、视频和文字)以用户投稿、用户转载内容为主,如果涉及侵权请尽快告知,我们将会在第一时间删除。文章观点不代表本网站立场,如需处理请联系客服。电话:028-86922220;邮箱:631063699@qq.com。内容未经允许不得转载,或转载时需注明来源: 创新互联