وب سرویس پیامک با زبان Go (Golang)؛ ارسال سریع با Goroutine و Rest API

package freesms import ( "bytes" "encoding/json" "fmt" "net/http" "time" ) type Client struct { BaseURL string APIKey string HTTPClient *http.Client } func NewClient(apiKey string) *Client { return &Client{ BaseURL: "https://api.free-sms.ir/v1", APIKey: apiKey, HTTPClient: &http.Client{ Timeout: 5 * time.Second, Transport: &http.Transport{ MaxIdleConns: 100, MaxIdleConnsPerHost: 20, }, }, } } // ساختار درخواست ارسال OTP type OTPRequest struct { To string `json:"to"` PatternCode string `json:"pattern_code"` Params map[string]interface{} `json:"params"` } type APIResponse struct { Status bool `json:"status"` Code int `json:"code"` Message string `json:"message"` } // متد ارسال کد تایید یکبار مصرف func (c *Client) SendOTP(to, patternCode string, params map[string]interface{}) (*APIResponse, error) { reqBody, err := json.Marshal(OTPRequest{ To: to, PatternCode: patternCode, Params: params, }) if err != nil { return nil, err } req, err := http.NewRequest("POST", c.BaseURL+"/otp", bytes.NewBuffer(reqBody)) if err != nil { return nil, err } req.Header.Set("Authorization", "Bearer "+c.APIKey) req.Header.Set("Content-Type", "application/json") resp, err := c.HTTPClient.Do(req) if err != nil { return nil, err } defer resp.Body.Close() var result APIResponse if err := json.NewDecoder(resp.Body).Decode(&result); err != nil { return nil, err } return &result, nil }

package main import ( "fmt" "sync" "your-module/freesms" ) func worker(id int, client *freesms.Client, jobs <-chan string, wg *sync.WaitGroup) { defer wg.Done() for mobile := range jobs { resp, err := client.SendOTP(mobile, "login_otp", map[string]interface{}{"code": 58291}) if err != nil { fmt.Printf("Worker %d error sending to %s: %v\n", id, mobile, err) } else { fmt.Printf("Worker %d sent to %s, response: %s\n", id, mobile, resp.Message) } } } func main() { client := freesms.NewClient("YOUR_API_KEY") recipients := []string{"09121234567", "09351234567", "09191234567"} jobs := make(chan string, len(recipients)) var wg sync.WaitGroup // اجرای ۵ ورکر همزمان for w := 1; w <= 5; w++ { wg.Add(1) go worker(w, client, jobs, &wg) } for _, r := range recipients { jobs <- r } close(jobs) wg.Wait() }

package main import ( "net/http" "github.com/gin-gonic/gin" ) type WebhookPayload struct { MessageID string `json:"message_id"` Recipient string `json:"recipient"` Status string `json:"status"` DeliveredAt string `json:"delivered_at"` } func main() { r := gin.Default() r.POST("/api/sms/webhook", func(c *gin.Context) { var payload WebhookPayload if err := c.ShouldBindJSON(&payload); err != nil { c.JSON(http.StatusBadRequest, gin.H{"error": err.Error()}) return } // ذخیره در دیتابیس PostgreSQL یا MongoDB c.JSON(http.StatusOK, gin.H{"status": "received"}) }) r.Run(":8080") }