1 package com.bawei.stream 2 3 import java.net.InetSocketAddress 4 5 import org.apache.spark.storage.StorageLevel 6 import org.apache.spark.streaming. ...
分类:
Web程序 时间:
2020-05-05 18:21:50
阅读次数:
79
一、背景 SpringBoot的应用监控方案比较多,SpringBoot+Prometheus+Grafana是目前比较常用的方案之一。它们三者之间的关系大概如下图: 关系图 二、开发SpringBoot应用 首先,创建一个SpringBoot项目,pom文件如下: <dependency> <gr ...
分类:
编程语言 时间:
2020-05-04 19:47:36
阅读次数:
141
服务端 Server package com.oy.groupchat; import io.netty.bootstrap.ServerBootstrap; import io.netty.channel.ChannelFuture; import io.netty.channel.Channel ...
分类:
Web程序 时间:
2020-05-04 09:13:45
阅读次数:
76
实例要求:1) 编写一个 Netty 群聊系统, 实现服务器端和客户端之间的数据简单通讯(非阻塞)2) 实现多人群聊3) 服务器端: 可以监测用户上线, 离线, 并实现消息转发功能4) 客户端: 通过 channel 可以无阻塞发送消息给其它所有用户, 同时可以接受其它用户发送的消息(有服务器转发得 ...
分类:
Web程序 时间:
2020-05-04 00:58:50
阅读次数:
97
1.基本说明 1) netty 的组件设计: Netty 的主要组件有 Channel、 EventLoop、 ChannelFuture、 ChannelHandler、 ChannelPipe 等2) ChannelHandler 充当了处理入站和出站数据的应用程序逻辑的容器。 例如, 实现 C ...
分类:
Web程序 时间:
2020-05-04 00:56:26
阅读次数:
66
基本介绍 1) Java 的 NIO, 用非阻塞的 IO 方式。 可以用一个线程, 处理多个的客户端连接, 就会使用到 Selector(选择器)2) Selector 能够检测多个注册的通道上是否有事件发生(注意:多个 Channel 以事件的方式可以注册到同一个Selector), 如果有事件发 ...
分类:
其他好文 时间:
2020-05-04 00:41:47
阅读次数:
77
golang语言特性:1、天然并发a.从语言层面支持并发,非常简单。b.goroute,轻量级线程,创建成千上万个goroute成为可能。c.基于CSP(CommunicationSequentialProcess通讯序列进程)模型实现。CSP:每个goroute之间通过管道(channel,类似linux/unix中的pipe)进行通讯,每个goroute都是独立的,是可调度的执行单位,比线程要
分类:
编程语言 时间:
2020-05-03 13:10:17
阅读次数:
69
1 package com.spark_sql 2 3 import java.util.Properties 4 import org.apache.spark.sql.{DataFrame, SparkSession} 5 6 object DataFromMysql { 7 def main( ...
分类:
数据库 时间:
2020-05-02 11:31:58
阅读次数:
63
1构建MySQL服务器1.1问题本案例要求熟悉MySQL官方安装包的使用,快速构建一台数据库服务器:安装MySQL-server、MySQl-client软件包修改数据库用户root的密码确认MySQL服务程序运行、root可控1.2方案本课程将使用64位的RHEL7操作系统,MySQL数据库的版本是5.7.17。访问http://dev.mysql.com/downloads/mysql/,找到
分类:
数据库 时间:
2020-05-02 09:21:28
阅读次数:
73
一、Flume的官方网站在哪里? http://flume.apache.org/ 二、Flume部署与测试 2.1 JDK安装 解压: tar zxvf jdk 7u55 linux x64.gz 2.2 Flume安装 安装包下载网址: apache flume 1.5.0 bin.tar.gz ...
分类:
Web程序 时间:
2020-05-02 00:07:48
阅读次数:
72