Redis の WebAPI (Gin)

こちらで定めた仕様を満たすサーバーサイドのプログラムです。
Redis の WebAPI を作成

次のプログラムを改造しました。
Gin の使い方

redis_api.go

// ---------------------------------------------------------------
//
//	redis_api.go
//
//					Jan/28/2021
// ---------------------------------------------------------------
package main

import "github.com/gin-gonic/gin"
import "net/http"
import (
	"os"
	"fmt"
	"net"
	"strings"
	"encoding/json"
)

// ---------------------------------------------------------------
func main() {
	router := gin.Default()

	router.GET("/user/:name", func(c *gin.Context) {
		name := c.Param("name")
		c.String(http.StatusOK, "Hello %s", name)
	})

	router.POST("/redis_read", func(c *gin.Context) {
		key := c.PostForm("key")
		message := read_proc(key)
		c.String(http.StatusOK, message)
	})

	router.POST("/redis_insert", func(c *gin.Context) {
		key := c.PostForm("key")
		value := c.PostForm("value")
		message := insert_proc(key,value)
		c.String(http.StatusOK, message)
	})

	router.POST("/redis_list", func(c *gin.Context) {
		message := list_proc()
		c.String(http.StatusOK, message)
	})
	router.Run(":8080")
}

// ---------------------------------------------------------------
// [4]:
func read_proc(key string) string {
	fmt.Fprintf (os.Stderr,"*** read_proc ***\n")
	hostname := "localhost"
	port := "6379"

	conn, err := net.Dial ("tcp", hostname + ":" + port)
	if err != nil {
		fmt.Println(err)
		return "err"
		}

	json_str := mcached_socket_read_proc (conn,key)
	conn.Close ()

	return json_str
}

// ---------------------------------------------------------------
// [4-6]:
func mcached_socket_read_proc (conn net.Conn,key_in string) string {
	json_str := ""
	str_received := socket_read_proc (conn,key_in)

	lines := strings.Split(str_received,"\n")

	if (! strings.Contains(lines[0],"END")) {
		json_str = lines[1]
		}

	return	json_str
}

// ---------------------------------------------------------------
// [4-6-8]:
func socket_read_proc (conn net.Conn,key_in string) string {
	str_received := ""
	_, err := conn.Write([]byte("get " + key_in + "\r\n"))
	if err != nil {
		fmt.Println(err)
		return str_received
		}

	buf := make([]byte, 1024)
	nn, err := conn.Read(buf[:])
	if err != nil {
		fmt.Println(err)
		return str_received
		}

	str_received = string(buf[0:nn])

	return	str_received
}

// ---------------------------------------------------------------
// [6]:
func insert_proc(key string, value string) string {
	fmt.Fprintf (os.Stderr,"*** insert_proc ***\n")
	hostname := "localhost"
	port := "6379"

	conn, err := net.Dial ("tcp", hostname + ":" + port)
	if err != nil {
		fmt.Println(err)
		return "err"
		}

	redis_socket_write_proc (conn,key,value)

	conn.Close ()

	return "ok"
}

// ----------------------------------------------------------------
func redis_socket_write_proc (conn net.Conn,key_in string,json_str string) {
	fmt.Println (key_in)
	fmt.Println (json_str)

	comm_aa := "set " + key_in + " '" + json_str + "'\r\n"
	conn.Write([]byte(comm_aa))

	buf := make ([]byte,1024)
	conn.Read (buf[:])

	fmt.Println (string(buf[0:10]))
}

// ----------------------------------------------------------------
// [8]:
func list_proc() string {
	fmt.Fprintf (os.Stderr,"*** list_proc ***\n")
	hostname := "localhost"
	port := "6379"

	conn, err := net.Dial ("tcp", hostname + ":" + port)
	if err != nil {
		fmt.Println(err)
		return "err"
		}

	
	keys := key_get_proc(conn)

	conn.Close ()

	output, _ := json.Marshal(keys)

	return string(output)
}

// ---------------------------------------------------------------
// [8-4]:
func key_get_proc (conn net.Conn) []string {
	var keys []string

	string_received := string_get_proc (conn)

	if 0 < len (string_received) {
		datax := strings.Split (string_received,"\n")
		for _, pp := range datax {
			if (0 < len (pp)) && (pp[:1] == "t") {
				pp = strings.TrimRight(pp, "\r")
				keys = append(keys, pp)
				}
			}
		}

	return keys
}
 
// ----------------------------------------------------------------
// [8-4-4]:
func string_get_proc (conn net.Conn) string{
	str_received := ""

	comm_aa := "keys *" + "\r\n"

	_, err := conn.Write([]byte(comm_aa))
	if err != nil {
		fmt.Println(err)
		return str_received
		}

	buf := make([]byte, 1024)
	nn, err := conn.Read(buf[:])
	if err != nil {
		fmt.Println(err)
		return str_received
		}

	str_received = string(buf[0:nn])

	return str_received
}

// ---------------------------------------------------------------

サーバーの実行

go run redis_api.go

テストスクリプト

read

curl -X POST http://localhost:8080/redis_read -d key=t1851

insert

curl -X POST http://localhost:8080/redis_insert -d key=t1855 \
	-d value='{"name": "宇都宮","population": 8751206,"date_mod": "2021-1-16"}'

list

curl -X POST http://localhost:8080/redis_list