aluferraz / go-expert-stress-test Goto Github PK

Stress Testing Tool

Abordagem

O package stresstest contém a lógica principal da aplicação. Utilizando de golang channels para controlar a concorrecia, disparamos goroutines em paralelo para atingir a concorrencia desejada.

Para controlar que todas as requisições foram executadas, utilizo waitgroups.

go-expert-stress-test/usecases/stresstest/stress-test.go

Lines 32 to 71 in e23d777

 func (st *StressTest) Execute() (StressTestDTOOutput, error) { 

 start := time.Now() 

 var wg sync.WaitGroup 

 queue := make(chan struct{}, st.Input.Concurrency) 

 defer close(queue) 

 requests := st.Input.Requests 

 resultsChan := make(chan int, requests) 

 defer close(resultsChan) 

 result := StressTestDTOOutput{ 

 Results: make(map[int]int), 

 } 

 var hasError error 

 for i := 0; i < requests; i++ { 

 wg.Add(1) 

 queue <- struct{}{} 

 go func() { 

 resp, err := http.Get(st.Input.Url) 

 if err != nil { 

 hasError = errors.Join(hasError, err) 

 <-queue 

 return 

 } 

 resultsChan <- resp.StatusCode 

 <-queue 

 }() 

 } 

 go func() { 

 for res := range resultsChan { 

 result.Results[res] += 1 

 wg.Done() 

 } 

 }() 

 wg.Wait() 

 result.ExecutionTime = time.Since(start) 

 return result, hasError 

 }

Usage

Para utilizar a ferramenta, é necessário passar três parâmetros: url, requests e concurrency.

Aqui está um exemplo de como você pode executar a ferramenta:

docker build . -t "alusoft-stress-test" && \
docker run alusoft-stress-test --url=http://example.com --requests=10 --concurrency=5

Neste exemplo, a ferramenta realizará um total de 10 requisições para http://example.com com um nível de concorrência de 5.

Output

Após executar o teste, você verá uma saída como esta:

Stress Testing http://example.com, Requests 10, Concurrency 5...
Total of request with Status code[200]: 10 
Total of request with: 10 
Execution time 1.056415s

Isso significa que a ferramenta fez um total de 1000 requisições para http://example.com e todas essas requisições tiveram um código de status HTTP 200 (OK). O tempo de execução é o tempo que levou para o teste ser concluído.

aluferraz / go-expert-stress-test Goto Github PK

go-expert-stress-test's Introduction

Stress Testing Tool

Abordagem

Usage

Output

go-expert-stress-test's People

Contributors

Watchers

Recommend Projects

React

Vue.js

Typescript

TensorFlow

Django

Laravel

D3

Recommend Topics

javascript

web

server

Machine learning

Visualization

Game

Recommend Org

Facebook

Microsoft

Google

Alibaba

D3

Tencent

	func (st *StressTest) Execute() (StressTestDTOOutput, error) {
	start := time.Now()

	var wg sync.WaitGroup
	queue := make(chan struct{}, st.Input.Concurrency)
	defer close(queue)
	requests := st.Input.Requests
	resultsChan := make(chan int, requests)
	defer close(resultsChan)
	result := StressTestDTOOutput{
	Results: make(map[int]int),
	}

	var hasError error
	for i := 0; i < requests; i++ {
	wg.Add(1)
	queue <- struct{}{}

	go func() {
	resp, err := http.Get(st.Input.Url)
	if err != nil {
	hasError = errors.Join(hasError, err)
	<-queue
	return
	}
	resultsChan <- resp.StatusCode
	<-queue
	}()
	}
	go func() {
	for res := range resultsChan {
	result.Results[res] += 1
	wg.Done()
	}
	}()

	wg.Wait()
	result.ExecutionTime = time.Since(start)
	return result, hasError
	}