活性卡桑德拉

或是冒险从Cassandra被动地读取数据。

总览

让我们首先尝试从编程的角度定义什么是反应性。

功能反应式编程是使用功能性编程的构建块进行反应式编程的编程范例。

函数式编程是一种编程范例,是一种构建计算机程序的结构和元素的样式,这种处理将计算视为对避免状态和可变数据的数学函数的评估。 函数式编程强调产生仅取决于其输入而不取决于程序状态的结果的函数。

我们如何用Java进行函数式编程? Java是面向对象的编程语言,其中到处都有可变状态。

世界各地的所有Java开发人员都使用以下任何接口:

java.lang.Runnable,java.util.Comparator,java.util.concurrent.Callable或java.awt.event.ActionListener。 所有这些接口都只声明了一个方法。 这些接口被称为单一抽象方法或SAM。 使用这些流行的方法是创建匿名内部类。

public class RunnableTest {public static void main(Sting[] args){new Thread(new Runnable(){@Overridepublic void run(){System.out.println("A new thread is running ...");}}).start();}
}

由于语言规范中不包含函数,因此Java中的函数式编程非常困难。 通过引入“ lambda”,它将在Java 8中变得更加简单。 但是我们如何用Java进行函数式编程呢?

让我们看一个简单的例子。

@FunctionalInterface
public interface Worker {public void doWork();
}
public class FunctionalWorker {public static void main(String[] args){// anonymous inner class wayexecute( new Worker(){@Overridepublic void doWork() {System.out.println ("working ...");}});// lambda's wayexecute(() -> System.out.println("working in lambda's way ..."));}public static void execute(Worker worker){worker.doWork();}
}

响应式编程是一种围绕数据流和更改传播的编程范例。 例如,在命令式编程设置中,a:= b + c表示在表达式求值的瞬间,即为a分配了b + c的结果。 以后可以更改b或c的值,而不会影响a。 在反应式编程中,a的值将基于新值自动更新。

因此,我们应该对什么是功能响应式编程有一个很好的了解,让我们开始构建一个原型……

反应性地从Cassandra读取数据

卡桑德拉(Cassandra)是其中的NoSql存储之一,非常受欢迎。

假设我们必须构建一个头像服务。 该服务将把化身的元信息和内容直接存储在cassandra中。

我们正在使用的Java驱动程序通过executeAsync()方法为我们提供了查询cassandra异步的支持 。 调用此方法将返回一个Future。 众所周知,java Futures是可阻止的并且无法组成。

好的,所以我们有异步支持,但是我们仍然需要一种能够以被动方式读取它的方法……

Netflix建立了RxJava库,并在以后开源了该库,该库提供了Java(以及其他JVM语言)的功能性响应编程。

通过提供可过滤,选择,转换,组合和组成Observable的运算符的集合,Functional React提供了有效的执行和组合。

可以将Observable数据类型视为等效于Iterable的“推”,即“拉”。 使用Iterable,使用者从生产者和线程块中提取值,直到这些值到达为止。 与Observable类型相反,只要值可用,生产者就会将值推送给消费者。 这种方法更加灵活,因为值可以同步或异步到达。

Observable类型将四个缺少的语义添加到Gang of Four的Observer模式中,在Iterable类型中可用:

  1. 生产者向消费者发出没有更多可用数据的信号的能力。
  2. 生产者向消费者发出发生错误的信号的能力。

通过这两个简单的加法,我们统一了Iterable和Observable类型。 它们之间的唯一区别是数据流动的方向。 这一点非常重要,因为现在我们对Iterable执行的任何操作也可以对Observable执行。

让我们看看如何结合RxJava和Cassandra异步查询执行来构建Observable。

package net.devsprint.reactive.cassandra;import java.util.concurrent.ExecutorService;import rx.Observable;
import rx.Observer;
import rx.Subscription;
import rx.subscriptions.Subscriptions;import com.datastax.driver.core.ResultSet;
import com.datastax.driver.core.Session;
import com.google.common.util.concurrent.FutureCallback;
import com.google.common.util.concurrent.Futures;/*** Wraps an async execution of Datastax Java driver into an observable.* */
public class ObservableCassandra {public static Observable executeAsync(final Session execution,final String query, final ExecutorService executorService) {return Observable.create(new Observable.OnSubscribeFunc() {@Overridepublic Subscription onSubscribe(final Observer observer) {try {Futures.addCallback(execution.executeAsync(query),new FutureCallback() {@Overridepublic void onSuccess(ResultSet result) {observer.onNext(result);observer.onCompleted();}@Overridepublic void onFailure(Throwable t) {observer.onError(t);}}, executorService);} catch (Throwable e) {// If any Throwable can be thrown from// executeAsyncobserver.onError(e);}return Subscriptions.empty();}});}}

executeAsync()方法返回一个Guava可监听的Future 。 在此将来添加回调可以使我们正确地实现Observer接口。

一个简单的服务可以实现如下:

package net.devsprint.reactive.cassandra;import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;import rx.Observable;import com.datastax.driver.core.ResultSet;
import com.datastax.driver.core.Session;public class AvatarService {private static final String QUERY = "select * avatars";private static final ExecutorService executorService = Executors.newFixedThreadPool(Runtime.getRuntime().availableProcessors());private final Session session;public AvatarService(Session session) {this.session = session;}Observable getAvatars() {return ObservableCassandra.executeAsync(session, QUERY, executorService);}}

假设查询很繁重,我们将提供一个单独的执行上下文,在该上下文中将执行回调。

通过这两个类,我们可以启动Avatar服务,但它不会做任何事情。 仅当至少有一个订户时,它才会开始从Cassandra获取数据。 一个完整的例子可以在Reactive Cassandra中找到。

参考:来自Java日历日历博客的JCG合作伙伴 gciuloaica的Reactive Cassandra 。

翻译自: https://www.javacodegeeks.com/2014/01/reactive-cassandra.html

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/365767.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

UVA1602 Lattice Animals 搜索+剪枝

题目大意 给出一个$w\times h$的网格,定义一个连通块为一个元素个数为$n$的方格的集合$A,\forall x\in A, \exists y\in A$,使得$x,y$有一条公共边。现要求一个元素个数极多的连通块的集合$K_N$,使得$\forall A,B\in K_n$,不存在一…

js 停止事件冒泡 阻止浏览器的默认行为

在前端开发工作中,由于浏览器兼容性等问题,我们会经常用到“停止事件冒泡”和“阻止浏览器默认行为”。 浏览器默认行为: 在form中按回车键就会提交表单;单击鼠标右键就会弹出context menu. a标签 1..停止事件冒泡 JavaScrip…

魔域传说显示与服务器断开连接,《魔域传说》合服公告

8月2日合服公告亲爱的勇士,为了给大家提供更加优质的游戏体验,《魔域传说》将于2021年8月2日14:00对部分服务器进行合服维护,维护时长预计3小时,维护完成时间视维护情况可能提前或延后,在维护期间将不能登陆服务器&…

python怎么打开程序管理器_Python 进程管理工具 Supervisor 使用教程

因为我的个人网站 restran.net 已经启用,博客园的内容已经不再更新。请访问我的个人网站获取这篇文章的最新内容,Python 进程管理工具 Supervisor 使用教程 Supervisor 是基于 Python 的进程管理工具,只能运行在 Unix-Like 的系统上&#xff…

Hive的伴奏_OURDEN INSTRUMENTALS MIXTAPE Vol.108 “Sober” 伴奏合辑

OURDEN INSTRUMENTALS MIXTAPE Vol.108Sober曲目列表 Track List :Anne Tello – Love Transformation (Prod. By Peter Monk)Blac Youngsta – Left (Prod. By Yung Lan)Bling X – Missing You (Prod. By Phivestarr Productions)BlocBoy JB – Ali (Prod. By Denaro Love)Bl…

命名空间和程序集

命名空间 命名空间是在逻辑上分割代码,程序集是在物理上分割代码。 嵌套命名空间 namespace one { namespace two { } } 通过one.two引用内部嵌套的命名空间的代码。 命名空间不必和程序集同名。 类的可见性 internal 修饰的类,仅能在本程序集中访问。 p…

WebSocket和Java

WebSocket是一项很酷的新技术,它允许浏览器与服务器之间进行实时双向通信,而几乎没有开销。 我在这里想要做的是,提供一个非常简洁但足够全面的概述,以介绍如何开始使用该技术。 因此,从以下几件事开始: 在…

网页顶部进度条-NProcess.js

背景 有些网站,比如github上在查看项目文件夹层级时会在网页顶部出现一个 进度条,虽然是PC端却有一种移动端体验,个人认为可以提升使用体验,经查阅相关资料后,找到一个NProgress.js全站进度条插件 示例 在使用vue开发S…

点击图片放大至原始图片大小

有些时候为了排版的整洁,页面展示的图片不得不都是限定宽高的,如果想要点击图片放大至原始大小进行预览,再次点击回到原来样子,就要用到下面的代码了: var _w parseInt($(window).width());//获取浏览器的宽度$("…

ft服务器设置传输协议,ft服务器设置成主动模式

ft服务器设置成主动模式 内容精选换一换如果您选择使用SFS Turbo实现文件共享存储,此章节操作可跳过,您可以参见《SAP HANA用户指南》中的“格式化磁盘”章节,挂载Backup卷。NFS Server磁盘需要格式化,并挂载到相应的目录后&#…

c语言将字符串按空格分割_以空格作为分隔符的字符串三角形C语言

这是一个独特的三角形,它与所有其他三角形不同,它以这种方式打印由空格分隔的单词。我在寻找的答案不存在于任何其他问题中,已经检查过了。以空格作为分隔符的字符串三角形C语言输出应该是这样的这这是这是这是最好的这是最好的办法这是最好的…

制作逻辑卷快照

逻辑卷快照的功能是将逻辑卷的数据保存备份、以及快速的数据恢复 查看逻辑卷的详细信息:vgdisplay 对vg01卷组的lv01逻辑卷做一个名称为SNAP而大小为150M的逻辑卷快照: lvcreate -L 150M -s -n SNAP /dev/rhcsa/vo 查看逻辑卷和快照的信息: lvs 在逻辑卷中…

使用JPA标准@ViewScoped通过分页,过滤和排序进行Primefaces DataTable延迟加载

Primefaces数据表惰性分页有效,但是在Web上使用Criteria搜索完整示例后,我感到非常沮丧。 所以我混合了来自 http://stackoverflow.com/questions/13972193/how-to-query-data-for-primefaces-datatable-with-lazy-loading-and-pagination http://www.…

mysql text字段导出_Mysql数据库的各种命令:

一、连接MYSQL格式: mysql -h主机地址 -u用户名 -p用户密码1、连接到本机上的MYSQL。 首先打开DOS窗口,然后进入目录mysqlbin,再键入命令mysql -u root -p,回车后提示你输密码. 注意用户名前可以有空格也可以没有空格,…

微信浏览器返回刷新,监听微信浏览器返回事件,网页防复制,移动端禁止图片长按和vivo手机点击img标签放大图片

以下代码都经过iphone7,华为MT7 ,谷歌浏览器,微信开发者工具,PC端微信验证。如有bug,还请在评论区留言。 demo链接:https://pan.baidu.com/s/1c35mbjM 密码:5yyf 1.移动端微信浏览器返回刷新…

access数据库为什么一直登陆_为什么要养成用Access数据库保存数据的习惯?

我是宇哥,专门教数据库的,学办公软件的女同学没有不认识我的。一、今天强调一下:为什么要养成用标准数据库保存数据的习惯~其实制造业企业,都更倾向于用Access数据库保存日常数据,尤其是一些高端制造业&…

服务器主板北桥芯片组有哪些,主板芯片组_目前的主板芯片组都有哪些?

目前主流的芯片组有:Intel(英特尔)的、、、。AMD(超微)的、、、。nVidia的、、。芯片组就相当于主板的大脑,主板是什么芯片组决定了主板可以装什么处理器。因为主板芯片分为北桥芯片(离处理器近的)与南桥芯片(离处理器远的),它们一般是成对出…

快速安装puppeteer (跳过安装Chromium)

npm i --save puppeteer --ignore-scripts 设置镜像下载 npm config set PUPPETEER_DOWNLOAD_HOSThttps://npm.taobao.org/mirrors npm install --save puppeteer 转载于:https://www.cnblogs.com/jso0/p/10336205.html

python地板除与除法的区别_“地板除”还是“取整除”?地板除和天花板除floor division和ceil devision...

上一篇文章知识点太多,我需要一一查看理解。 在运算符 ➡ 算数运算符 ➡ 操作符 ➡ // 整除(地板除) 3//4 为什么叫地板除? 向下取整除,就是地板除 floor division 向上取整除,就是天花板除,cei…

运行,JUnit! 跑!!!

JUnit与JavaScript和SVN一起是程序员经常开始使用的一些技术,甚至没有读过一篇博客文章,更不用说一本书了。 也许这是一件好事,因为它们看起来足够简单且易于理解,因此我们无需任何手册即可立即使用它们,但这也意味着它…