up

server/build/.gitignore

@@ -0,0 +1 @@
+/.git-hash

server/build/build-server.sh

@@ -0,0 +1,36 @@
+#!/bin/bash -e
+
+DIR=$(readlink -f "$0") && DIR=$(dirname "$DIR") && cd "$DIR"
+
+GIT_ROOT=$(git rev-parse --show-cdup 2>/dev/null)
+if [ -n "$GIT_ROOT" ]; then
+	TMPDIR="${GIT_ROOT}/tmp"
+fi
+
+. ./common.sh
+
+DATE=$(TZ='Asia/Shanghai' date '+%Y-%m-%d %H:%M:%S')
+GO_VERSION=$(go version)
+GIT_VERSION=$(./git-hash.sh)
+if [ "$DOCKER_RUNNING" == "yes" ] && [ -f .git-hash ]; then
+	GIT_VERSION=$(cat .git-hash || :)
+	HOSTNAME="docker"
+fi
+
+LDFLAGS="-X '${BUILD_PACKAGE}.BuildGoVersion=${GO_VERSION}' \
+	-X '${BUILD_PACKAGE}.BuildTime=${DATE}' \
+	-X '${BUILD_PACKAGE}.BuildType=${TYPE}' \
+	-X '${BUILD_PACKAGE}.BuildHost=${HOSTNAME}' \
+	-X '${BUILD_PACKAGE}.BuildGit=${GIT_VERSION}'"
+
+cd ../src
+
+if [ -d "vendor" ]; then
+	VENDOR="-mod=vendor"
+fi
+
+CGO_ENABLED=0 go build $VENDOR \
+	-ldflags "$LDFLAGS" \
+	-o "$EXE_NEXT" \
+	"../build/${TYPE}/"*.go \
+	2> >(while read -r line; do echo -e "\e[38;2;255;45;45;48;2;10;10;10m$line\e[0m" >&2; done)

server/build/common.sh

@@ -0,0 +1,18 @@
+BIN="orca-server"
+BUILD_PACKAGE="project/build"
+
+TYPE="${1:-dev}"
+
+if [ ! -f "${DIR}/${TYPE}/go.mod" ]; then
+	echo "no build \"${TYPE}\""
+	exit 1
+fi
+
+DIST_DIR="$(dirname "$DIR")/dist/${TYPE}"
+mkdir -p "$DIST_DIR"
+
+EXE="${DIST_DIR}/${BIN}"
+EXE_NEXT="${EXE}-next"
+
+PID_FILE="${EXE}.pid"
+LOG_FILE="${DIST_DIR}/server.log"

server/build/config.ini

@@ -0,0 +1 @@
+type = dev

server/build/dev/go.mod

@@ -0,0 +1,7 @@
+module dev
+
+go 1.17
+
+require project v0.0.0
+
+replace project v0.0.0 => ../../src

server/build/dev/main.go

@@ -0,0 +1,7 @@
+package main
+
+import "project"
+
+func main() {
+	project.Start()
+}

server/build/get-pid.sh

@@ -0,0 +1,36 @@
+#!/bin/bash -e
+
+DIR=$(readlink -f "$0") && DIR=$(dirname "$DIR") && cd "$DIR" || exit 1
+
+. ./common.sh
+
+if [ -n "$PID_FILE" ] && [ -f "$PID_FILE" ]; then
+	PID=$(cat "$PID_FILE" 2>/dev/null|| :)
+fi
+if [ -z "$PID" ] || [ -z "$EXE" ]; then
+	>&2 echo no pid or exec
+	exit 1
+fi
+
+EXE_LINK="/proc/${PID}/exe"
+
+if [ ! -L "$EXE_LINK" ]; then
+	>&2 echo "no pid $PID"
+	exit 2
+fi
+if [ ! -r "$EXE_LINK" ]; then
+	>&2 echo "can not read pid $PID"
+	exit 3
+fi
+
+EXE_READLINK=$(readlink -f "$EXE_LINK" || :)
+if [ -z "$EXE_READLINK" ]; then
+	>&2 echo "unknown pid $PID"
+	exit 4
+fi
+if [ "$EXE_READLINK" != "$EXE" ]; then
+	>&2 echo "pid $PID not file $EXE (${EXE_READLINK})"
+	exit 5
+fi
+
+echo "$PID"

server/build/git-hash.sh

@@ -0,0 +1,26 @@
+#!/bin/bash
+
+HASH=$(git rev-parse --short HEAD 2>/dev/null || :)
+if [ -z "$HASH" ]; then
+	echo "empty"
+	exit
+fi
+
+TAG=$(git describe --exact-match "$HASH" 2>/dev/null | head -n 1)
+if [ -n "$TAG" ]; then
+	HASH="$TAG"
+fi
+
+ST=$(git status -s -u | head -n 1)
+if [ -n "$ST" ]; then
+	HASH="${HASH}-dirty"
+fi
+
+BRANCH=$(git branch --no-color 2>/dev/null | sed -e '/^[^*]/d' -e "s/* \(.*\)/\1/")
+if [[ "$BRANCH" == *"("* ]]; then
+	BRANCH=''
+else
+	BRANCH="${BRANCH}:"
+fi
+
+echo "${BRANCH}${HASH}"

server/build/prod/go.mod

@@ -0,0 +1,7 @@
+module prod
+
+go 1.17
+
+require project v0.0.0
+
+replace project v0.0.0 => ../../src

server/build/prod/main.go

@@ -0,0 +1,7 @@
+package main
+
+import "project"
+
+func main() {
+	project.Prod()
+}

server/build/run-server.sh

@@ -0,0 +1,22 @@
+#!/bin/bash -e
+
+DIR=$(readlink -f "$0") && DIR=$(dirname "$DIR") && cd "$DIR" || exit 1
+
+. ./common.sh
+
+if [ ! -f config.ini ]; then
+	echo "type = $TYPE" > config.ini
+fi
+
+"${DIR}/build-server.sh" "$TYPE"
+echo 'done'
+
+echo
+"${DIR}/stop-server.sh" "$TYPE" || :
+echo 'done'
+
+mv "$EXE_NEXT" "$EXE"
+
+echo
+"${DIR}/start-server.sh" "$TYPE"
+echo 'done'

server/build/start-server.sh

@@ -0,0 +1,22 @@
+#!/bin/bash -e
+
+DIR=$(readlink -f "$0") && DIR=$(dirname "$DIR") && cd "$DIR" || exit 1
+
+. ./common.sh
+LOG="log file: $LOG_FILE"
+
+PID=$(./get-pid.sh "$TYPE" 2>/dev/null || :)
+if [ -n "$PID" ]; then
+	echo "server running, pid = $PID"
+	echo "$LOG"
+	exit
+fi
+
+ulimit -n 65535 >/dev/null 2>&1 || :
+echo "ulimit = $(ulimit -n)"
+
+nohup "$EXE" > "$LOG_FILE" 2>&1 &
+PID="$!"
+echo "$PID" > "$PID_FILE"
+echo "new server started, pid = $PID"
+echo "$LOG"

server/build/status.sh

@@ -0,0 +1,19 @@
+#!/bin/bash
+
+DIR=$(readlink -f "$0") && DIR=$(dirname "$DIR") && cd "$DIR" || exit 1
+
+. ./common.sh
+
+PID=$(./get-pid.sh "$TYPE")
+
+if [ -z "$PID" ]; then
+	exit
+fi
+
+cat "/proc/${PID}/limits"
+echo
+cat "/proc/${PID}/status"
+echo
+cat "/proc/${PID}/io"
+echo
+echo "more in /proc/${PID}"

server/build/stop-server.sh

@@ -0,0 +1,20 @@
+#!/bin/bash -e
+
+DIR=$(readlink -f "$0") && DIR=$(dirname "$DIR") && cd "$DIR" || exit 1
+
+. ./common.sh
+
+PID=$(./get-pid.sh "$TYPE" 2>/dev/null || :)
+if [ -z "$PID" ]; then
+	echo server is not running
+	exit
+fi
+
+echo 'stoping server' >> "$LOG_FILE" 2>&1 &
+
+echo "kill pid $PID $EXE"
+sudo kill "$PID"
+while [ -e "/proc/${PID}/exe" ];
+do
+	sleep 1;
+done;

server/dist/.gitignore

@@ -0,0 +1 @@
+*

server/src/build/build.go

@@ -0,0 +1,29 @@
+package build
+
+import "fmt"
+
+// BuildGoVersion ...
+var BuildGoVersion string
+
+// BuildTime ...
+var BuildTime string
+
+// BuildType ...
+var BuildType string
+
+// BuildHost ...
+var BuildHost string
+
+// BuildGit ...
+var BuildGit string
+
+// DumpBuildInfo ...
+func DumpBuildInfo() {
+	fmt.Println()
+	fmt.Println(BuildGoVersion)
+	fmt.Println(BuildTime)
+	fmt.Println(BuildType)
+	fmt.Println(BuildHost)
+	fmt.Println(BuildGit)
+	fmt.Println()
+}

server/src/config/config.go

@@ -0,0 +1,10 @@
+package config
+
+// config
+var (
+	Prod bool
+	Dir  string
+
+	MySQL     = `user:pass@/dbname`
+	StaticDir = `/tmp`
+)

server/src/config/init.go

@@ -0,0 +1,22 @@
+package config
+
+import (
+	"os"
+	"path/filepath"
+)
+
+func init() {
+
+	Dir, _ = filepath.Abs(filepath.Dir(os.Args[0]))
+
+	list := map[string]*string{
+		`ORCA_MYSQL`: &MySQL,
+		`STATIC_DIR`:    &StaticDir,
+	}
+	for k, v := range list {
+		s := os.Getenv(k)
+		if len(s) > 1 {
+			*v = s
+		}
+	}
+}

server/src/go.mod

@@ -0,0 +1,9 @@
+module project
+
+go 1.19
+
+require github.com/zhengkai/zog v1.0.3
+
+require github.com/zhengkai/life-go v1.0.3
+
+require github.com/prometheus/client_golang v1.14.0 // indirect

server/src/go.sum

@@ -0,0 +1,6 @@
+github.com/prometheus/client_golang v1.14.0 h1:nJdhIvne2eSX/XRAFV9PcvFFRbrjbcTUj0VP62TMhnw=
+github.com/prometheus/client_golang v1.14.0/go.mod h1:8vpkKitgIVNcqrRBWh1C4TIUQgYNtG/XQE4E/Zae36Y=
+github.com/zhengkai/life-go v1.0.3 h1:rzm+Hb8H4He5trWx3lthFEQPf3sHpns0bDZ7vubT6sI=
+github.com/zhengkai/life-go v1.0.3/go.mod h1:e2RGLfk+uRzjhRrMQash9X4iY3jAuGj99r0qj5JS7m4=
+github.com/zhengkai/zog v1.0.3 h1:dkJdXJKRjbqqlseFycA1d80AUU6HAZrPe4WplpmwTo4=
+github.com/zhengkai/zog v1.0.3/go.mod h1:dXbJ0XDMRXQX+XeNuIM9hJy/6OLRNtXHPq/86ll8u6I=

server/src/project.go

@@ -0,0 +1,27 @@
+package project
+
+import (
+	"project/build"
+	"project/config"
+	"project/zj"
+
+	"github.com/zhengkai/life-go"
+)
+
+// Start ...
+func Start() {
+
+	build.DumpBuildInfo()
+
+	zj.Init()
+
+	life.Wait()
+}
+
+// Prod ...
+func Prod() {
+
+	config.Prod = true
+
+	Start()
+}

server/src/web/server.go

@@ -0,0 +1,33 @@
+package web
+
+import (
+	"fmt"
+	"net/http"
+	"project/zj"
+	"time"
+)
+
+// Server ...
+func Server(port int) {
+
+	addr := fmt.Sprintf(`localhost:%d`, port)
+
+	mux := http.NewServeMux()
+	mux.HandleFunc(`/`, failbackHandle)
+
+	s := &http.Server{
+		Addr:         addr,
+		Handler:      mux,
+		ReadTimeout:  30 * time.Second,
+		WriteTimeout: 30 * time.Second,
+		IdleTimeout:  30 * time.Second,
+	}
+
+	zj.J(`start web server`, addr)
+
+	s.ListenAndServe()
+}
+
+func failbackHandle(w http.ResponseWriter, r *http.Request) {
+	zj.J(`failback handle`, r.URL.String())
+}

server/src/zj/init.go

@@ -0,0 +1,48 @@
+package zj
+
+import (
+	"path/filepath"
+	"project/config"
+
+	"github.com/zhengkai/zog"
+)
+
+// Init ...
+func Init() {
+
+	mainCfg := zog.NewConfig()
+	mainCfg.Caller = zog.CallerLong
+
+	infoCfg := mainCfg.Clone()
+	infoCfg.Color = zog.ColorInfo
+	infoCfg.LinePrefix = `[IO] `
+
+	debugCfg := mainCfg.Clone()
+	debugCfg.Color = zog.ColorLight
+	debugCfg.LinePrefix = `[Debug] `
+
+	errCfg := zog.NewErrConfig()
+	errCfg.Color = zog.ColorWarn
+	errCfg.LinePrefix = `[Error] `
+
+	baseLog.CDefault = mainCfg
+	baseLog.CDebug = debugCfg
+	baseLog.CInfo = infoCfg
+	baseLog.CError = errCfg
+	baseLog.CWarn = errCfg
+	baseLog.CFatal = errCfg
+
+	baseLog.SetDirPrefix(filepath.Dir(zog.GetSourceFileDir()))
+
+	// 生产环境走 docker，不写本地文件
+	if !config.Prod {
+
+		mainFile, _ := zog.NewFile(config.Dir+`/log/default.txt`, false)
+		infoFile, _ := zog.NewFile(config.Dir+`/log/io.txt`, false)
+		errFile, _ := zog.NewFile(config.Dir+`/log/err.txt`, true)
+
+		mainCfg.Output = append(mainCfg.Output, mainFile)
+		infoCfg.Output = append(infoCfg.Output, infoFile)
+		errCfg.Output = append(errCfg.Output, mainFile, errFile)
+	}
+}

server/src/zj/log.go

@@ -0,0 +1,36 @@
+package zj
+
+import "github.com/zhengkai/zog"
+
+var baseLog = &zog.Logger{}
+
+// J log
+var J = baseLog.Println
+
+// F log printf
+var F = baseLog.Printf
+
+// D debug log
+var D = baseLog.Debugln
+
+// DF debug printf
+var DF = baseLog.Debugf
+
+// W warn log
+var W = baseLog.Warningln
+
+// WF warn log
+var WF = baseLog.Warningf
+
+// IO ...
+var IO = baseLog.Infoln
+
+// IOF ...
+var IOF = baseLog.Infof
+
+// Watch ...
+var Watch = baseLog.WatchStack
+
+// N log nothing
+func N(x ...interface{}) {
+}