編集履歴

質問編集履歴

サンプルコードの追加

2020/01/31 05:41

投稿

ryoyai

スコア5

test CHANGED Viewed

File without changes

test CHANGED Viewed

@@ -151,3 +151,383 @@
 アドバイスいただければ幸いです。
 よろしくお願いいたします。
+# 追記：サンプルコード
+ご指摘を受け、実際のプログラムの挙動に似せたものをサンプルコードとして作成してみました。
+これを作っている過程で気づいたのですが、このプログラムは**グローバル変数としてキャッシュ**を持っています。
+そのキャッシュデータに対する同時アクセス制御（`mutex`）に問題があるのではないかと思い、`mutex`まわりをいくつか修正してみたところ、停止現象がかなり減った感じがしています。
+そのため現時点ではグローバル変数への同時アクセスが影響しているのではないかと疑っています。
+（ただし、それがF5で解消するというのもよく分からない話のように思え、この点の疑問は残っています）
+**実際のプログラムに似せるため、プログラム内にファイルシステムへのアクセスが存在します。ご注意お願いします。**
+```go
+package main
+import (
+	"bufio"
+	"encoding/json"
+	"io/ioutil"
+	"log"
+	"net/http"
+	"os"
+	"path"
+	"strconv"
+	"sync"
+	"github.com/gorilla/mux"
+)
+var (
+	DataCache = map[string]string{}
+	Datapath  string
+	mutex     sync.RWMutex
+)
+type res_ping struct {
+	Msg string `json:"msg"`
+}
+func GetPing(w http.ResponseWriter, r *http.Request) {
+	log.Println("GetPingStart")
+	defer log.Println("GetPingEnd")
+	res := res_ping{Msg: "server_alive"}
+	b, _ := json.Marshal(res)
+	w.Write(b)
+}
+type res_get struct {
+	Msg string `json:"msg"`
+}
+func GetData(w http.ResponseWriter, r *http.Request) {
+	log.Println("GetDataStart")
+	defer log.Println("GetDataEnd")
+	line, _ := mux.Vars(r)["line"]
+	if line == "" {
+		line = "0"
+	}
+	mutex.RLock()
+	msg := DataCache[line]
+	mutex.RUnlock()
+	res := res_get{Msg: msg}
+	b, _ := json.Marshal(res)
+	w.Write(b)
+}
+type req_post struct {
+	Data string `json:"data"`
+}
+type res_post struct {
+	Msg string `json:"msg"`
+}
+func PostData(w http.ResponseWriter, r *http.Request) {
+	log.Println("PostDataStart")
+	defer log.Println("PostDataEnd")
+	body := r.Body
+	defer body.Close()
+	b, _ := ioutil.ReadAll(body)
+	req := req_post{}
+	_ = json.Unmarshal(b, &req)
+	data := req.Data
+	mutex.Lock()
+	defer mutex.Unlock()
+	file, _ := os.OpenFile(Datapath, os.O_WRONLY|os.O_APPEND, 0666)
+	defer file.Close()
+	file.WriteString(data + "\n")
+	file.Close()
+	readdata()
+	res := res_post{Msg: "OK"}
+	rb, _ := json.Marshal(res)
+	w.Write(rb)
+}
+func SetJsonheader(w http.ResponseWriter) {
+	w.Header().Set("Content-Type", "application/json")
+}
+func Wrap(f func(w http.ResponseWriter, r *http.Request)) func(w http.ResponseWriter, r *http.Request) {
+	return func(w http.ResponseWriter, r *http.Request) {
+		EnableCors(&w)
+		SetJsonheader(w)
+		f(w, r)
+	}
+}
+func EnableCors(w *http.ResponseWriter) {
+	(*w).Header().Set("Access-Control-Allow-Origin", "http://localhost:8004")
+	(*w).Header().Set("Access-Control-Allow-Methods", "POST, GET, OPTIONS, PUT, DELETE")
+	(*w).Header().Set("Access-Control-Allow-Headers", "Accept, Content-Type, Content-Length, Accept-Encoding, X-CSRF-Token, Authorization")
+}
+func setup() {
+	log.Println(Datapath)
+	file, err := os.Create(Datapath)
+	if err != nil {
+		log.Fatal(err)
+	}
+	defer file.Close()
+	// 実際の挙動に近づけるためにファイル書き込み（データ多め）をおこなっています。問題があれば適宜修正してください。
+	for i := 0; i < 10000; i++ {
+		_, _ = file.WriteString("data898999898989898998989ddddd\n")
+	}
+	file.Close()
+	readdata()
+	//DataCache["0"] = "data0"
+	//DataCache["1"] = "data1"
+	//DataCache["2"] = "data2"
+}
+func readdata() {
+	file, _ := os.Open(Datapath)
+	defer file.Close()
+	sc := bufio.NewScanner(file)
+	count := 0
+	for sc.Scan() {
+		DataCache[strconv.Itoa(count)] = sc.Text()
+		count++
+	}
+}
+func main() {
+	datadir := os.TempDir()
+	datapath := path.Join(datadir, "data_6f3eb709jlgq0w2h.txt")
+	Datapath = datapath
+	setup()
+	defer os.Remove(datapath)
+	r := mux.NewRouter()
+	r.HandleFunc("/ping", Wrap(GetPing)).Methods("GET", "POST", "OPTIONS")
+	r.HandleFunc("/data/{line}", Wrap(GetData)).Methods("GET", "OPTIONS")
+	r.HandleFunc("/data", Wrap(GetData)).Methods("GET", "OPTIONS")
+	r.HandleFunc("/data", Wrap(PostData)).Methods("POST", "OPTIONS")
+	srv := http.Server{
+		Addr:              ":48000",
+		Handler:           r,
+		TLSConfig:         nil,
+		ReadTimeout:       0,
+		ReadHeaderTimeout: 0,
+		WriteTimeout:      0,
+		IdleTimeout:       0,
+		MaxHeaderBytes:    0,
+		TLSNextProto:      nil,
+		ConnState:         nil,
+		ErrorLog:          nil,
+		BaseContext:       nil,
+		ConnContext:       nil,
+	}
+	log.Println("start")
+	srv.SetKeepAlivesEnabled(false)
+	err := srv.ListenAndServe()
+	if err != nil {
+		log.Fatalf(err.Error())
+	}
+}
+```

fetchを使用している点を追記

2020/01/31 05:41

投稿

ryoyai

スコア5

test CHANGED Viewed

File without changes

test CHANGED Viewed

@@ -120,7 +120,7 @@
-リクエストはブラウザから送る場合でも、ツール（postmanを使っています）で送る場合でも発生します。
+リクエストはブラウザ(`fetch`を使用)から送る場合でも、ツール（`postman`を使用）で送る場合でも発生します。
 発生頻度はそれなりに高く、リクエスト数十回に1回くらい見かける印象です（プロダクトでこの頻度だと使い物にならないと思います）。