首页 > Golang > Go教程

基于Golang 高并发问题的解决方案

来源：脚本之家

时间：2023-02-24 11:58:04 342浏览收藏

怎么入门Golang编程？需要学习哪些知识点？这是新手们刚接触编程时常见的问题；下面golang学习网就来给大家整理分享一些知识点，希望能够给初学者一些帮助。本篇文章就来介绍《基于Golang 高并发问题的解决方案》，涉及到高并发，有需要的可以收藏一下

Golang 高并发问题的解决

Golang在高并发问题上，由于协程的使用，相对于其他编程语言，已经有了很大的优势，即相同的配置上，Golang可以以更低的代价处理更多的线程，同样的线程数，占用更低的资源！及时这样，只是解决了一部分问题而已，因为在每个协程里，处理逻辑还是会有问题。

高并发时，还是要考虑服务器所能承受的最大压力，数据库读取时的io问题，连接数问题，带宽问题等等

研究了一下并发解决方案，在此记录一下

参考文章：Handling 1 Million Requests per Minute with Go

地址：http://marcio.io/2015/07/handling-1-million-requests-per-minute-with-golang/

代码如下：

100

101

102

103

104

105

106

107

//==================================
//  * Name：Jerry
//  * Tel：18017448610
//  * DateTime：2019/2/24 14:02
//==================================
package main
import (
    "github.com/lunny/log"
    "runtime"
    "sync"
    "time"
)
//工厂模型
type Factory struct {
    Wg        *sync.WaitGroup //任务监控系统
    MaxWorker int             //最大机器数
    MaxJobs   int             //最大工作数量
    JobQueue  chan int        //工作队列管道
    Quit      chan bool       //是否关闭机器
}
//创建工厂模型
func NewFactory(maxWorker int, wg *sync.WaitGroup) Factory {
    return Factory{
        Wg:        wg,                        //引用任务监控系统
        MaxWorker: maxWorker,                 //机器数量（数量多少，根据服务器性能而定）
        JobQueue:  make(chan int, maxWorker), //工作管道，数量大于等于机器数
        Quit:      make(chan bool),
    }
}
//设置最大订单数量
func (f *Factory) SetMaxJobs(taskNum int) {
    f.MaxJobs = taskNum
}
//开始上班
func (f *Factory) Start() {
    //机器开机，MaxWorker
    for i := 0; i 
 
<h3>测试代码及结果</h3>
<p>上面代码中，MaxWorker的数量很重要，取决于服务器所能承受的压力，当然也不能无限增大，合理数值效率最高（具体多少合适，自己测试）</p>
<p>代码：</p>
 
<pre class="brush:plain;">func Benchmark_Begin(b *testing.B) {
 Begin()
}</pre>
 
<h3>结果：</h3>
<p>1000台机器（协程），10000的工作量，我的个人PC测试结果如下：</p>
<blockquote>
<p>2019/02/26 16:42:31 核数： 4</p>
<p>2019/02/26 16:42:31 开始生产</p>
<p>2019/02/26 16:42:33 所有订单任务生产完成</p>
<p>goos: windows</p>
<p>goarch: amd64</p>
<p>pkg: day11</p>
<p>Benchmark_hight2-4 1 2035574000 ns/op</p>
<p>PASS</p>
<p>Process finished with exit code 0</p>
</blockquote>
<h2>总结：</h2>
<p>此方法仅仅是在代码层面解决一定的问题，高并发 产生的原因还包括其他原因，如带宽，数据库读取速度等等，还需加大带宽，多级数据库，优化数据的检索等等方法</p>
<p><strong>补充：golang 高并发任务处理方案</strong></p>
<p>这个主要用golang 的chan 和routine属性做的，比很多语言方便多了，可以参考参考</p>
<p>​</p>
 
<pre class="brush:plain;">//任务的请求
type MtaskRequest struct {
    Ceshi int
    // [redacted]
}
  
//job队列+work池
var (
    MaxWorker = os.Getenv("MAX_WORKERS")
    MaxQueue  = os.Getenv("MAX_QUEUE")
)
  
// Job represents the job to be run
type Job struct {
    MtaskRequest MtaskRequest
}
  
// A buffered channel that we can send work requests on.
  
// var JobQueue chan Job ---这样申明会卡主，没有初始化
var JobQueue = make(chan Job)
  
// Worker represents the worker that executes the job
type Worker struct {
    WorkerPool chan chan Job
    JobChannel chan Job
    quit       chan bool
}
  
func NewWorker(workerPool chan chan Job) Worker {
    return Worker{
        WorkerPool: workerPool,
        JobChannel: make(chan Job),
        quit:       make(chan bool)}
}
  
// Stop signals the worker to stop listening for work requests.
func (w Worker) Stop() {
    go func() {
        w.quit 
 
<p>以上为个人经验，希望能给大家一个参考，也希望大家多多支持golang学习网。如有错误或未考虑完全的地方，望不吝赐教。</p><p>以上就是《基于Golang 高并发问题的解决方案》的详细内容，更多关于golang的资料请关注golang学习网公众号！</p></pre>

golang 高并发

声明：本文转载于：脚本之家如有侵犯，请联系study_golang@163.com删除