golang重构博客统计服务

func initRedisPool() {
	// 建立连接池
	RedisClient = &redis.Pool{
		// 从配置文件获取maxidle以及maxactive，取不到则用后面的默认值
		MaxIdle:     1,
		MaxActive:   10,
		IdleTimeout: 180 * time.Second,
		Dial: func() (redis.Conn, error) {
			c, err := redis.Dial("tcp", RedisAddress)
			if err != nil {
				return nil, err
			}
			// 选择db
			c.Do("SELECT", RedisDb)
			return c, nil
		},
	}
}

/**
 * 设置redis的对应key的value
 */
func redisSet(key string, value string) {
	c, err := RedisClient.Dial()
	if err != nil {
		fmt.Println("Connect to redis error", err)
		return
	}
	_, err = c.Do("SET", key, value)
	if err != nil {
		fmt.Println("redis set failed:", err)
	}
}

/**
 * 获取redis的对应key的value
 */
func redisGet(key string) (value string) {
	c, err := RedisClient.Dial()
	if err != nil {
		fmt.Println("Connect to redis error", err)
		return
	}
	val, err := redis.String(c.Do("GET", key))
	if err != nil {
		fmt.Println("redis get failed:", err)
		return ""
	} else {
		fmt.Printf("Got value is %v \n", val)
		return val
	}
}

/**
 * redis使得对应的key的值自增
 */
func redisIncr(key string) (value string) {
	c, err := RedisClient.Dial()
	_, err = c.Do("INCR", key)
	if err != nil {
		fmt.Println("incr error", err.Error())
	}

	incr, err := redis.String(c.Do("GET", key))
	if err == nil {
		fmt.Println("redis key after incr is : ", incr)
	}
	return incr
}

package main

import (
	"encoding/json"
	"fmt"
	"github.com/garyburd/redigo/redis"
	"log"
	"net/http"
	"time"
	"strings"
)

const RedisAddress = "127.0.0.1:6379"
const RedisDb = 0

const AllowRequestUrlH = "*"
const  AllowRequestUrlW = "*"
const  IllegalCharacters = "?"
const  DefaultReadCount = "1"

var (
	// 定义常量
	RedisClient *redis.Pool
)

func main() {
	// 初始化redis连接池
	initRedisPool()

	// 启动web服务监听
	http.HandleFunc("/*-*/*/", blogReadCountIncr)       //设置访问的路由
	err := http.ListenAndServe(":9401", nil) //设置监听的端口
	if err != nil {
		log.Fatal("ListenAndServe: ", err)
	}
}

func blogReadCountIncr(responseWriter http.ResponseWriter, request *http.Request) {

	// 解析参数，默认不解析
	request.ParseForm()

	blogId := request.Form.Get("blogId")

	log.Println(">>>>>> method blogReadCountIncr exec , request params is : ",blogId)

	// 判断请求参数是否为空
	if "" == blogId {
		result := ResultCode{
			Code: 200,
			Msg:  "success",
		}

		ret, _ := json.Marshal(result)
		fmt.Fprintf(responseWriter, string(ret)) //这个写入到w的是输出到客户端的
	}
	
	readCount := redisGet(blogId)
	if "" == readCount {
		// 不符合规则，直接返回
		flag := strings.Index(blogId, AllowRequestUrlH) != 0 ||strings.Index(blogId, AllowRequestUrlW) != 0||strings.Contains(blogId, IllegalCharacters)
		if  !flag {
			result := ResultCode{
				Code: 200,
				Msg:  "success",
			}

			ret, _ := json.Marshal(result)
			fmt.Fprintf(responseWriter, string(ret)) //这个写入到w的是输出到客户端的
		}

		redisSet(blogId, DefaultReadCount)
		readCount = DefaultReadCount
	} else {
		readCount = redisIncr(blogId)
	}
	log.Println(">>>>>> readCount is : ",readCount)
	result := ResultCode{
		Code: 200,
		Msg:  "success",
		Data: readCount,
	}
	ret, _ := json.Marshal(result)
	fmt.Fprintf(responseWriter, string(ret)) //这个写入到w的是输出到客户端的
}
// 结构体定义返回值
type ResultCode struct {
	Msg  string `json:"msg"`
	Code int    `json:"code"`
	Data string `json:"data"`
}

ret, _ := json.Marshal(result)

type ResultCode struct {
	msg  string `json:"msg"`
	code int    `json:"code"`
	data string `json:"data"`
}

type ResultCode struct {
	Msg  string `json:"msg"`
	Code int    `json:"code"`
	Data string `json:"data"`
}