package cn.irisz.steam import org.apache.flink.api.common.RuntimeExecutionMode import org.apache.flink.streaming.api.scala._ import org.apache.flink.t ...
分类：
其他好文 时间：
2021-06-29 15:38:43
阅读次数：
0
01 背景 面对大量用户访问、高并发请求，单机网站可以从软硬件两个方面寻求解决方法： 1、硬件方面：可以使用高性能的服务器、大型数据库，存储设备，高性能Web服务器； 2、软件方面：采用高效率的编程语言(比如Go，Erlang，Scala)等。 但是，当单机容量达到极限时，我们需要考虑业务拆分和分布 ...
分类：
编程语言 时间：
2021-06-28 20:23:37
阅读次数：
0
关键点 概念的解析 kafka的架构图 架构深入 kafka的工作流程及文件存储机制 kafka的生产者：a.分区策略 b.数据可靠性保证 c.数据一致性保证 kafka的消费者：a.消费方式 b.分区分配策略 c.offset的维护 zookeeper的作用 Kafka常见面试题：根据问题去了解大 ...
分类：
其他好文 时间：
2021-06-28 18:56:22
阅读次数：
0
Scala-Hello World 目标，在本地启动一个项目，能够输出helloworld https://www.scala-lang.org/ 官网提供的下载安装方式有很多种。 推荐IDE： IDEA 和 VSCode 这里我安装了IDEA，就用了它。 创建scala文件的时候，提示安装Scal ...
分类：
其他好文 时间：
2021-06-25 17:00:41
阅读次数：
0
Scala 操作MySQL 本地之前安装过MySQL 启动： mysql.server start 停止： mysql.setver stop 登录： mysql -u root ; 登录root用户。 选择一个database ： use erwa 查看所有的database： show data ...
分类：
数据库 时间：
2021-06-25 17:00:08
阅读次数：
0
1.当extends app 时，可以引入变量，而使用main函数不能引入 extends app main 函数 2. extends app 会延迟加载，使用main函数更加稳定 等区别网络自行搜索 其他不同待补充 ...
分类：
移动开发 时间：
2021-06-24 18:03:37
阅读次数：
0
环境准备 kafka依赖zookeeper，所以搭建kafka需要先配置zookeeper。网格信息如下： zookeeper 192.168.56.101:2181 kafka1 192.168.56.101:9092 kafka2 192.168.56.101:9093 kafka3 192.1 ...
分类：
其他好文 时间：
2021-06-23 16:51:10
阅读次数：
0
1. 为什么你们公司选择RabbitMQ作为消息中间件 在消息队列选型时，我们调研了市场上比较常用ActiveMQ，RabbitMQ，RocketMQ，Kafka。 RabbitMQ相对成熟稳定，这是我们选择它最主要的原因。 社区比较活跃，有完善的资料可以参考。 Rabbitmq的吞吐量可以达到万级 ...
分类：
其他好文 时间：
2021-06-22 18:28:57
阅读次数：
0
官网下载Kafka 安装包，解压安装： http://kafka.apache.org/downloads.html 编辑配置文件 #将kafka文件夹复制到另外两台节点下 注意修改每个节点对应的server.properties文件的broker.id和listenrs 启动kafka # 登录z ...
分类：
系统相关 时间：
2021-06-21 20:02:59
阅读次数：
0
脚本位置 cd /home/hadoop/bin 脚本内容 vi kafka.sh #输入以下内容 #!/bin/bash case $1 in "start" ){ for(( i = 1;i <= 3;i = $i +1));do echo hadoop0$i kafka $1 ssh hado ...
分类：
其他好文 时间：
2021-06-20 18:41:23
阅读次数：
0
