后端代码实现一个webSocket的服务端，消息精准推送和批量推送代码如下：@ServerEndpoint(value = "/websocket")@Component@Slf4jpublic class WebSocketServer {// 静态变量，用来记录当前在线连接数。应该把它设计成线程安全的。private static int onlineCount = 0;private sta

docker安装prestodb大数据查询引擎安装条件docker镜像下载特殊说明： Catalog安装条件1.dockerdocker镜像下载我们对Markdown编辑器进行了一些功能拓展与语法支持，除了标准的Markdown编辑器功能，我们增加了如下几点新功能，帮助你用它写博客：下载地址： prestodb-sandbox执行下载镜像命令：sudo docker pull ahanaio/pr

部署前准备(需要root账号)节点主机名唯一，建议写入/etc/hosts禁止swap分区关闭防火墙root@haishu:/home/haishu# hostnamectl set-hostname k8s-masterroot@haishu:/home/haishu# tail /etc/hosts127.0.1.1haishu-System-Product-Name# The followi

场景：用户请求信息通过kafka到flink计算引擎，flink拿到请求信息后去查询三方数据处理，数据处理完成后把处理结果放回到kafka中。这里三方数据源两种：1.mysql数据源2.http三方接口项目地址：https://github.com/1105748319/flinkDemoTest.git下面直接上代码：主要的类：package com.flink;import org.apach

#flink连接kafka并读取数据前提条件flink版本1.11.2直接上代码import org.apache.flink.api.common.functions.FlatMapFunction;import org.apache.flink.api.common.restartstrategy.RestartStrategies;import org.apache.flink.stream