demo_performance_counter

type Aggregator ¶

type Aggregator struct{}

Aggregator 是一个工具类，目前只有一个方法，几十行左右的代码量，负责各种统计数据的计算。 当需要扩展新的统计功能时，要修改 aggregate() 方法的代码，并且一旦越来越多的统计功能添加进来之后， 这个函数的代码量会持续增加，可读性、可维护性就变差了。 这个类的设计存在职责不够单一、不易扩展等问题，需要在之后的版本中，对其结构做优化。

func NewAggregator() *Aggregator

func (a *Aggregator) Aggregate(requestInfos []RequestInfo, duration time.Duration) *RequestStat

type App ¶

type App struct{}

func (a App) Run()

type ConsoleReporter ¶

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

ConsoleReporter 和 EmailReporter 中存在代码重复问题。 在这两个类中，从数据库中取数据、做统计的逻辑都是相同的，可以抽取出来复用，否则就违反了 DRY 原则。 而且整个类负责的事情比较多，职责不是太单一。特别是显示部分的代码，可能会比较复杂（比如 Email 的展示方式）， 最好是将显示部分的代码逻辑拆分成独立的类。除此之外，因为代码中涉及线程操作， 并且调用了 Aggregator 的方法，所以代码的可测试性不好。

func NewConsoleReporter(metricsStorage MetricsStorage, aggregator *Aggregator) *ConsoleReporter

func (r *ConsoleReporter) StartRepeatedReport(period, duration time.Duration)

type EmailReporter ¶

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

func NewEmailReporter(metricsStorage MetricsStorage, aggregator *Aggregator) *EmailReporter

func (r *EmailReporter) AddToAddress(addr ...string)

func (r *EmailReporter) StartDailyReport()

type EmailSender ¶

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

func NewEmailSender(smtpAddr string) *EmailSender

func (s *EmailSender) AddReceiver(receiver ...string)

func (s *EmailSender) SendMail(msg []byte) error

type Metric ¶

type Metric interface {
	RecordResponseTime(apiName string, responseTime time.Duration)
	RecordTimestamp(apiName string, timestamp int64)
	StartRepeatedReport(period time.Duration) error
}

type Metrics ¶

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

func (m *Metrics) RecordResponseTime(apiName string, responseTime time.Duration)

func (m *Metrics) RecordTimestamp(apiName string, timestamp int64)

func (m *Metrics) StartRepeatedReport(period time.Duration) error

type MetricsCollector ¶

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

MetricsCollector 负责采集和存储数据，职责相对来说比较单一。 它基于接口而非实现编程，通过依赖注入的方式来传递 MetricsStorage 对象， 可以在不需要修改代码的情况下，灵活地替换不同的存储方式，满足开闭原则。

func NewMetricsCollector(metricsStorage MetricsStorage) *MetricsCollector

func (c *MetricsCollector) RecordRequest(info *RequestInfo)

type MetricsStorage ¶

type MetricsStorage interface {
	SaveRequestInfo(info *RequestInfo)

	GetRequestInfo(apiName string, startTime, endTime time.Time) []RequestInfo
	GetRequestInfos(startTime, endTime time.Time) map[string][]RequestInfo
}

MetricsStorage 和 RedisMetricsStorage 的设计比较简单。 需要实现新的存储方式的时候，只需要实现 MetricsStorage 接口即可。 因为所有用到 MetricsStorage 和 RedisMetricsStorage 的地方， 都是基于相同的接口函数来编程的，所以， 除了在组装类的地方有所改动（从 RedisMetricsStorage 改为新的存储实现类）， 其他接口函数调用的地方都不需要改动，满足开闭原则。

type RedisMetricsStorage ¶

type RedisMetricsStorage struct{}

func NewRedisMetricsStorage() *RedisMetricsStorage

func (r *RedisMetricsStorage) GetRequestInfo(apiName string, startTime, endTime time.Time) []RequestInfo

func (r *RedisMetricsStorage) GetRequestInfos(startTime, endTime time.Time) map[string][]RequestInfo

func (r *RedisMetricsStorage) SaveRequestInfo(info *RequestInfo)

type RequestInfo ¶

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

func NewRequestInfo(apiName string, responseTime time.Duration, timestamp int64) *RequestInfo

func (r *RequestInfo) ApiName() string

func (r *RequestInfo) ResponseTime() time.Duration

func (r *RequestInfo) SetApiName(apiName string)

func (r *RequestInfo) SetResponseTime(responseTime time.Duration)

func (r *RequestInfo) SetTimestamp(timestamp int64)

func (r *RequestInfo) Timestamp() int64

type RequestStat ¶

type RequestStat struct {
	MaxResponseTime  time.Duration
	MinResponseTime  time.Duration
	AvgResponseTime  time.Duration
	P999ResponseTime time.Duration
	P99ResponseTime  time.Duration
	Count            int64
	Tps              int64
}

type UserController ¶

type UserController struct {
	Metric
}

func NewUserController(metric Metric) *UserController

func (c *UserController) Login(telephone, password string)

func (c *UserController) Register(user UserVO)

type UserVO ¶

type UserVO struct{}