alpakka项目是一个基于akka-streams流处理编程工具的scala/java开源项目，通过提供connector连接各种数据源并在akka-streams里进行数据处理。alpakka-kafka就是alpakka项目里的kafka-connector。对于我们来说：可以用alpakka-kafka来对接kafka，使用kafka提供的功能。或者从另外一个角度讲：alpakka-kafka就是一个用akka-streams实现kafka功能的scala开发工具。
alpakka-kafka-consumer的功能描述很简单：向kafka订阅某些topic然后把读到的消息传给akka-streams做业务处理。在kafka-consumer的实现细节上，为了达到高可用、高吞吐的目的，topic又可用划分出多个分区partition。分区是分布在kafka集群节点broker上的。由于一个topic可能有多个partition，对应topic就会有多个consumer，形成一个consumer组，共用统一的groupid。一个partition只能对应一个consumer、而一个consumer负责从多个partition甚至多个topic读取消息。kafka会根据实际情况将某个partition分配给某个consumer，即partition-assignment。所以一般来说我们会把topic订阅与consumer-group挂钩。这个可以在典型的ConsumerSettings证实：
Scala是可伸缩语言(Scalable Language)的缩写，读作skah-lah， 于2004年1月20日发布了第一个公开版本。其实早在2001年，Martin Odersky就开始Scala的设计工作，Martin 是瑞士洛桑联邦理工大学（EPFL）计算机与通信科学学院的一名教授， Martin曾和Haskell 语言设计者之一 Philip Wadler合作，设计了一个原型系统GJ， 最终演变为 Java 泛型。Martin还曾受雇于 Sun 公司，编写了 javac 的参考编译器，这套系统后来
Akka-http的客户端Api应该是以HttpRequest操作为主轴的网上消息交换模式编程工具。我们知道：Akka-http是搭建在Akka-stream之上的。所以，Akka-http在客
关于grpc，在前面的scalaPB讨论里已经做了详细的介绍：google gRPC是一种全新的RPC框架，在开源前一直是google内部使用的集成工具。gRPC支持通过http/2实现protobuf格式数据交换。protobuf即protocol buffer，是google发明的一套全新的序列化传输协议serialization-protocol，是二进制编码binary-encoded的，相对java-object，XML，Json等在空间上占有优势，所以数据传输效率更高。由于gRPC支持http/2协议，可以实现双向通讯duplex-communication，解决了独立request/response交互模式在软件编程中的诸多局限。这是在系统集成编程方面相对akka-http占优的一个亮点。protobuf格式数据可以很方便的转换成 json格式数据，支持对外部系统的的开放协议数据交换。这也是一些人决定选择gRPC作为大型系统微服务集成开发工具的主要原因。更重要的是：用protobuf和gRPC进行client/server交互不涉及任何http对象包括httprequest,httpresponse，很容易上手使用，而且又有在google等大公司内部的成功使用经验，用起来会更加放心。
实际上很早就写了一系列关于akka-streams的博客。但那个时候纯粹是为了了解akka而去学习的，主要是从了解akka-streams的原理为出发点。因为akka-streams是akka系列工具的基础，如：akka-http, persistence-query等都是基于akka-streams的，其实没有真正把akka-streams用起来。这段时间所遇到的一些需求也是通过集合来解决的。不过，现在所处的环境还是逼迫着去真正了解akka-streams的应用场景。现状是这样的：跨入大数据时代，已经有大量的现代IT系统从传统关系数据库转到分布式数据库（非关系数据库）了。不难想象，这些应用的数据操作编程不说截然不同吧，肯定也会有巨大改变。特别是在传统SQL编程中依赖数据关系的join已经不复存在了，groupby、disctict等操作方法也不是所有的分布式数据库都能支持的。而这些操作在具体的数据呈现和数据处理中又是不可缺少的。当然，有很多需求可以通过集合来满足，但涉及到大数据处理我想最好还是通过流处理来实现，因为流处理stream-processing的其中一项特点就是能够在有限的内存空间里处理无限量的数据。所以流处理应该是分布式数据处理的理想方式了。这是这次写akka-streams的初衷：希望能通过akka-streams来实现分布式数据处理编程。
前段时间跟一个朋友聊起kafka,flint,spark这些是不是某种分布式运算框架。我自认为的分布式运算框架最基础条件是能够把多个集群节点当作一个完整的系统，然后程序好像是在同一台机器的内存里运行一样。当然，这种集成实现方式有赖于底层的一套消息系统。这套消息系统可以把消息随意在集群各节点之间自由传递。所以如果能够通过消息来驱动某段程序的运行，那么这段程序就有可能在集群中任何一个节点上运行了。好了，akka-cluster是通过对每个集群节点上的中介发送消息使之调动该节点上某段程序运行来实现分布式运算的。那么，kafka也可以实现消息在集群节点间的自由流通，是不是也是一个分布式运算框架呢？实际上，kafka设计强调的重点是消息的接收，或者叫消息消费机制。至于接收消息后怎么去应对，用什么方式处理，都是kafka用户自己的事了。与分布式运算框架像akka-cluster对比，kafka还缺了个在每个集群节点上的”运算调度中介“，所以kafka应该不算我所指的分布式运算框架，充其量是一种分布式的消息传递系统。实际上kafka是一种高吞吐量、高可用性、安全稳定、有良好口碑的分布式消息系统。
使用gRPC作为云平台和移动前端的连接方式，网络安全应该是必须考虑的一个重点。gRPC是支持ssl/tls安全通讯机制的。用了一个周末来研究具体使用方法，实际上是一个周末的挖坑填坑过程。把这次经历记录下来与各位分享。
上面这段文字摘抄自 Akka 官网（akka.io），翻译成中文也就是：“Akka 是一个为 Java 和 Scala 构建高并发、分布式和弹性消息驱动应用程序的工具包”。而 Akka 具有的一切特性，其实都源自于一个用于处理并发计算问题的模型——Actor 模型。
MicrosoftInternetExplorer4 0 2 DocumentNotSpecified 7.8 磅 Normal 0 @font-face{ font-family:"Times New Roman"; } @font-face{ font-family:"宋体"; } @font-face{ font-family:"Calibri"; } @font-face{ font-family:"Liberation Serif"; } @font-face{ font
在日常运维工作中，常部署到的FTP是vsftpd和proftd。之前写了Linux下FTP虚拟账号环境部署总结，下面简单说下本地用户下的FTP环境部署过程： 简单梳理下FTP主动和被动两种工作模式： FTP协议有两种工作方式： 1）port方式：主动模式 port（主动）方式的连接过程是：客户端向服务器的FTP端口（默认是21）发送连接请求，服务器接受连接，建立一条命令链路。当需要传送数据时，服务器从20端口向客户端的空闲端口发送连接请求，建立一条数据链路来传送数据。 2）pasv方式：被动模式 pasv（
Akka 集群的核心是集群成员（cluster membership），以跟踪哪些节点是集群的一部分以及它们的健康状况。
最近，我一直在研究 Pulsar 及其与 Kafka 的比较。通过快速搜索，你会看到这两个最著名的开源消息传递系统之间正在进行的"战争"。
文件传输协议（File Transfer Protocol，FTP），基于该协议FTP客户端与服务端可以实现共享文件、上传文件、下载文件。 FTP 基于TCP协议生成一个虚拟的连接，主要用于控制FTP连接信息，同时再生成一个单独的TCP连接用于FTP数据传输。用户可以通过客户端向FTP服务器端上传、下载、删除文件，FTP服务器端可以同时提供给多人共享使用。
vsftpd 是“very secure FTP daemon”的缩写，安全性是它的一个最大的特点。vsftpd 是一个 UNIX 类操作系统上运行的服务器的名字，它可以运行在诸如 Linux、BSD、Solaris、 HP-UNIX等系统上面，是一个完全免费的、开放源代码的ftp服务器软件，支持很多其他的 FTP 服务器所不支持的特征。
VSFTP是一个基于GPL发布的类Unix系统上使用的FTP服务器软件，它的全称是Very Secure FTP 从此名称可以看出来，编制者的初衷是代码的安全。
ftp回话包含了两个通道，控制通道和数据通道，ftp的工作有两种模式，一种是主动模式，一种是被动模式，以ftpserver为参照物，主动模式，服务器主动连接客户端传输，被动模式，等待客户端的连接
Cataclysm：Dark Days Ahead 是一个回合制的生存游戏，设定在一个后启示录世界中。尽管有些人将其描述为 “僵尸游戏”，但 Cataclysm 远不止于此。在这个残酷、持久、程序生成的世界中努力生存下去吧！搜寻死亡文明的遗物，找到食物、装备或者幸运地发现一辆油箱满满的车来逃离危险。与各种强大怪兽作斗争，从僵尸到巨型昆虫再到杀手机器人以及更奇异和致命的东西，并对抗其他想要你拥有之物的人...
前言 经过前三篇文章的介绍，已经通过VMware安装了Hadoop的集群环境，当然，我相信安装的过程肯定遇到或多或少的问题，这些都需要自己解决，解决的过程就是学习的过程，本篇的来介绍几个Hadoop环境中需要用到的软件，确切的说是两款：VSFTP和SecureCRT。 闲言少叙，进入本篇的正题。 背景 这里简要说明下这两款软件的作用。 1、VSFTP这个从字面就能理解就是搭建FTP服务器用的，为什么要搭建FTP服务呢？ 我相信，如果按部就班的按照我之前的文章全装Hadoop的童鞋会发现一个很繁琐的过程，
关于Linux下搭建FTP服务的文章网上有很多，但是大部分都局限于某一点，在实际操作过程中会遇到各种问题，针对本人在使用中用到的一些设置和出现的问题对网络信息进行了归纳整理和总结。 示例操作系统：CentOS. 示例FTP软件：VSFTPD. 测试工具：windows cmd或者cuteftp、smartftp等工具 一、VSFTPD环境安装： 输入#rpm -qa |grep vsftpd检测是否安装了vsftpd软件， 如果没有安装，使用YUM命令进行安装。即yum install vsftpd
FTP服务器（File Transfer Protocol Server）是在互联网上提供文件存储和访问服务的计算机，它们依照FTP协议提供服务。
淘宝从2018年开始对整体架构进行反应式升级， 取得了非常好的成绩。其中『猜你喜欢』应用上限 QPS 提升了 96%，同时机器数量缩减了一半；另一核心应用『我的淘宝』实际线上响应时间下降了 40% 以上。PayPal凭借其基于Akka构建的反应式平台squbs，仅使用8台2vCPU虚拟机，每天可以处理超过10亿笔交易，与基于Spring实现的老系统相比，代码量降低了80%，而性能却提升了10倍。能够取得如此好的成绩，人们不禁要问反应式到底是什么？ 其实反应式并不是一个新鲜的概念，它的灵感来源最早可以追溯到90年代，但是直到2013年，Roland Kuhn等人发布了《反应式宣言》后才慢慢被人熟知，继而在2014年迎来爆发式增长，比较有意思的是，同时迎来爆发式增长的还有领域驱动设计(DDD)，原因是2014年3月25日，Martin Fowler和James Lewis向大众介绍了微服务架构，而反应式和领域驱动是微服务架构得以落地的有力保障。紧接着各种反应式编程框架相继进入大家视野，如RxJava、Akka、Spring Reactor/WebFlux、Play Framework和未来的Dubbo3等，阿里内部在做反应式改造时也孵化了一些反应式项目，包括AliRxObjC、RxAOP和AliRxUtil等。 从目前的趋势看来，反应式概念将会逐渐深入人心， 并且将引领下一代技术变革。
vsftp的用户有三种类型：匿名用户、系统用户、虚拟用户。 1）匿名登录：在登录FTP时使用默认的用户名，一般是ftp或anonymous。 2）本地用户登录：使用系统用户登录，在/etc/passwd中。 3）虚拟用户登录：这是FTP专有用户，有两种方式实现虚拟用户，本地数据文件和数据库服务器。 FTP虚拟用户是FTP服务器的专有用户，使用虚拟用户账号可以提供集中管理的FTP根目录，方便了管理员的管理，同时将用于FTP登录的用户名、密码与系统用户账号区别开，进一步增强了FTP服务器的安全性。某种意义上来说
Akka 是一个开源的并发、分布式、基于消息驱动的框架，用于构建高可伸缩性、可靠性和并发性强的应用程序。它是基于 JVM（Java虚拟机）的，主要使用 Scala 编程语言开发，但也提供了 Java API，因此可以在 Java 和 Scala 中使用。
FTP支持两种模式，一种方式叫做Standard (也就是 PORT方式，主动方式)，一种是 Passive (也就是PASV，被动方式)。
文件传输协议（英文：File Transfer Protocol，缩写：FTP）是用于在网络上进行文件传输的一套标准协议，使用客户/服务器模式。它属于网络传输协议的应用层。FTP 是相当古老的传输协议之一，他最主要的功能是在服务器与客户端之间进行档案的传输。 FTP 其实是以 TCP 封包的模式进行服务器与客户端计算机之间的联机，当联机建立后，此外，也可以直接管理用户在 FTP 服务器上面的档案，相当的方便！ 而这个古老的协议是使用明码传输，且过去有相当多的安全危机历史。为了更安全的使用 FTP 协议， 我们主要介绍较为安全但功能较少的 vsftpd 这个软件。今天这篇教程，我们将使用腾讯云CVM服务器来部署VSFTP所提供的FTP服务。
前面我们完成了一个CQRS模式的数据采集（录入）平台。可以预见：数据的产生是在线下各式各样的终端系统中，包括web、桌面、移动终端。那么，为了实现一个完整的系统，必须把前端设备通过某种网络连接形式与数据采集平台集成为一体。有两种方式可以实现需要的网络连接：Restful-api, gRPC。由于gRPC支持http/2通讯协议，支持持久连接方式及双向数据流。所以对于POS设备这样的前端选择gRPC作为网络连接方式来实现实时的操作控制应该是正确的选择，毕竟采用恒久连接和双向数据流效率会高很多。gRPC是google公司的标准，基于protobuffer消息：一种二进制序列化数据交换机制。gRPC的优势在这里就不再细说，读者可以参考前面有关gRPC的讨论博文。
如果安装了SElinux且不懂配置的，建议将其关闭。方法是修改/etc/selinux/config文件的如下内容：
虽然说现在已经有各种网盘服务，但是图方便的话最好还是有自己的ftp服务器，今天就介绍下在centos下安装vsftpd搭建ftp服务器。 首先更新下系统，可以使用yum把vsftpd服务安装上 yum update -y yum install vsftpd -y 安装完成后需要进行一些配置，打开 /etc/vsftpd/vsftpd.conf 更改如下三个参数 anonymous_enable=NO local_enable=YES chroot_local_user=YES 修改完后不要关闭，在后边加入
在这篇文章中，我将解释Kafka Streams抑制的概念。尽管它看起来很容易理解，但还是有一些内在的问题/事情是必须要了解的。这是我上一篇博文CDC分析的延续。
安装完后，有/etc/vsftpd/vsftpd.conf 文件，是vsftp的配置文件。 [root@linuxidc ~]# yum -y install vsftpd
二、实施步骤： 1、系统基础设置 计算机名、IP地址、网关、子网掩码、DNS设置 2、安装所需要的软件 Yum install httpd -y Yum install vsftpd* -y Yum install pam* -y Yum install mod_ssl* -y
FTP简介 FTP以它所使用的协议：文件传输协议（File Transfer Protocol）来命名的。FTP运行在OSI模型（Open System Interconnection model，开放系统互连模型）的应用层，并利用传输控制协议TCP在不同的主机之间提供可靠的数据传输。FTP是传输的所有文件都是通过“三次握手”来实现的，当数据包有丢失时，会重新传输，以保证数据可靠。
Ftp 介绍 文件传输协议（File Transfer Protocol，FTP），基于该协议FTP客户端与服务端可以实现共享文件、上传文件、下载文件。 FTP 基于TCP协议生成一个虚拟的连接，主要用于控制FTP连接信息，同时再生成一个单独的TCP连接用于FTP数据传输。用户可以通过客户端向FTP服务器端上传、下载、删除文件，FTP服务器端可以同时提供给多人共享使用。 FTP服务是Client/Server（简称C/S）模式，基于FTP协议实现FTP文件对外共享及传输的软件称之为FTP服务器源端，客户端程
大家好，我是架构君，一个会写代码吟诗的架构师。今天说一说Linux搭建FTP_linuxftp服务器配置,希望能够帮助大家进步!!!
我们在日常使用 UbuntuServer 服务器时，经常会直接使用基于 ssh 的 sftp 连接服务器直接进行文件上传和下载，不过这个方式其实有一定的安全隐患，当一个团队有多个人员，需要连接服务器去发布时，如果使用 ssh 则意味着需要将系统的 账户和密码 告知对方，别人就不仅拥有了 sftp 的连接权限，同时也拥有了 ssh 的连接权限，意味着可以直接登陆服务器，而且 对方使用 sftp 登陆之后可以看到服务器上全部的文件，这显示是不符合预期的，我们要的仅仅是给对方提供一个 ftp 文件上传下载的权限，并且最好能够限定到具体的目录。
本文介绍了Centos6.9安装vsftpd并配置多用户的方法，分享给大家，具体如下：
-v 表示设置目录映射 设置举例 -v /share:/home/vsftpd 将宿主机的/share目录映射到docker容器的/home/vsftpd (用户zhaoolee登录后, 程序会在/home/vsftpd文件夹下, 自动新建一个zhaoolee文件夹, 用来存放上传的文件)
描述: FTP只通过TCP连接,没有用于FTP的UDP组件.FTP不同于其他服务的是它使用了两个端口, 一个数据端口和一个命令端口(或称为控制端口)。通常21端口是命令端口，20端口是数据端口。当混入主动(Active)/被动模式(Passive)的概念时，数据端口就有可能不是20了。
上一节描述了如何使用 Actor 路径来启用位置透明（location transparency）。这个特殊的特性需要一些额外的解释，因为在编程语言、平台和技术的上下文中，相关术语“透明远程处理（transparent remoting）”的使用方式非常不同。
本文实例讲述了CentOS7服务器环境下vsftpd安装及配置方法。分享给大家供大家参考，具体如下：
一、概念 1.1介绍 FTP：File transfer protocol 文件传输协议 端口 TCP21:命令 TCP20:数据
FTP（文件传输协议）是一种常用的网络协议，用于在客户端和服务器之间进行文件传输。在 Ubuntu Linux 中，您可以设置和使用 FTP 服务器，以便通过网络与其他设备共享文件。本文将详细介绍如何在 Ubuntu Linux 中设置和使用 FTP 服务器。
用两台机器做实验，一台作为服务端（linux-001 192.168.141.128），一台作为客户端（linux-02 192.168.141.129）
DAS 指 Direct Attached Storage，即直连附加存储，这种设备直接连接到计算机主板总线上，计算机将其识别为一个块设备，例如常见的硬盘，U 盘等，这种设备很难做到共享。
vsftpd是一款运行在Linux操作系统上的FTP服务程序，不仅完全开源而且免费，此外，还具有很高的安全性、传输速度，以及支持虚拟用户验证等其他FTP服务程序不具备的特点。
为了使用分布式发布订阅（Distributed Publish Subscribe），你需要将以下依赖添加到你的项目中：
了解了kafka原理之后，对kafka的的应用场景有了一些想法。在下面的一系列讨论中把最近一个项目中关于kafka的应用介绍一下。
本人Linux菜鸟一枚，最近项目中有用到对ftp的操作，无奈身边一穷二白，什么都需要从头开始，各种百度和查询资料，千辛万苦，排除万难。终于搭建好服务，顺利访问。
领取专属 10元无门槛券
手把手带您无忧上云
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM
