kafka概念介绍： 吞吐量：单位时间内处理的数据量。讲求的是单位时间内处理的数据量要大 Zookeeper是什么： 概念说明：zk是分布式环境下的第三方协同服务，帮助分布式系统，比如存储、计算、调度等均需要协同服务 特点特征：简单、易使用、高效、稳定 应用场景：核心是要解决一致性问题 分布式环境下的命名一致性问题 分布式服务环境下的高可用性问题 HA问题：high available 核心还是一个选举策略问题 代码实现

前言 大家好，本文是博主在负责对企业项目新技术引入时，考虑不周的点，文中以第一视角对整个过程进行复盘以及事后分析。以 Mycat 为例。希望对大家有所帮助~ 一、背景 在一次会议内容提到一个新的技术，是我没有涉及到的领域—分库分表技术预研，当时会议提到该领域其中一个技术点 Mycat 技术点，该技术是我没有涉及到，而在此次会议被安排负责该项技术的预研。 二、需求 接下来，我就花时间去了解 Mycat这个东西，网上各种找资料，说实话，资料还是非常的多的，当时的想法

1：SpringBoot版本选择 git地址: https://github.com/spring-projects/spring-boot/releases/ 如何选择版本 通过查看springboot的官方地址，截止2022年9月，最新版是2.7.3，那我们就要使用这个版本吗？非也，接下来我们还需要看springcloud的对应版本来选择springboot版本 官网推荐必须用2.x以后的版本 https://github.com/spring-projects

一、nginx常用配置命令 配置命令路径 /usr/local/nginx/sbin 查看nginx版本 ./nginx -v 停止nginx服务 ./nginx -s stop 启动nginx服务 ./nginx 重新加载nginx，适用于当nginx.conf配置文件修改后，使用下面命令可以使得配置文件生效 ./nginx -s reload 查看nginx服务是否运行 netstat -ntlp 二、nginx配置文件 由三部分组成

背景 本文基于spark 3.2 driver内存 2G 问题描述 在基于复杂的sql运行中，或者说是存在多个join操作的sql中，如果说driver内存不是很大的情况下，我们经常会遇到如下报错： Caused by: org.apache.spark.SparkException: Could not execute broadcast in 800 secs. You can increase the timeout for broadcasts via spark.sql.b

目录 1：配置热更新 1.1：方式一 1.2：方式二 2.配置共享 1）添加一个环境共享配置 2）在configservice中读取共享配置 3）运行两个ConfigApplication，使用不同的profile 4）配置共享的优先级 测试本地application.yml文件 测试：Nacos配置中心的configservice.yaml优先级 测试：Nacos配置中心的服务名-profile.yaml优先级 3：多服务共享配置 方式一： 方式二： 1：配

话不多说,直接上代码 #!/bin/bash # mysql备份脚本 #备份目录 backup_dir='/data/backup/' #备份库名列表,括号内多个数据库空格隔开 db_name_array="all" #备份时间 current_time=$(date +%Y%m%d_%H%M%S) #备份文件名(没用上) filepath=$backup_dir$db_name'_'$current_time'.sql' #备份多个数据库循环，利用管道命令连接gzip命令直接备份为gz压缩文

扇出（fanout）交换机是将接收到到消息广播给它知道的所有队列，从而实现生产者发送一条消息，可以供多个消费者消费。 案例：一个生产者发送一条消息，通过扇出交换机，广播给两个消费者消费，如下图：    1、创建连接获取信道RabbitUtils工具类，linux上需要关闭防火墙才可以连接上 //连接工厂，创建信道工具类 public class RabbitUtils { // 得到一个连接的 channel public static Channel getChan

1. 什么是Table API & SQL Table API& SQL 是一种关系型API，用户可以像操作MySQL数据库表一样的操作数据，而不需要写Java代码完成flink function，更不需要手工的优化Java代码调优。SQL对一个非程序员操作来讲，学习成本很低，如果一个系统提供SQL支持，将很容易被用户接受。 总结来说，关系型API的好处： 关系型API是声明式的 查询能够被有效的优化 查询可以高效的执行 “Everybody” kn

大家好，由于我想去北京找工作，但是发现北京人才济济，面试要求各种五花八门的卷，很多岗位都能胜任，但是因为专科学历，连面试机会都没有，不过今天我给大家带来的教程，是完全可以让大家应用到实际工作中快速使用的干货，并给大家准备了一套纯净版springboot+netty 4.x的源码实现方案,有支持qos1、qos2、qos3具体的示例，并有日志说明 码云地址：mqtt-netty: 基于springboot2.1.5,netty4.1.53.Final 实现mqtt服务，实现功能1.服务端发布主题

一.首先说一下，不超过500M的视频如何提供给前端，这种方式比较快速，但是对前端不友好，特别大的视频文件，浏览器无法播放。 下面是Java代码实例。 这种方式不需要引入依赖。首先进行配置 import org.springframework.core.io.FileSystemResource; import org.springframework.core.io.Resource; import org.springframework.stereotype.Component; im

我是 YYDataV数据可视化  专注于 数据可视化大屏，工厂扫码装箱系统 等 我的微信 6550523，多多交流 ~ 目录 效果展示 1.动态实时更新数据效果图 2.鼠标右键切换主题   一. 确定需求方案  1. 屏幕分辨率 2. 部署方式  二. 整体架构设计 三.开发思路 1. 数据爬取 requests 2.  数据准备 pandas 四.编码实现 （基于篇幅及可读性考虑，此处展示部分关键代码） 1. 前端html代码 2. 世界疫情地图