server

Documentation

Overview

服务端, 实体结构定义

实现(Server)接口

服务端参数初始化

服务组件初始化启动相关实现

数据库操作, 及集群交互操作

队列操作, 文件信息入队及出队列

服务端, 组件服务实现

公共方法实现

Index

• Constants
• Variables
• type Service
  • func NewService() (server *Service, err error)
  • func (server Service) AppendToDownloadQueue(fileInfo *en.FileInfo)
  • func (server Service) AppendToQueue(fileInfo *en.FileInfo)
  • func (server Service) AutoRepair(forceRepair bool)
  • func (server Service) BackUpMetaDataByDate(date string)
  • func (server *Service) BenchMark(w http.ResponseWriter, r *http.Request)
  • func (server Service) CheckAuth(w http.ResponseWriter, r *http.Request) bool
  • func (server Service) CheckFileAndSendToPeer(date string, filename string, isForceUpload bool)
  • func (server Service) CheckPeerFileExist(peer string, md5sum string, fpath string) (*en.FileInfo, error)
  • func (server Service) DownloadFromPeer(peer string, fileInfo *en.FileInfo)
  • func (server Service) GetFileInfoFromLevelDB(key string) (*en.FileInfo, error)
  • func (server Service) GetGroupRouteName() string
  • func (server Service) GetHost() string
  • func (server Service) GetLdb() *leveldb.DB
  • func (server Service) GetMd5sByDate(date string, filename string) (mapset.Set, error)
  • func (server Service) GetQueueFileLog() chan *en.FileLog
  • func (server Service) GetQueueFromPeers() chan en.FileInfo
  • func (server Service) GetQueueToPeers() chan en.FileInfo
  • func (server Service) GetQueueUpload() chan en.WrapReqResp
  • func (server Service) GetRequestURI(action string) string
  • func (server Service) GetSceneMap() *goutil.CommonMap
  • func (server Service) GetServerName() string
  • func (server Service) GetStatMap() *goutil.CommonMap
  • func (server Service) GetSumMap() *goutil.CommonMap
  • func (server Service) NotPermit(w http.ResponseWriter, r *http.Request)
  • func (server Service) Reload(w http.ResponseWriter, r *http.Request)
  • func (server Service) RemoveKeyFromLevelDB(key string, db *leveldb.DB) error
  • func (server Service) RepairFileInfoFromFile()
  • func (server Service) RepairStatByDate(date string) en.StatDateFileInfo
  • func (server Service) SaveFileInfoToLevelDB(key string, fileInfo *en.FileInfo, db *leveldb.DB) (*en.FileInfo, error)
  • func (server Service) SaveFileMd5Log(fileInfo *en.FileInfo, filename string)
  • func (server *Service) Start()
  • func (server Service) Upload(w http.ResponseWriter, r *http.Request)
  • func (server Service) VerifyGoogleCode(secret string, code string, discrepancy int64) bool

Constants

const (
	CONST_SMALL_FILE_SIZE = conf.CONST_SMALL_FILE_SIZE
	// 操作标识
	CONST_FILE_Md5_FILE_NAME   = conf.CONST_FILE_Md5_FILE_NAME
	CONST_Md5_ERROR_FILE_NAME  = conf.CONST_Md5_ERROR_FILE_NAME
	CONST_Md5_QUEUE_FILE_NAME  = conf.CONST_Md5_QUEUE_FILE_NAME
	CONST_REMOME_Md5_FILE_NAME = conf.CONST_REMOME_Md5_FILE_NAME
	//
	CONST_STAT_FILE_TOTAL_SIZE_KEY = conf.CONST_STAT_FILE_TOTAL_SIZE_KEY
	CONST_STAT_FILE_COUNT_KEY      = conf.CONST_STAT_FILE_COUNT_KEY

	CONST_BIG_UPLOAD_PATH_SUFFIX = conf.CONST_BIG_UPLOAD_PATH_SUFFIX

	GO_FASTDFS_IP = conf.GO_FASTDFS_IP
	Go_FastDFS    = conf.Go_FastDFS
)

Variables

var (
	DOCKER_DIR                  = conf.DirDocker
	DATA_DIR                    = conf.DirData
	STORE_DIR                   = conf.DirStore
	LARGE_DIR_NAME              = conf.DirLargeName
	STATIC_DIR                  = conf.DirStatic
	LARGE_DIR                   = conf.DirLarge
	LOG_DIR                     = conf.DirLog
	STORE_DIR_NAME              = conf.STORE_DIR_NAME
	CONST_CONF_FILE_NAME        = conf.CONSTConfFileName
	CONST_LEVELDB_FILE_NAME     = conf.CONSTLevelDBFileName
	CONST_LOG_LEVELDB_FILE_NAME = conf.CONSTLevelDBFileNameLog
	CONST_SEARCH_FILE_NAME      = conf.CONSTSearchFileName
	CONST_STAT_FILE_NAME        = conf.CONSTStatFileName
	CONST_QUEUE_SIZE            = conf.CONSTQueueSize
	CONST_UPLOAD_COUNTER_KEY    = conf.CONSTUploadCounterKey
)

项目应用目录

Types

type Service

type Service struct {
	// contains filtered or unexported fields
}

定义服务结构

func NewService

func NewService() (server *Service, err error)

func (Service) AppendToDownloadQueue

func (server Service) AppendToDownloadQueue(fileInfo *en.FileInfo)

func (Service) AppendToQueue

func (server Service) AppendToQueue(fileInfo *en.FileInfo)

func (Service) AutoRepair

func (server Service) AutoRepair(forceRepair bool)

func (Service) BackUpMetaDataByDate

func (server Service) BackUpMetaDataByDate(date string)

func (*Service) BenchMark

func (server *Service) BenchMark(w http.ResponseWriter, r *http.Request)

func (Service) CheckAuth

func (server Service) CheckAuth(w http.ResponseWriter, r *http.Request) bool

func (Service) CheckFileAndSendToPeer

func (server Service) CheckFileAndSendToPeer(date string, filename string, isForceUpload bool)

func (Service) CheckPeerFileExist

func (server Service) CheckPeerFileExist(peer string, md5sum string, fpath string) (*en.FileInfo, error)

检测文件是否存在, 并获取文件信息

func (Service) DownloadFromPeer

func (server Service) DownloadFromPeer(peer string, fileInfo *en.FileInfo)

从集群(查找到文件的节点 peer)中下载文件

func (Service) GetFileInfoFromLevelDB

func (server Service) GetFileInfoFromLevelDB(key string) (*en.FileInfo, error)

func (Service) GetGroupRouteName

func (server Service) GetGroupRouteName() string

获取访问路由名称, 未配置使用服务名称

func (Service) GetHost

func (server Service) GetHost() string

func (Service) GetLdb

func (server Service) GetLdb() *leveldb.DB

func (Service) GetMd5sByDate

func (server Service) GetMd5sByDate(date string, filename string) (mapset.Set, error)

func (Service) GetQueueFileLog

func (server Service) GetQueueFileLog() chan *en.FileLog

func (Service) GetQueueFromPeers

func (server Service) GetQueueFromPeers() chan en.FileInfo

func (Service) GetQueueToPeers

func (server Service) GetQueueToPeers() chan en.FileInfo

func (Service) GetQueueUpload

func (server Service) GetQueueUpload() chan en.WrapReqResp

func (Service) GetRequestURI

func (server Service) GetRequestURI(action string) string

func (Service) GetSceneMap

func (server Service) GetSceneMap() *goutil.CommonMap

func (Service) GetServerName

func (server Service) GetServerName() string

获取服务名称

func (Service) GetStatMap

func (server Service) GetStatMap() *goutil.CommonMap

func (Service) GetSumMap

func (server Service) GetSumMap() *goutil.CommonMap

func (Service) NotPermit

func (server Service) NotPermit(w http.ResponseWriter, r *http.Request)

func (Service) Reload

func (server Service) Reload(w http.ResponseWriter, r *http.Request)

func (Service) RemoveKeyFromLevelDB

func (server Service) RemoveKeyFromLevelDB(key string, db *leveldb.DB) error

func (Service) RepairFileInfoFromFile

func (server Service) RepairFileInfoFromFile()

func (Service) RepairStatByDate

func (server Service) RepairStatByDate(date string) en.StatDateFileInfo

func (Service) SaveFileInfoToLevelDB

func (server Service) SaveFileInfoToLevelDB(key string, fileInfo *en.FileInfo, db *leveldb.DB) (*en.FileInfo, error)

func (Service) SaveFileMd5Log

func (server Service) SaveFileMd5Log(fileInfo *en.FileInfo, filename string)

func (*Service) Start

func (server *Service) Start()

启动服务 ---------- ---------- ---------- 01 相关参数配置初始化 02 启动相关服务组件 ---------- ---------- ----------

func (Service) Upload

func (server Service) Upload(w http.ResponseWriter, r *http.Request)

上传文件

func (Service) VerifyGoogleCode

func (server Service) VerifyGoogleCode(secret string, code string, discrepancy int64) bool