1 前置阅读 在阅读本文章之前,你可以先阅读: Topshelf一个用于使用.NET构建Windows服务框架 2 使用 2.1 创建应用程序 首先,创建一个新的控制台应用程序并从nuget获取Topshelf和Microsoft.Extensions.Hosting软件包 Topshelf Mi
作为一个7年老.NET程序员,最近几年苹果慢慢接替微软,成为我心中最酷的科技公司。 为什么我会选择Mac os作为我的开发环境? 很多做.net的同学都使用Windows系统作为自己的开发环境,我其实也一样。 但是现在.NET Core已经跨平台了,微软也推出vs for mac的ide,我们没理
尊敬的园友: 非常非常对不起,我们没有照顾好园子,让园子出了一个巨大的bug。 7天还17年欠下的债(网站运营工作),四两拔万斤,我们的任何努力都是杯水车薪。 园子的一片狼藉,是我们根本来不及。 园子的一团混乱,是我们已手忙码乱。 博文只能推荐无能反对,不是我们不讲武德;博客后台无法保存草稿,不是
    在大型复杂的应用中,业务模块之间总是相互关联,相互纠缠。无论对业务管理或软件开发方面都会造成困惑:从业务管理方面难以厘清确切的管理范围和职责:就是说不知一项业务具体谁来管。在软件开发方面则无法确定开发人员的具体分工和维护责任,即确定一项业务功能具体靠谁来修改、优化。拿一个普通的网上购物过程
上一篇我们通过示范案例基本了解了一个独立交易类型的库存管理模块应该是怎样的一块业务。这篇我们讨论一些如何从技术上来实现这样的业务模块。讲确切点应该说如何借助kafka的特性来实现功能开发。 底层方面:多节点服务器集群、kafka分布部署。 对上一层主要关注partition相关的问题:partit
   alpakka-kafka-consumer的功能描述很简单:向kafka订阅某些topic然后把读到的消息传给akka-streams做业务处理。在kafka-consumer的实现细节上,为了达到高可用、高吞吐的目的,topic又可用划分出多个分区partition。分区是分布在
  alpakka项目是一个基于akka-streams流处理编程工具的scala/java开源项目,通过提供connector连接各种数据源并在akka-streams里进行数据处理。alpakka-kafka就是alpakka项目里的kafka-connector。对于我们来说:可以用
节日最后一天,没什么事情,想聊聊我对中国计算机技术发展的一个遗憾,为什么我们没有开发出自己的编程语言   1.华为推“智慧养猪”,或许暗示方向有变 近日,华为机器视觉总裁在微头条爆料称,华为机器视觉推出了智慧养猪方案。养殖业的发展方向是数字化、智能化和无人化。此前任正非接受媒体采访时也曾提
  前段时间跟一个朋友聊起kafka,flint,spark这些是不是某种分布式运算框架。我自认为的分布式运算框架最基础条件是能够把多个集群节点当作一个完整的系统,然后程序好像是在同一台机器的内存里运行一样。当然,这种集成实现方式有赖于底层的一套消息系统。这套消息系统可以把消息随意在集群各
作者:程序之心丁仪 来源:https://chengxuzhixin.com/blog/post/zen_me_cheng_wei_ji_shu_da_niu.html 天天写业务代码,感觉没长进,技术深度止步不前,感觉很烦躁。很多人都在问,怎么样才能成为技术大牛?机会总是留给有准备的
主流国产数据库 随着贸易战的升级 ,自主研发和知识产权也是一个大的趋势,达梦和人大金仓是国产数据库中比较主流的   1、达梦数据库 更接近Oracle,更偏向自主研发,对开发人员友好度不如金仓  达梦公司在总结DM系列产品研发与应用经验的基础上,坚持开放创新、简洁实用的理念,历经五年匠心
fink slink 后的数据被复写了??? 生产环境总会遇到各种各样的莫名其名的数据,一但考虑不周便是车毁人亡啊。   线上sink 流是es , es 的文档id 是自定义的 id+windowSatarTime 设window size = 10min , watermark 最大延
flink 处理实时数据的三重保障 window+watermark 来处理乱序数据对于 TumblingEventTimeWindows window 的元数据startTime,endTime 和程序启动时间无关,当你指定出 window.size 时, window的startTi
      什么是解释器与编译器 1、解释器 解释器是一种计算机程序,它将每个高级程序语句转换成机器代码。   2、编译器 把高级语言编写的程序转换成机器码,将人可读的代码转换成计算机可读的代码(0和1)。   3、机器语言 一个机器语言程序是由一系列二进制模式组成的(例 110110)
本文只是以left_join作为举例,right_join,full_join 等是同理的,大家可以自行扩展   1. 实验思路   1.提供两个流             nameStream: 用户名称信息从 9999 端口获取             ageStream: 有用户年龄
在实际的开发中,我们往往需要定义大量的类结构,来实现面向对象式的数据管理。考虑一种场景,这种场景下单个类管理的类成员变量有很多个,我们如何实现在少量代码编写的情况先实现一个类的序列化? 1. 在Java 中要实现一个类的序列化,需要 implements Serializable ,这个类
作者: Jiaming Song, Dongjie Shi, Gong, Qiyuan, Lei Xia, Wei Du, Jason Dai        随着深度学习项目从实验到生产的发展,越来越多的应用需要对深度学习模型进行大规模和实时的分布式推理服务。虽然已经有一些工具可用于相关任
   实际上很早就写了一系列关于akka-streams的博客。但那个时候纯粹是为了了解akka而去学习的,主要是从了解akka-streams的原理为出发点。因为akka-streams是akka系列工具的基础,如:akka-http, persistence-query等都是基于akk
在Java或Scala中存在三种特殊类型的值,分别是Infinity,-Infinity,NaN,但这三个特殊值只存在于Double类型的计算过程中,对于同样形式的计算整形数据则会抛出异常如1.0/0.0 和 1/0 是不一样的r def main(args: Array[Strin