完成基本消息开发

722f4f1e · Joneq · a88eb837 · 722f4f1e · 722f4f1e · 722f4f1e
Commit 722f4f1e authored Sep 14, 2022 by Joneq
Showing with 148 additions and 10 deletions
README.md
internal/cmd/websocket/main.go
resource/public/html/css/bootstrap.min.css
resource/public/html/js/jquery.min.js
resource/public/html/websocket.html
--- a/README.md
+++ b/README.md
-# GoFrame Template For SingleRepo
-
-Project Makefile Commands: 
- `make cli`: Install or Update to the latest GoFrame CLI tool.
- `make dao`: Generate go files for `Entity/DAO/DO` according to the configuration file from `hack` folder.
- `make service`: Parse `logic` folder to generate interface go files into `service` folder.
- `make image TAG=xxx`: Run `docker build` to build image according `manifest/docker`.
- `make image.push TAG=xxx`: Run `docker build` and `docker push` to build and push image according `manifest/docker`.
- `make deploy TAG=xxx`: Run `kustomize build` to build and deploy deployment to kubernetes server group according `manifest/deploy`.
\ No newline at end of file
+基本环境
+    项目:ssh://git@git.ichunt.net:22611/gongyang/go-websocket.git
+    框架：go-frame      详细安装指南： GoFrame 项目开发指南
+    go verion：go version go1.17.8 darwin/amd64
+    prot：8199
+
+基本架构
+1 数据存入 
+队列和http_post请求l的两种方式
+结构体
+
+2 数据发送
+
+
+
+websocket demo文件  
+app_dir +resource/public/html/websocket.html
+127.0.0.1/ichunt/go-websocket/resource/public/html/websocket.html
\ No newline at end of file
--- a/internal/cmd/websocket/main.go
+++ b/internal/cmd/websocket/main.go
+package main
+
+import (
+	"github.com/gogf/gf/v2/frame/g"
+	"github.com/gogf/gf/v2/net/ghttp"
+
+	// "github.com/gogf/gf/v2/os/gctx"
+	"github.com/gogf/gf/v2/os/gfile"
+	"github.com/gogf/gf/v2/os/glog"
+)
+
+func main() {
+	s := g.Server()
+	s.BindHandler("/ws", func(r *ghttp.Request) {
+		var ctx = r.Context()
+		ws, err := r.WebSocket()
+		if err != nil {
+			glog.Error(ctx, err)
+			r.Exit()
+		}
+		for {
+			msgType, msg, err := ws.ReadMessage()
+			if err != nil {
+				return
+			}
+			if err = ws.WriteMessage(msgType, msg); err != nil {
+				return
+			}
+		}
+	})
+	s.SetServerRoot(gfile.MainPkgPath())
+	s.SetPort(8199)
+	s.Run()
+}
--- a/resource/public/html/css/bootstrap.min.css
+++ b/resource/public/html/css/bootstrap.min.css
--- a/resource/public/html/js/jquery.min.js
+++ b/resource/public/html/js/jquery.min.js
--- a/resource/public/html/websocket.html
+++ b/resource/public/html/websocket.html
+<!DOCTYPE html>
+<html>
+<head>
+    <title>gf websocket echo server</title>
+    <link rel="stylesheet" href="./css/bootstrap.min.css">
+    <script src="./js/jquery.min.js"></script>
+    <meta charset="utf-8" />
+</head>
+<body>
+<div class="container">
+    <div class="list-group" id="divShow"></div>
+    <div>
+        <div><input class="form-control" id="txtContent" autofocus rows="6" placeholder="请输入发送内容"></div>
+        <div><button class="btn btn-default" id="btnSend" style="margin-top:15px">发 送</button></div>
+    </div>
+</div>
+</body>
+</html>
+
+<script type="application/javascript">
+    // 显示提示信息
+    function showInfo(content) {
+        $("<div class=\"list-group-item list-group-item-info\">" + content + "</div>").appendTo("#divShow")
+    }
+    // 显示警告信息
+    function showWaring(content) {
+        $("<div class=\"list-group-item list-group-item-warning\">" + content + "</div>").appendTo("#divShow")
+    }
+    // 显示成功信息
+    function showSuccess(content) {
+        $("<div class=\"list-group-item list-group-item-success\">" + content + "</div>").appendTo("#divShow")
+    }
+    // 显示错误信息
+    function showError(content) {
+        $("<div class=\"list-group-item list-group-item-danger\">" + content + "</div>").appendTo("#divShow")
+    }
+
+    $(function () {
+        var url = "ws://127.0.0.1:8199/ws";
+        var ws  = new WebSocket(url);
+        try {
+            // ws连接成功
+            ws.onopen = function () {
+                showInfo("WebSocket Server [" + url +"] 连接成功！");
+            };
+            // ws连接关闭
+            ws.onclose = function () {
+                if (ws) {
+                    ws.close();
+                    ws = null;
+                }
+                showError("WebSocket Server [" + url +"] 连接关闭！");
+            };
+            // ws连接错误
+            ws.onerror = function () {
+                if (ws) {
+                    ws.close();
+                    ws = null;
+                }
+                showError("WebSocket Server [" + url +"] 连接关闭！");
+            };
+            // ws数据返回处理
+            ws.onmessage = function (result) {
+                showWaring(" > " + result.data);
+            };
+        } catch (e) {
+            alert(e.message);
+        }
+
+        // 按钮点击发送数据
+        $("#btnSend").on("click", function () {
+            if (ws == null) {
+                showError("WebSocket Server [" + url +"] 连接失败，请F5刷新页面!");
+                return;
+            }
+            var content = $.trim($("#txtContent").val()).replace("/[\n]/g", "");
+            if (content.length <= 0) {
+                alert("请输入发送内容!");
+                return;
+            }
+            $("#txtContent").val("")
+            showSuccess(content);
+            ws.send(content);
+        });
+
+        // 回车按钮触发发送点击事件
+        $("#txtContent").on("keydown", function (event) {
+            if (event.keyCode == 13) {
+                $("#btnSend").trigger("click");
+            }
+        });
+    })
+
+</script>
\ No newline at end of file