我正在尝试编写一个从 http 请求接收数据流的 go 服务器。问题是一旦它收到 {status: connected} 我如何保持连接?
func stream() {
t := time.Now()
a := t.Format("15:03")
if a > string("08:30") && a < string("15:00") {
color.Red("Streaming. . .")
config := oauth1.NewConfig("HIDDEN", "HIDDEN")
token := oauth1.NewToken("HIDDEN", "HIDDEN")
httpClient := config.Client(oauth1.NoContext, token)
path := "https://stream.tradeking.com/v1/market/quotes.json?symbols=aapl"
resp, _ := httpClient.Get(path)
fmt.Println(resp)
body, _ := ioutil.ReadAll(resp.Body)
fmt.Printf("Raw Response Body:\n%v\n", string(body))
defer resp.Body.Close()
} else {
color.Red("%s \nMarkets are closed! Please, come back later.", t)
}
}
我在main中调用这个函数。我还收到了类似标题的内容:
&{200 OK 200 HTTP/1.1 1 1 map[日期:[Mon, 16 Jan 2017 17:45:36 GMT] X-Powered-By:[Express] 服务器:[cloudflare-ngi
nx] 内容类型:[application/json] 连接:[keep-alive] Set-Cookie:[__cfduid=dcfcf86c79c56e659ce2b1bade3643c
981484588736; expires=星期二,2018 年 1 月 16 日 17:45:36 GMT;路径=/;域名=.tradeking.com; HttpOnly] 变化:[接受编码
g] Cf-Ray:[322361d0efd40938-DFW]] 0xc42032e0c0 -1 [分块] false true map[] 0xc4200d21e0 0xc42040cbb0}
最佳答案
原来市场因 MLK 日休市,因此服务器没有任何响应。
在一定超时后,远程服务器超时。
关于Golang 在我的直播中超时,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/41682200/
有没有办法在这个简单的get方法中添加超时选项?我正在使用法拉第3.3。Faraday.get(url)四处寻找,我只能先发起连接后应用超时选项,然后应用超时选项。或者有什么简单的方法?这就是我现在正在做的:conn=Faraday.newresponse=conn.getdo|req|req.urlurlreq.options.timeout=2#2secondsend 最佳答案 试试这个:conn=Faraday.newdo|conn|conn.options.timeout=20endresponse=conn.get(url
使用rails4,ruby2。我在rails配置中为我的cookiesession设置了30分钟的超时时间。问题是,如果我转到表单,让session超时,然后提交表单,我会收到此ActionController::InvalidAuthenticityToken错误。如何在Rails中优雅地处理这个错误?比如说,重定向到登录屏幕? 最佳答案 在您的ApplicationController:rescue_fromActionController::InvalidAuthenticityTokendoredirect_tosome_p
在Ruby中,我需要在n毫秒秒后暂停一段代码的执行。我知道RubyTimeout库支持秒的超时:http://ruby-doc.org/stdlib/libdoc/timeout/rdoc/index.html这可能吗? 最佳答案 只需为超时使用十进制值。n毫秒的示例:Timeout::timeout(n/1000.0){sleep(100)} 关于Ruby在n*milli*秒后超时一段代码,我们在StackOverflow上找到一个类似的问题: https:
我在一台Windows764位机器上使用Sass和Ruby(最新版本),我正在我的家庭服务器上处理一个共享文件夹。(但是,我不得不承认问题本身也出现在服务器上,因为我试图安装Ruby并直接-watch服务器上的文件)。问题如下:如果我第一次保存,检测到变化,我的style.css被直接覆盖。之后,我总是需要保存多达7次才能覆盖style.css。每次都会检测到更改,但不会编译任何内容。这是一个屏幕:>>>Sassiswatchingforchanges.PressCtrl-Ctostop.overwritestyle.css>>>Changedetectedto:E:/Websites
我在尝试通过rubygems安装json模块时收到此警告。有什么想法吗?Mac-Minipoulh$sudogeminstalljsonPassword:WARNING:File'/System/Library/Frameworks/Ruby.framework/Versions/1.8/usr/lib/ruby/gems/1.8/specifications/json-1.2.0.gemspec'doesnotevaluatetoagemspecificationBuildingnativeextensions.Thiscouldtakeawhile...ERROR:Errori
我正在熟悉一些JRuby代码,我希望能够在代码中放置一个断点并(像往常一样)从命令行运行,当它到达时进入调试器那一点。我可以在我的代码中添加一些东西来强制JRuby进入调试器吗?我尝试运行jruby-rdebugfoo.rb(而不是通常的jrubyfoo.rb),然后使用b设置断点bar.py:98,然后继续。但是每次出现异常时调试器都会停止,而且在到达我感兴趣的代码行之前似乎有很多异常。我希望能够将“break-into-debugger”在我的代码中添加行并运行jrubyfoo.rb并让调试器首先停止在该行。(即我正在寻找Ruby/JRuby等同于Python中的importpdb
这个错误已经有好几个月了,在这里:http://www.ruby-forum.com/topic/1094002其中显示代码更改的两个链接:https://github.com/godfat/ruby/commit/f4e0e8f781b05c767ad2472a43a4ed0727a75708https://github.com/godfat/ruby/commit/c7a6cf975d88828c2ed27d253f41c480f9b66ad6我有Ruby1.9.2和rvm。我会把这些更改粘贴到适当的文件中,但我不知道如何粘贴。这在几天前就奏效了。我不能像这样执行RubyonRai
我正在尝试使用Vagrant创建我的第一个ChefRecipe,但在第一步就遇到了问题。我的Recipe的第一行是:include_recipe"apt"但是当我尝试vagrantprovision时,出现以下错误:==>default:[2014-09-21T07:15:42+00:00]WARN:MissingCookbookDependency:==>default:Recipe`apt`isnotintherun_list,andcookbook'apt'==>default:isnotadependencyofanycookbookintherun_list.Toloadth
我正在使用rails3.2.5ActionMailer发送纯文本邮件。鉴于我有这样的邮件View:message_from_user.text.erb:Hi,Yougotthefollowingmessagefrom:当@message是"quotes&ersands",那么纯文本邮件包含"quotes&ersands".所以看起来rails只是将其视为HTMLView并转义任何html以防止跨站点脚本。然而,这是一封纯文本邮件。分机号是.text.erb和ActionMailer检测到这一点并将MIME设置为text/plain.所以我从不想转
RTS在阿里云视频直播的基础上进行底层技术优化,通过集成阿里云播放器SDK,支持在千万级并发场景下节点间毫秒级延时直播的能力,弥补了传统直播存在3~6秒延时的问题,确保了超低延时、低卡顿、秒开流畅的直播观看体验。本文介绍了基于RTS超低延迟直播优化强互动场景体验的最佳实践方案,并以阿里云播放器Aliplayer为例,详细介绍RTS超低延迟拉流接入、自动降级、排障信息获取等逻辑的实现,助力企业打造互动直播行业的产品竞争力。适用场景该方案适用于对超低延迟直播有诉求的客户,尤其是业务中存在强互动场景直播的场景。强互动场景直播主要是指对主播和观众存在互动,或观众存在更高实时性观看、画面互动需求的情况,