家里蹲的狐狸按照逗比VPS监控的样子仿照做了一个
效果是这样的
知识点
按socket分为了客户端和服务端
index.html部分
<!doctype html>
<html lang="en">
<head>
<meta charset="utf-8">
<meta name="viewport" content="width=device-width, initial-scale=1">
<meta name="description" content="">
<title>Go语言与ajax示例</title>
<!-- Bootstrap core CSS -->
<link href="assets/dist/css/bootstrap.min.css" rel="stylesheet">
</head>
<body>
<div class="container themed-container">
<header class="d-flex justify-content-center py-3">
<p class="h2">系统信息</p>
</header>
<table class="table table-sm table-bordered" style="text-align: center;">
<thead>
<tr>
<th scope="col">节点名</th>
<th scope="col">在线时间</th>
<th scope="col">网络 ↓|↑</th>
<th scope="col">流量 ↓|↑</th>
<th scope="col">处理器</th>
<th scope="col">内存</th>
<th scope="col">硬盘</th>
</tr>
</thead>
<tbody>
<tr data-bs-toggle="collapse" data-bs-target="#tr1" aria-expanded="true">
<th scope="row">RackNerd2.5G</th>
<td id="day">8天</td>
<td id="net">1K | 2K</td>
<td id="speed">1G | 2G</td>
<td><div class="progress">
<div class="progress-bar bg-success" role="progressbar" aria-valuenow="0" aria-valuemin="0" aria-valuemax="100" id="cpu">0%</div></div></td>
<td><div class="progress">
<div class="progress-bar bg-success" role="progressbar" aria-valuenow="0" aria-valuemin="0" aria-valuemax="100" id="mem">0%</div></div></td>
<td><div class="progress">
<div class="progress-bar bg-success" role="progressbar" aria-valuenow="0" aria-valuemin="0" aria-valuemax="100" id="disk">0%</div></div></td>
</tr>
<tr>
<td colspan="16"><div id="tr1" class="collapse">
显示额外信息
</div></td>
</tr>
</tbody>
</table>
</article>
</div>
<script src="assets/dist/js/bootstrap.bundle.min.js"></script>
<script src="assets/dist/js/jquery-3.6.0.min.js"></script>
<script src="assets/dist/js/loli.js"></script>
</body>
</html>js部分
$(function (){
setInterval(myajax, 2000);
function myajax(){
$.get('/ajax',function(data,status){
if (status == 'success') {
cpuclass = data.Cpuused+"%"
memclass = data.Memused+"%"
diskclass = data.Diskused+"%"
$('#cpu').css("width",cpuclass)
$('#cpu').text(data.Cpuused+"%")
$('#mem').css("width",memclass)
$('#mem').text(data.Memused+"%")
$('#disk').css("width",diskclass)
$('#disk').text(data.Diskused+"%")
$('#net').text(data.Netsend+"G | "+data.Netrecv+"G")
$('#speed').text(data.Netdown+" | "+data.Netup)
$('#day').text(data.Uptime+"天")
$('#tr1').text("硬盘: "+data.Diskfree+"G/"+ data.Disktotal+'G | 内存: '+data.Memavailable+"G/"+ data.Memtotal+"G | Swap: "+data.Swapfree+"G/"+data.Swaptotal+"G")
}
});
};
});server服务端
package main
import (
"fmt"
"net"
"net/http"
"text/template"
)
type Consys struct {
data string
c net.Conn
}
var info string
func index(w http.ResponseWriter, r *http.Request) {
t, _ := template.ParseFiles("index.html") //找模板
t.Execute(w, nil) //执行模板
}
func ajax(w http.ResponseWriter, r *http.Request) {
w.Header().Set("Content-type", "application/json;charset=utf-8")
fmt.Fprintln(w,info)
}
func main() {
go startserver()//开个协程，要不然会跟http的监听有冲突
http.Handle("/assets/", http.StripPrefix("/assets/", http.FileServer(http.Dir("assets"))))
http.HandleFunc("/", index) //函数也是一种变量
http.HandleFunc("/ajax", ajax) //函数也是一种变量
http.ListenAndServe(":8082", nil)
}
func startserver(){
addr, _ := net.ResolveTCPAddr("tcp4", "localhost:8899")
lis, _ := net.ListenTCP("tcp4", addr)
fmt.Println("服务器已启动")
for {//通过gorountine，每个客户端分配一个独立协程。
conn, _ := lis.Accept()
go handleConn(conn)
}
fmt.Println("服务器结束")
}
func handleConn(conn net.Conn){
defer conn.Close()
b := make([]byte, 256)
for{
count, err := conn.Read(b)
if err != nil {//这里判断一下err，如果断开就跳出循环，关闭当前连接
fmt.Println(err.Error())
break
}
info = string(b[:count])
}
}client部分
package main
import (
"encoding/json"
"fmt"
"strconv"
"time"
net2 "net"
"github.com/shirou/gopsutil/cpu"
"github.com/shirou/gopsutil/disk"
"github.com/shirou/gopsutil/mem"
"github.com/shirou/gopsutil/net"
"github.com/shirou/gopsutil/host"
)
type Sys struct {
Cpuused int
Memused int
Memavailable float64
Swaptotal float64
Swapfree float64
Memtotal float64
Disktotal float64
Diskfree float64
Diskused int
Netsend float64
Netrecv float64
Netup string
Netdown string
Uptime int
}
func main(){
//服务器端ip和端口
conn, _ := net2.Dial("tcp", "localhost:8899")
//向服务端发送数据
s:=Sys{}
c := make(chan []byte,2)//设置2个缓存，这样取了一个就会马上放进去一个
go func() {
for{
s = getstatus()
d, _ := json.Marshal(s)
c<-d
}
}()
for{
conn.Write(<-c)
}
////关闭连接
conn.Close()
}
func toG(i uint64) float64 {
return float64(i) / 1024 / 1024 / 1024
}
func toKB(i uint64) float64 {
return float64(i) / 1024
}
func toMB(i uint64) float64 {
return float64(i) / 1024 / 1024
}
func Decimal(value float64) float64 {
value, _ = strconv.ParseFloat(fmt.Sprintf("%.2f", value), 64)
return value
}
func getNetSpeed() (string, string) {
// 读取所有网卡网速
Net, _ := net.IOCounters(true)
// 定义网速保存变量
var rx, tx uint64
// 循环网络信息
for _, nv := range Net {
// 去除多余信息
if "eth0" == nv.Name {
// 加上网速信息
rx += nv.BytesRecv
tx += nv.BytesSent
}
}
// 暂停一秒
time.Sleep(time.Second)
// 重新读取网络信息
Net, _ = net.IOCounters(true)
// 网络信息保存变量
var rx2, tx2 uint64
// 循环网络信息
for _, nv := range Net {
// 去除多余信息
if "eth0" == nv.Name {
// 加上网速信息
rx2 += nv.BytesRecv
tx2 += nv.BytesSent
}
}
// 两次相减
if toKB(rx2-rx) > 1024 || toKB(tx2-tx) > 1024 {
down:= strconv.FormatFloat(toMB(rx2 - rx),'f',2,64)+"MB/S"
up:= strconv.FormatFloat(toMB(tx2 - tx),'f',2,64)+"MB/S"
return down, up
} else {
down:= strconv.FormatFloat(toKB(rx2 - rx),'f',2,64)+"KB/S"
up:= strconv.FormatFloat(toKB(tx2 - tx),'f',2,64)+"KB/S"
return down, up
}
}
func getstatus() Sys {
s := Sys{}
m, _ := mem.VirtualMemory()
c, _ := cpu.Percent(time.Second, false)
d, _ := disk.Usage("/")
n, _ := net.IOCounters(true)
swap,_:=mem.SwapMemory()
s.Netsend = Decimal(toG(n[1].BytesSent))
s.Netrecv = Decimal(toG(n[1].BytesRecv))
s.Diskused = int(d.UsedPercent)
s.Diskfree = Decimal(toG(d.Free))
s.Disktotal = Decimal(toG(d.Total))
s.Memused = int(m.UsedPercent)
s.Memtotal = Decimal(toG(m.Total))
s.Memavailable = Decimal(toG(m.Available))
s.Cpuused = int(c[0])
s.Netdown, s.Netup = getNetSpeed()
s.Uptime = int(getUptime()/60/60/24)
s.Swaptotal=Decimal(toG(swap.Total))
s.Swapfree=Decimal(toG((swap.Free)))
return s
}
func getUptime() uint64 {//获取的是秒数
up, err := host.BootTime()
if nil != err {
return 0
}
return uint64(time.Now().Unix()) - up
}
现在只有一个客户端，下次实时多个客户端连接怎么传递数据到页面
