草庐IT

Streaming模式

全部标签

java - 如何在 Spring Boot 中全局配置 `@DateTimeFormat` 模式?

我是我的SpringBoot应用程序,我有一些接受日期作为查询参数的Controller:@RestControllerpublicclassMyController{@GetMappingpublicResponseEntitygetDataByDate(@RequestParam(value="date")@DateTimeFormat(iso=DateTimeFormat.ISO.DATE)finalLocalDatedate){returnResponseEntity.ok();}}效果很好,我什至可以使用@RequestParam(value="date",required=

Java,设计模式 : Multiple event sources and One event Handler

我想在具有多个事件源(线程)的Java中实现一个设计。这样的事件源完成一个特定的任务,必须通知唯一的事件处理程序(类),这个事件处理程序必须根据事件源通知完成其他任务。我的问题是:如何在Java中以适当的方式实现这个设计?有类似这种设计的设计模式吗?提前谢谢你:)。 最佳答案 我认为您正在寻找Observer图案。Java确实有一些标准接口(interface)(java.util.Observer、java.util.Observable),尽管这些接口(interface)不是特定于类型的;因此,如果域似乎需要它,您可能会考虑自

java - 需要设计/模式/结构帮助编写 java 'world'

我一直想用Java编写一个简单的世界,但我可以运行“世界”,然后在以后添加新对象(在世界开始运行时不存在)(模拟/观察future对象之间的不同行为)。问题是我不想在世界开始后停止或重新启动它,我希望它运行一个星期而不必重新编译它,但有能力放入对象并重做/重写/随着时间的推移删除/创建/改变它们。世界可以像一个10x10的x/y“位置”数组一样简单(想想棋盘),但我想需要某种ticktimer进程来监视对象并给每个对象(如果有的话)一个机会去“行动”(如果他们愿意的话)。示例:我在星期一编写了World.java并让它运行。然后在星期二,我编写了一个名为Rock.java的新类(它不会

java - gwt 序列化策略托管模式不同步

在托管模式下运行我的GWT应用程序(gwt2.0.4)时,调用在远程Tomcat上运行的RPC方法时,出现GWT序列化异常:INFO:GwtRpcEventSrvc:ERROR:Theserializationpolicyfile'/84EC7BA65AF8175BAA99B47877FDE163.gwt.rpc'wasnotfound;didyouforgettoincludeitinthisdeployment?SEVERE:GwtRpcEventSrvc:WARNING:FailedtogettheSerializationPolicy'84EC7BA65AF8175BAA99B

java - 在 Java 中尝试/执行模式实现

我是try/do(或trier/doer)模式的粉丝,这种模式最好使用out参数在C#中实现,例如:DateTimedate;if(DateTime.TryParse("2012-06-18",outdate)){//Dosomethingwithdate}我目前正在开发一个Java1.5项目,为此我正在使用一个名为TryResult的新类实现try/do模式,该类从任何实现try/do模式的方法返回:publicclassTryResult{privatebooleanmSuccess=false;privateResultTypemResult=null;publicTryResu

java - Spark Streaming 历史状态

我正在构建用于检测欺诈ATM卡交易的实时处理。为了有效地检测欺诈,逻辑需要卡的最后交易日期,每天(或最近24小时)的交易金额总和其中一个用例是,如果在该国家/地区的最后一次交易超过30天后在本国境外进行的卡交易,则发送可能存在欺诈的警报因此尝试将Spark流式处理视为一种解决方案。为了实现这一点(可能我缺少关于函数式编程的想法)下面是我的伪代码stream=ssc.receiverStream()//inputreceivers1=stream.mapToPair()//createskeywithcardandtransactiondateasvalues2=stream.reduc

java - 在 ArrayLists 中使用命令模式进行撤消和重做

所以我有一个程序,您可以在其中登录并在friends数组列表中添加/删除friend。我也可以喜欢某个东西,那个东西将被存储到likesarraylist中。我被要求为我执行的任何操作设置撤消和重做选项。所以我想加apple为好友。之后,当我选择撤消选项时,我可以撤消该操作,这样apple就不会成为我的friend。当输入是我输入要存储到friends数组列表中的任何名称或单词时,我如何使用CommandPattern来解决这个问题?我做了一些研究,发现使用命令模式可能是我最好的选择,因为这必须在我已有的Facebook类下完成。我假设我将不得不使用两个不同的堆栈,但我有点迷失了主题。

java - 工厂模式 : Validating input when creating a bean (Guice/Guava)

我正在编写一个新应用,使用Guice进行依赖注入(inject),并使用Guava的先决条件进行属性验证。我正在使用工厂模式根据外部输入创建bean。问题是,验证输入的首选方式是什么?(在可维护性、清晰度等方面)让我们假设这些类:Bean.javapublicinterfaceBean{publicObjectgetFoo();}BeanImpl.javapublicclassBeanImplimplementsBean{privatefinalObjectfoo;publicBeanImpl(Objectparam){foo=param;}@OverridepublicStringg

Java 枚举 - 枚举上的 Switch 语句与访问者模式 - 性能优势?

我已经搜索了好几天来找到这个基于性能的问题的答案。到目前为止,在浏览Internet之后,我了解到有几种方法可以在Java中使用枚举,详细记录在here中。.好吧,作为初学者肯定会喜欢在switch-case语句中使用枚举,这样可以使代码更加清晰和更好地理解。但另一方面,我们也有一个Visitor模式风格的枚举实现,这确保了类型安全和可扩展性,已讨论here.话虽如此,回到这个问题背后的最初想法,到目前为止,我了解到如果使用枚举正确设计了一个switch-case结构,这确保了case值不稀疏,并且Enum声明是在与switch-case语句相同的编译单元中,java编译器通过实现诸如

java - 命令模式 - 返回一个值

我正在使用命令模式通过TCP/IP套接字将命令从客户端传递到服务器。服务器将获取命令对象,将其反序列化,然后在命令对象上调用execute()。但是,我需要通过套接字将一个值传回给调用者。命令模式是否允许这样做?如果没有,是否有解决方法?我看过维基百科上的电灯开关示例,很棒,但是没有返回值。非常感谢任何建议。 最佳答案 您不应该在发送到远程服务器的Command上使用“execute()”方法,这在很多方面都很糟糕,尤其是在Java中。Command应该代表接收者应该采取的行动。在这种情况下是在某个对象上调用方法。Command模式