[go] Go 언어를 사용하여 웹소켓으로 실시간 주식 시장 동향 제공하기

22 Dec 2023

최근 실시간 주식 시장 동향을 제공하는 웹 애플리케이션의 중요성이 높아지고 있습니다. 이를 위해 Go 언어와 웹소켓을 활용하여 안정적이고 신속한 실시간 데이터 전송 및 처리가 가능합니다.

웹소켓을 이용한 실시간 데이터 전송

웹소켓은 클라이언트와 서버 간 실시간 양방향 통신을 제공하는 프로토콜로, HTTP보다 낮은 지연 시간으로 데이터를 전송할 수 있습니다. Go 언어의 내장된 웹소켓 라이브러리를 사용하면 간단하게 실시간 데이터 전송 시스템을 구축할 수 있습니다.

다음은 Go에서 웹소켓을 사용하여 클라이언트와 서버 간 양방향 통신을 구현하는 간단한 예제입니다:

import (
    "github.com/gorilla/websocket"
    "net/http"
)

var upgrader = websocket.Upgrader{
    ReadBufferSize:  1024,
    WriteBufferSize: 1024,
}

func websocketHandler(w http.ResponseWriter, r *http.Request) {
    conn, _ := upgrader.Upgrade(w, r, nil)
    for {
        // 클라이언트로부터 메시지 수신
        messageType, p, _ := conn.ReadMessage()
        // 받은 메시지 처리
        // ...
        // 클라이언트로 메시지 전송
        conn.WriteMessage(messageType, p)
    }
}

func main() {
    http.HandleFunc("/websocket", websocketHandler)
    http.ListenAndServe(":8080", nil)
}

위 예제에서는 gorilla/websocket 라이브러리를 사용하여 웹소켓을 핸들링하고, 클라이언트와 서버 간의 메시지 송수신을 처리합니다.

주식 시장 데이터 처리

주식 시장 데이터의 처리에는 FinanceData.IO나 Alpha Vantage와 같은 금융 데이터 제공 업체의 API를 사용할 수 있습니다. 이러한 API를 통해 주식 가격, 거래량, 지표 및 뉴스 등의 데이터를 얻을 수 있습니다.

다음은 Go에서 FinanceData.IO API를 활용하여 주식 시세 정보를 가져오는 간단한 예제입니다:

package main

import (
    "encoding/json"
    "fmt"
    "net/http"
)

const apiKey = "YOUR_API_KEY"

type StockPrice struct {
    Symbol string  `json:"symbol"`
    Price  float64 `json:"price"`
}

func getStockPrice(symbol string) (*StockPrice, error) {
    url := fmt.Sprintf("https://financedata.io/api/v1/stock/latest_price?symbol=%s&apikey=%s", symbol, apiKey)
    resp, err := http.Get(url)
    if err != nil {
        return nil, err
    }
    defer resp.Body.Close()

    var stockPrice StockPrice
    err = json.NewDecoder(resp.Body).Decode(&stockPrice)
    if err != nil {
        return nil, err
    }
    return &stockPrice, nil
}

func main() {
    stockSymbol := "AAPL"
    stockPrice, err := getStockPrice(stockSymbol)
    if err != nil {
        fmt.Println("Error fetching stock price:", err)
        return
    }
    fmt.Printf("Latest price of %s: $%v\n", stockPrice.Symbol, stockPrice.Price)
}

위 예제에서는 financedata.io API를 통해 특정 주식의 최신 가격을 가져오는 방법을 보여줍니다.

마무리

Go 언어와 웹소켓을 활용하여 웹 기반의 실시간 주식 시장 동향을 제공하는 것은 높은 성능과 안정성을 제공할 수 있습니다. 이러한 기술들을 적극적으로 활용하여 효율적이고 빠른 실시간 데이터 전송 및 처리를 구현할 수 있습니다.