2.8日学习打卡----初学RabbitMQ（三）
之前我们使用原生JAVA操作RabbitMQ较为繁琐，接下来我们使用SpringBoot整合RabbitMQ，简化代码编写创建SpringBoot项目，引入RabbitMQ起步依赖
Flink对接Kafka的topic数据消费offset设置参数
在 Flink 的配置文件（如 flink-conf.yaml）中，，可以通过设置以下参数来配置。是 Flink 中用于设置消费 Kafka topic 数据的起始 offset 的配置参数之一。参数是用于 Flink 1.14 版本及以上。在更早的版本中，可以使用。参数来设置消费 Kafka 数据
后端接口如何提高性能？从MySQL、ES、HBASE等技术一起探讨下！(摘抄)
后端接口如何提高性能？从MySQL、ES、HBASE等技术一起探讨下！
大数据在社交媒体行业的应用：用户行为分析和内容推荐
1.背景介绍社交媒体是现代互联网行业的一个重要领域，其核心是让用户在线交流互动。随着互联网的普及和用户数量的增加，社交媒体平台上产生的数据量巨大，这些数据包括用户的个人信息、互动记录、内容等。大数据技术在社交媒体行业中发挥着重要作用，主要体现在用户行为分析和内容推荐等方面。本文将从大数据的角度深入探
RabbitMQ消息可靠性投递与ACK确认机制
deliveryTag介绍：表示消息投递序号，每次消费消息或者消息重新投递后，deliveryTag都会增加。basicNack和basicReject介绍。开启confirmCallback配置。RabbitMQ的ACK介绍。配置文件开启手动确认。
spring boot rabbitmq常用配置
【代码】spring boot rabbitmq常用配置。
用友U8 Cloud ArchiveVerify SQL注入漏洞复现
用友U8 Cloud ArchiveVerify接口处存在SQL注入漏洞，未授权的攻击者可通过此漏洞获取数据库权限，从而盗取用户数据，造成用户信息泄露。
flink数据源#
这两种情况之间的差异很小：在有界/批处理情况下，枚举器会生成一组固定的拆分，并且每个拆分必然是有限的。在无界流式处理情况下，两者之一不成立（拆分不是有限的，或者枚举器不断生成新的拆分）。一旦找到新文件，它就会为它们生成新的拆分，并可以将它们分配给可用的 SourceReaders。是源使用的数据的一
springCloud使用apache的http类和RestTemplate以及Eureka
然后访问Eureka的页面，
Nacos、Eureka、Zookeeper注册中心的区别
Nacos、Eureka和Zookeeper都是常用的注册中心，它们在功能和实现方式上存在一些不同。
hive的应用场景
hive的具体应用
Springboot教程（二）——过滤器、拦截器
这里要注意，过滤器最后应调用chain.doFilter(request, response)方法，将请求交给后一个过滤器。当然，有些时候不想交给后一个过滤器，也可以不写要启用过滤器，需要写一个配置类，用@Configuration标注。在配置类中，定义一个方法，用@Bean标注，这个方法需要先获取
2024-02-26（Spark，kafka）
1）SparkSQL和Hive都是用在大规模SQL分布式计算的计算框架，均可以运行在YARN上，在企业中被广泛应用。2）SparkSQL的数据抽象为：SchemaRDD（废弃），DataFrame（Python，R，Java，Scala），DataSet（Java，Scala）3）DataFrame
FlinkSQL处理Canal-JSON数据
在正常的操作环境下，Canal能够以exactly-once的语义投递每条变更事件，Flink能够正常消费Canal产生的变更事件。此时，Canal可能会投递重复的变更事件到Kafka中，当Flink从Kafka中消费的时候就会得到重复的事件，可能导致Flink query的运行得到错误的结果或者非
探索Hadoop的三种运行模式：单机模式、伪分布式模式和完全分布式模式
Hadoop作为一种强大的大数据处理框架，有多种运行模式，每种模式都适用于不同的使用场景。本文将介绍Hadoop的三种常见运行模式：单机模式、伪分布式模式和完全分布式模式。
RabbitMQ基础篇
SpringAMQP是基于RabbitMQ封装的一套模板，并且还利用SpringBoot对其实现了自动装配，使用起来非常方便。自动声明队列、交换机及其绑定关系基于注解的监听器模式，异步接收消息封装了RabbitTemplate工具，用于发送消息Publisher：生产者，也就是要发送消息的程序，但是
Hadoop-Yarn-启动篇
1、用户执行./start-yarn.sh2、start-yarn.sh中依次启动resourceManager、nodemanager、proxyserver3、根据yarn命令和hadoop-functions.sh找到三个角色的启动类，并且在本地或者远程（通过ssh的方式）启动各自的java进
深入理解SpringCloud之Eureka
Eureka允许服务实例在注册时添加元数据，这些元数据可以包含任何自定义信息，比如服务版本、环境标签等。这些信息可以用于服务间的智能路由决策。eureka:instance:version: 1.0.0 # 服务版本environment: 测试环境 # 服务运行的环境这样，当客户端发现服务时，就可
Flink基本原理 + WebUI说明 + 常见问题分析
Flink基本原 + 框架解析 + 如何通过WebUI排查常见问题
智能城市与大数据：如何提高城市的综合治理能力
1.背景介绍随着人类社会的发展，城市化进程加速，人口密度不断增加，城市规模不断扩大。这导致了城市面临的各种挑战，如交通拥堵、环境污染、资源不足、安全隐患等。为了应对这些问题，人工智能、大数据技术在城市治理中发挥了越来越重要的作用。智能城市是一种利用信息技术和人工智能等新兴技术，为城市管理和治理提供支
