Golang开发简易投票系统实例-Golang-PHP中文网

Golang开发简易投票系统实例

P粉602998670

发布： 2025-09-19 15:13:01

原创

917人浏览过

先实现基础功能，再逐步优化扩展。使用Golang构建投票系统，核心包括定义投票与选项的结构体，通过HTTP接口实现创建投票、添加选项、投票和查看结果功能，利用sync.Mutex保证并发安全；初期采用内存存储便于快速验证逻辑，后续可迁移到数据库并添加索引提升查询效率；为提高性能，引入Redis缓存热门投票结果，使用worker pool控制并发量，并借助pprof分析瓶颈；安全性方面需防止重复投票、SQL注入和XSS攻击，强制HTTPS传输，结合用户认证与输入过滤；功能扩展可增加多题型支持、时间权限控制、数据分析及管理后台，提升系统实用性与可维护性。

golang开发简易投票系统实例

直接上手，用Golang构建一个简单的投票系统，核心在于快速理解并实现基本功能。别想着一步到位，先跑起来再说。

解决方案：

这个投票系统，我们用Go语言来实现，重点在于简单易懂。主要涉及以下几个部分：

数据结构： 定义投票选项和投票结果的结构体。
API接口： 提供创建投票、投票、查看结果等接口。
存储： 简单起见，我们先用内存存储，后续可以考虑数据库。
并发处理： 使用Go的goroutine和channel处理并发请求。

下面是一个简化的代码示例：

立即学习“go语言免费学习笔记（深入）”；

package main

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

// 投票选项
type Option struct {
    ID    int    `json:"id"`
    Title string `json:"title"`
    Count int    `json:"count"`
}

// 投票数据
type Poll struct {
    ID      int       `json:"id"`
    Title   string    `json:"title"`
    Options []Option `json:"options"`
    mu      sync.Mutex // 保护 Options
}

var (
    polls   = make(map[int]*Poll)
    pollID  = 1
    optionID = 1
    mu sync.Mutex //保护polls
)

// 创建投票
func createPollHandler(w http.ResponseWriter, r *http.Request) {
    if r.Method != http.MethodPost {
        http.Error(w, "Method not allowed", http.StatusMethodNotAllowed)
        return
    }

    var newPoll Poll
    err := json.NewDecoder(r.Body).Decode(&newPoll)
    if err != nil {
        http.Error(w, err.Error(), http.StatusBadRequest)
        return
    }
    mu.Lock()
    newPoll.ID = pollID
    pollID++
    polls[newPoll.ID] = &newPoll
    mu.Unlock()

    w.Header().Set("Content-Type", "application/json")
    json.NewEncoder(w).Encode(newPoll)
}

// 添加选项
func addOptionHandler(w http.ResponseWriter, r *http.Request) {
    if r.Method != http.MethodPost {
        http.Error(w, "Method not allowed", http.StatusMethodNotAllowed)
        return
    }

    pollIDStr := r.URL.Query().Get("poll_id")
    var option Option
    err := json.NewDecoder(r.Body).Decode(&option)
    if err != nil {
        http.Error(w, err.Error(), http.StatusBadRequest)
        return
    }

    var pollID int
    _, err = fmt.Sscan(pollIDStr, &pollID)
    if err != nil {
        http.Error(w, "Invalid poll ID", http.StatusBadRequest)
        return
    }

    mu.Lock()
    poll, ok := polls[pollID]
    if !ok {
        mu.Unlock()
        http.Error(w, "Poll not found", http.StatusNotFound)
        return
    }

    option.ID = optionID
    optionID++
    poll.Options = append(poll.Options, option)
    mu.Unlock()

    w.Header().Set("Content-Type", "application/json")
    json.NewEncoder(w).Encode(option)
}

// 投票
func voteHandler(w http.ResponseWriter, r *http.Request) {
    if r.Method != http.MethodPost {
        http.Error(w, "Method not allowed", http.StatusMethodNotAllowed)
        return
    }

    pollIDStr := r.URL.Query().Get("poll_id")
    optionIDStr := r.URL.Query().Get("option_id")

    var pollID, optionID int
    _, err := fmt.Sscan(pollIDStr, &pollID)
    if err != nil {
        http.Error(w, "Invalid poll ID", http.StatusBadRequest)
        return
    }

    _, err = fmt.Sscan(optionIDStr, &optionID)
    if err != nil {
        http.Error(w, "Invalid option ID", http.StatusBadRequest)
        return
    }

    mu.Lock()
    poll, ok := polls[pollID]
    if !ok {
        mu.Unlock()
        http.Error(w, "Poll not found", http.StatusNotFound)
        return
    }

    found := false
    for i := range poll.Options {
        if poll.Options[i].ID == optionID {
            poll.Options[i].Count++
            found = true
            break
        }
    }
    mu.Unlock()

    if !found {
        http.Error(w, "Option not found", http.StatusNotFound)
        return
    }

    w.WriteHeader(http.StatusOK)
}

// 获取投票结果
func getPollResultsHandler(w http.ResponseWriter, r *http.Request) {
    if r.Method != http.MethodGet {
        http.Error(w, "Method not allowed", http.StatusMethodNotAllowed)
        return
    }

    pollIDStr := r.URL.Query().Get("poll_id")
    var pollID int
    _, err := fmt.Sscan(pollIDStr, &pollID)
    if err != nil {
        http.Error(w, "Invalid poll ID", http.StatusBadRequest)
        return
    }
    mu.Lock()
    poll, ok := polls[pollID]
    mu.Unlock()
    if !ok {
        http.Error(w, "Poll not found", http.StatusNotFound)
        return
    }

    w.Header().Set("Content-Type", "application/json")
    json.NewEncoder(w).Encode(poll)
}

func main() {
    http.HandleFunc("/polls", createPollHandler)
    http.HandleFunc("/options", addOptionHandler)
    http.HandleFunc("/vote", voteHandler)
    http.HandleFunc("/results", getPollResultsHandler)

    fmt.Println("Server listening on port 8080")
    log.Fatal(http.ListenAndServe(":8080", nil))
}

登录后复制

这段代码提供了一些基本的HTTP接口，包括创建投票、添加选项、投票和查看结果。使用

sync.Mutex

登录后复制

来保证并发安全。

如何优化Golang投票系统的性能？

优化性能，不能只盯着代码。首先，考虑数据库。内存存储只适合小规模测试，实际应用必须用数据库，比如PostgreSQL或者MySQL。索引是关键，确保投票ID和选项ID上有索引，加快查询速度。

然后，缓存。频繁读取的数据，比如投票结果，可以缓存起来。Redis是个不错的选择。

再者，并发控制。虽然Go的goroutine很强大，但也要控制并发数量，防止资源耗尽。可以使用

semaphore

登录后复制

或者

worker pool

登录后复制

来限制并发。

最后，监控和调优。使用

pprof

登录后复制

工具来分析性能瓶颈，针对性地优化。

如何处理投票系统的安全性问题？

86CMS企业网站系统中英繁三语版1.2

86CMS企业网站系统为智能ASP网站管理程序，适合中小企业自建网站、二次开发使用。本程序具有体积小巧、程序文件结构严谨、界面清爽简单、功能强大、非专业人士使用入门快、中小企业使用投资小等实用特点。本版本为中英繁版本。86CMS企业网站系统中英繁三语版 v1.2 更新1.修正英文版的flash幻灯调用出错问题。2.修正英文版导航菜单设置出错问题。3.增加信息是否显示在中英各版的功能。4.调整首页视