go实现新浪微博消息服务接收服务 - 开源中国社区
当前访客身份：游客 [
当前位置：
发布于 日 18时,
go实现新浪消息服务接收工作。充分利用&&多核、协成、管道、select等功能。在停止时，不会立即停止，当功能不会有任何影响。因为是长连接导致接收时阻塞，所以不能立即结束。
代码片段(3)
sina.go&~&5KB&&&&
package main
"encoding/base64"
"encoding/json"
"/widuu/gojson"
"net/http"
type UserInfo struct {
password string
type storedata struct {
sinceId string
HOST = "127.0.0.1"
PORT = "8899"
var UserMap map[string]*storedata
var jsoncompare map[string]interface{}
* 打印输入信息
func printMessage(message string) {
fmt.Println(message, time.Unix(time.Now().Unix(), 0).String())
func listening(con net.Conn) {
data := make([]byte, 1024)
jsoncompare = make(map[string]interface{})
//打印连接对象IP 端口
fmt.Println("新链接地址: ", con.RemoteAddr(), time.Unix(time.Now().Unix(), 0).String())
var content string
//内容 长度接收
length, err := con.Read(data)
if err != nil {
fmt.Println("客户端退出.\n", con.RemoteAddr(), time.Unix(time.Now().Unix(), 0).String())
con.Close()
content = content + string(data[0:length])
//json数据正常
if err := json.Unmarshal([]byte(content), &jsoncompare); err == nil {
fmt.Println(con.RemoteAddr(), "发送成功 : ", content, time.Unix(time.Now().Unix(), 0).String())
//判断传送类型 type 1 启动客户监听 2 停止客户监听
typeVal := gojson.Json(content).Get("type").Tostring()
uid := gojson.Json(content).Get("uid").Tostring()
if typeVal == "1" {
var userObj UserInfo
userObj.source = gojson.Json(content).Get("source").Tostring()
userObj.account = gojson.Json(content).Get("account").Tostring()
userObj.password = gojson.Json(content).Get("password").Tostring()
userObj.uid = uid
userObj.sinceId = "0"
//检测是否已经开启 如果已经开启 不在开启
if _, ok := UserMap[userObj.uid]; ok {
con.Write([]byte(userObj.uid + " 现在正在运行中..."))
var accountData storedata
state := make(chan int)
accountData = storedata{state, ""}
fmt.Println(&accountData)
UserMap[userObj.uid] = &accountData
//判断senceId是否存在
if val, ok := UserMap[userObj.uid]; ok {
userObj.sinceId = (*val).sinceId
//开启新浪消息服务连接
go userObj.createConnect()
} else if typeVal == "2" {
//设置关闭
go setClose((*(UserMap[uid])).state)
con.Write([]byte(uid + " 稍后停止 "))
fmt.Println(con.RemoteAddr(), " Json信息指令有误 : ", content, time.Unix(time.Now().Unix(), 0).String())
con.Write([]byte("传送的数据不正确,请重新传送指令"))
content = ""
con.Write([]byte("信息发送成功..."))
* 设置新浪服务监听停止
func setClose(val chan int) {
func main() {
//设置用的cup核数
runtime.GOMAXPROCS(runtime.NumCPU())
printMessage("监听服务开启了...")
UserMap = make(map[string]*storedata)
//设置socket监听
lis, err := net.Listen("tcp", HOST+":"+PORT)
defer lis.Close()
if err != nil {
printMessage("监听的host和端口 : " + HOST + ":" + PORT)
os.Exit(-1)
//监听端口
conn, err := lis.Accept()
conn.SetDeadline(time.Now().Add(60 * time.Second)) //60秒断开
if err != nil {
printMessage("客户端连接错误 : " + err.Error())
os.Exit(0)
go listening(conn)
* 创建连接
func (obj *UserInfo) createConnect() {
content string
data := make([]byte, 1024)
//结束标识
accountStr := base64.StdEncoding.EncodeToString([]byte(obj.account + ":" + obj.password)) //帐号:密码 base64
//tr := &http.Transport{}
//创建连接
client := &http.Client{}
url := "https://m./2/messages/receive.json?source=" + obj.source + "&uid=" + obj.uid
if obj.sinceId != "" {
url = url + "since_id=" + obj.sinceId
req, _ := http.NewRequest("GET", url, nil)
req.Header.Add("Connection", "Close")
req.Header.Set("Host", "https://m.")
req.Header.Set("Authorization", "Basic "+accountStr)
printMessage(obj.uid + "新浪消息服务监听开始...")
response, _ := client.Do(req)
fmt.Println("connet statuscode :", response.StatusCode)
if response.StatusCode != 200 {
printMessage(obj.uid + "新浪消息服务监听失败...")
response.Body.Close()
time.Sleep(2 * time.Second)
//默认执行接收会阻塞
当接收到停止命令后不会立即停止
会在接收到数据后里面停止
printMessage(obj.uid + "进入循环接收内容...")
n, err = io.ReadAtLeast(response.Body, data, 1)
if err == io.EOF {
response.Body.Close()
content = string(data[0:n])
if err := json.Unmarshal([]byte(content), &jsoncompare); err == nil {
case &-(*(UserMap[obj.uid])).state:
printMessage(obj.uid + "新浪消息服务监听结束...")
delete(UserMap, obj.uid)
//退出该协成命令
runtime.Goexit()
//设置senceID
senceId := gojson.Json(content).Get("id").Tostring()
if senceId != "" {
UserMap[obj.uid] = &storedata{(*(UserMap[obj.uid])).state, senceId}
//通知接收api
go send(&content)
//通知其他应该
func send(jsonStr *string) {
fmt.Println(*jsonStr)
client.go&~&840B&&&&
package main
var str string
var msg = make([]byte, 1024)
func main() {
= "127.0.0.1"
remote = host + ":" + port
con, err := net.Dial("tcp", remote)
defer con.Close()
if err != nil {
fmt.Println("Server not found.")
os.Exit(-1)
fmt.Println("Connection OK.")
fmt.Printf("Enter a sentence:")
fmt.Scanf("%s\n", &str)
if str == "quit" {
fmt.Println("Communication terminated.")
os.Exit(1)
in, err := con.Write([]byte(str))
if err != nil {
fmt.Printf("Error when send to server: %d\n", in)
os.Exit(0)
length, err := con.Read(msg)
if err != nil {
fmt.Printf("Error when read from server.\n")
os.Exit(0)
str = string(msg[0:length])
fmt.Println(str)
3.&[代码][Google Go]代码&&&&
传输json数据串
开启监听服务
{"type":"1","source":"xxxx","uid":"xxxx","account":"xxxxx","password":"xxxxx"}
关闭监听服务
{"type":"2","uid":"xxxxx"}
开源中国-程序员在线工具：
相关的代码(12)
[Google Go]
[Google Go]
[Google Go]
[Google Go]
[Google Go]
[Google Go]
[Google Go]
[Google Go]
[Google Go]
[Google Go]
开源从代码分享开始
gangbo的其它代码新浪微博，如果我没有关注别人，可以@他吗？他能收到信息吗_百度知道
新浪微博，如果我没有关注别人，可以@他吗？他能收到信息吗
提问者采纳
提问者评价
太给力了，你的回答完美解决了我的问题！
其他类似问题
为您推荐：
新浪微博的相关知识
其他2条回答
可以 会受到
等待您来回答
下载知道APP
随时随地咨询
出门在外也不愁扫描或点击关注中金在线客服
下次自动登录
其它账号登录：
||||||||||||||||||||||||
&&&&>> &正文
阿里巴巴买完优土，又被预测要收购新浪微博了，怎么说？
来源：虎嗅网&&&
作者：佚名&&&
中金在线微博微信
扫描二维码
中金在线微信
　　上周五(10月16日)，阿里巴巴集团(以下简称“阿里”)宣布，已向优酷土豆公司(以下简称“优土”)董事会发出非约束性要约，拟现金收购视频网站优酷土豆。当时消息一出，大家又炸了，可能在想这还有阿里没收购的么。
　　今天这个来自美国知名财经网站SeekingAlpha的预测就是在告诉你，有啊，阿里还没有收购新浪微博(以下简称“微博”)啊，说不准一高兴还可以把新浪也一起收了呢。
　　我们先看下SeekingAlpha网站是怎么说的(虎嗅翻译后编辑)：
　　阿里巴巴可能会在未来的6个月里收购新浪微博，以和优土同样的模式，将其转为一家全资子公司。
　　在阿里巴巴宣布将斥资45亿美元收购优土剩余股权之后，，#说明新浪微博的投资人认为阿里巴巴全资并购的可能性加大，“并购说”不无道理
　　让我们回顾下新浪微博和优土视频的相似之处，来解释为何阿里收购新浪微博几乎的必然之举。首先，微博和优土的公司规模很相似，美股最新数据显示，新浪微博的市值为32亿美元，市值甚至还低于优土的50亿美元。截至二季度末期，阿里巴巴集团持有的现金规模为230亿美元，也就是说阿里用一些零花钱就可以收购新浪微博。
　　另外，微博和优土都经历了盈利模式不明确的历史性挑战。
　　优土一直没有寻找到明确的盈利模式，而他们最近大手笔的砸钱在原创内容和好莱坞电影版权上。尽管投资力度大，但目前从账面上看，还未见成效。优土上一季度净亏损达5500万美元，是去年同期亏损的两倍还多。而新浪微博尽管在上季度终于取得了420万美元的少量利润，但纵观过去它还不长的生命周期，几乎都在全力以赴地亏损。
　　而阿里愿意接盘优土的原因，也可能成为阿里收购微博的原因——填补阿里的业务空白。#阿里难道要包下所有的产业，才叫没有空白咩？
　　如果阿里的野心是成为全产业互联网巨头的话，那么微博和优土的加入的确能补上阿里一直以来的巨大业务空白。优土的到来填上了阿里娱乐产业拼图上的一块。同理，微博的加入可以补上阿里在社交领域的漏洞，毕竟阿里两年前大张旗鼓搞的亲生仔“来往”最后还是“死掉”了。
　　另外在公司所有权上，微博和优土也有相似之处。在上周公布阿里收购优土之前，阿里及其附属公司就已经在去年以12亿美元的价格购买了优土近20%的股权。同样地，阿里也在2013年以6亿美元收购了微博20%的股份，之后又宣布将提高股权份额至30%。
　　最后，它们的CEO也有不少共通之处。和很多其他中国互联网公司的头头不一样，优土CEO古永锵和微博董事长、新浪CEO曹国伟都是务实的人，不会将公司视为神圣不可收购的私人领地。两人对公司都没有个人执念，但这往往是横亘在中国互联网并购案中的核心阻力。相反，他们更有商人作风，愿意做出对股东最有利的选择，而不是执着于个人地位。
　　基于以上，作者十分看好阿里在未来6个月内向新浪微博发出收购要约。而且更具诱惑的是，如果阿里收购如今控股微博的新浪(新浪最新市值为27亿美元，PS：低于新浪微博的32亿美元估值)，阿里巴巴将能同时掌控中国互联网两大最有地位的网站：新浪和新浪微博。
　　而且从10月15日开始，新浪微博就和阿里旅游宣布了深度的战略合作，双方将在今年双11期间推出名为“蜻蜓客”的旅游产品。
责任编辑：cnfol001
好消息！还在为选择留学院校而苦恼吗？还在为复杂的移民申请流程而心烦吗？818出国网微信号汇聚最新的出国资讯，提供便捷的移民留学项目查询和免费权威的专家评估，为你的出国之路添能加油！
微信关注方法：1、扫描左侧二维码：2、搜索“818出国网”（chuguo818）关注818出国网微信。
我来说两句
24小时热门文章
栏目最新文章【新浪微博】新浪微博招聘|待遇|面试|怎么样-看准网
向公司老鸟咨询
问题将会推送给60位【新浪微博】老鸟，描述不清/无意义问题将会被删除哦~
问题标题（限30字）
新浪微博怎么样？
本行业综合排名5，查看排名
新浪微博待遇
元(平均月薪)&
比同行业水平高21%
1、负责微博“社会化营销”、“社会化营销案例库”、“微博营销快讯”等蓝V账号及“Social营销案例”、“社会化营销”微博、微信...
网友对新浪微博工资的印象 &&
相当不准了
1.负责新浪微博iPhone客户端的功能设计和开发
2.负责维护微博iPhone客户端，分析和解决用户碰到的各种疑难杂症
3.负责客户端的性能优化以及各种实用工具的开发...
网友对新浪微博工资的印象 &&
岗位职责：
1. 负责营销中心商机挖掘的APP 以及配套的社会化营销账号矩阵；
2. 负责产品原型设计工作和部分产品功能文档编写工作；
网友对新浪微博工资的印象 &&
1. 负责电销团队的整体业务管理、团队管理及相关支持平台的建设：
? 建立、积累、管理社会化营销潜在客户数据，领导团队有效地将潜在客户资源转...
网友对新浪微博工资的印象 &&
? 完成潜在商机的挖掘与过滤，促成商机的转化，完成新客户开发任务；
? 负责跟进、维护客户关系；
? 接受公司及部门提供的相关培训与训练，掌...
工作经验不限
面试整体感受
很好&&&&39%
一般&&&&52%
不好&&&&9%
2.7难度系数
获取面试机会来源
网络招聘 &&36%
校园招聘 &&36%
社会招聘 &&11%
内部推荐 &&6%
猎头推荐 &&3%
&&&&工资范围
&&&&&&&&行业竞争力
￥4700&-&￥22000
比同行业高8%
￥3000&-&￥17000
比同行业低10%
￥9000&-&￥12500
比同行业高1%
￥10000&-&￥12000
比同行业高53%
￥10000&-&￥13000
--&与同行业持平
&&&&&&&请或解锁
&&&&&&&请或解锁
&&&&&&&请或解锁
&&&&&&&请或解锁
&&&&&&&请或解锁
1、负责微博“社会化营销”、“社会化营销案例库”、“微博营销快讯”等蓝V账号及“Social营销案例”、“社会化营销”微博、微信...
登陆并完善简历后，即可看到相应的匹配度分值。该值通过您的经历与该职位的要求计算所得，简历完善度越高，分值也会越高。分值越高，表示您与该岗位的适合度越高，申请后获得面试机会的概率也越大。
1.负责新浪微博iPhone客户端的功能设计和开发
2.负责维护微博iPhone客户端，分析和解决用户碰到的各种疑难杂症
3.负责客户端的性能优化以及各种实用工具的开发...
登陆并完善简历后，即可看到相应的匹配度分值。该值通过您的经历与该职位的要求计算所得，简历完善度越高，分值也会越高。分值越高，表示您与该岗位的适合度越高，申请后获得面试机会的概率也越大。
岗位职责：
1. 负责营销中心商机挖掘的APP 以及配套的社会化营销账号矩阵；
2. 负责产品原型设计工作和部分产品功能文档编写工作；
登陆并完善简历后，即可看到相应的匹配度分值。该值通过您的经历与该职位的要求计算所得，简历完善度越高，分值也会越高。分值越高，表示您与该岗位的适合度越高，申请后获得面试机会的概率也越大。
1. 负责电销团队的整体业务管理、团队管理及相关支持平台的建设：
? 建立、积累、管理社会化营销潜在客户数据，领导团队有效地将潜在客户资源转...
登陆并完善简历后，即可看到相应的匹配度分值。该值通过您的经历与该职位的要求计算所得，简历完善度越高，分值也会越高。分值越高，表示您与该岗位的适合度越高，申请后获得面试机会的概率也越大。
? 完成潜在商机的挖掘与过滤，促成商机的转化，完成新客户开发任务；
? 负责跟进、维护客户关系；
? 接受公司及部门提供的相关培训与训练，掌...
工作经验不限
登陆并完善简历后，即可看到相应的匹配度分值。该值通过您的经历与该职位的要求计算所得，简历完善度越高，分值也会越高。分值越高，表示您与该岗位的适合度越高，申请后获得面试机会的概率也越大。
工作职责：
1、 负责项目官方账号运营，提升关注度，增加粉丝数量；
2、 参与频道日常选题的策划、编辑、发布及推广执行工作；
3、 基于运营...
登陆并完善简历后，即可看到相应的匹配度分值。该值通过您的经历与该职位的要求计算所得，简历完善度越高，分值也会越高。分值越高，表示您与该岗位的适合度越高，申请后获得面试机会的概率也越大。
工作职责：
1、负责代理公司合作及服务相关工作，包括日常咨询、广告版位管理、制作修改排期、完成合同流程、协调广告发布以及完成监测报告等；
登陆并完善简历后，即可看到相应的匹配度分值。该值通过您的经历与该职位的要求计算所得，简历完善度越高，分值也会越高。分值越高，表示您与该岗位的适合度越高，申请后获得面试机会的概率也越大。
通过培训、辅导、话术设计等手段带领本组顾问完成阶段性业绩指标以及培训指标
1. 培训组织
? 规划培训方案
? 协调内外部讲师资源
登陆并完善简历后，即可看到相应的匹配度分值。该值通过您的经历与该职位的要求计算所得，简历完善度越高，分值也会越高。分值越高，表示您与该岗位的适合度越高，申请后获得面试机会的概率也越大。
【岗位职责】
1、配合销售团队完成商业项目全案的服务支持工作。
2、参与项目提案阶段，同需求方一起进行可行性评估、头脑风暴、客户方案的分析、...
登陆并完善简历后，即可看到相应的匹配度分值。该值通过您的经历与该职位的要求计算所得，简历完善度越高，分值也会越高。分值越高，表示您与该岗位的适合度越高，申请后获得面试机会的概率也越大。
岗位职责：
1、负责公司微博内容发布、维护、管理、粉丝互动、话题制造，提高影响力和粉丝数；
2、微博内容文案及活动文案设计撰写，对潮流时尚...
登陆并完善简历后，即可看到相应的匹配度分值。该值通过您的经历与该职位的要求计算所得，简历完善度越高，分值也会越高。分值越高，表示您与该岗位的适合度越高，申请后获得面试机会的概率也越大。
网友对新浪微博工资的印象 &&
相当不准了
网友对新浪微博工资的印象 &&
网友对新浪微博工资的印象 &&
网友对新浪微博工资的印象 &&
行业好评度排名
看了该公司的人还看了
4461条信息
你在这里工作过？
点击星星为公司打分
想知道新浪微博怎么样？看准网()免费提供新浪微博招聘、新浪微博工资、新浪微博面试、评价、工作环境招聘及员工等信息。
另，本页主题别名有：新浪二面通知。
SNS/社交网络行业优秀公司
恭喜你已完成简历，共获得积分分享到微信
使用微信扫码将网页分享到微信
大约半年前，新浪尝试会员收费。“咚”一声后，石沉大海，鲜见后文。
时隔半年，现在传出的关于新浪微博商业化的消息，是它要的消息。
这个消息的传出不是没有依据的。本周三，从阿里离职后又与阿里有千丝万缕关系的丁香园 CTO 冯大辉（@Fenng）：阿里要投资新浪微博。其提到的原因，包括流量入口、言论阵地、狙击腾讯、低仓进入、SNS 情结等等。
其后程苓峰称，新浪微博从新浪门户剥离出来成为独立公司，估值 20-30 亿美元，阿里投资新浪微博 15%-20% 股份。其所依据的是新浪微博商业化压力，新浪微博在自助广告系统的布局，及阿里对流量入口的需求。
官方目前还没有回应。
不过从新浪 CEO 曹国伟 11 月 16 日财报会议上的发言，能找到两者之间合作的利益点。
在回答美林分析师关于新浪中小企业广告系统进展的时候，曹国伟回答：
中小企业在新广告系统上的投入见效需要时间……我们想给中小企业足够的广告位，测试新推荐引擎，提高其精准程度。我们推出的基于信息流的广告系统将非常适合于中小企业，我们正在进行测试，尚未产生太多收入。
而在谈到新浪为微博平台的中小企业广告系统所作的准备时，曹国伟的回答是：
这种广告将比微博平台上的显示广告系统更高效。但这更依赖于数据，我们需要很多数据、个人资料和微博关系图谱，因此这一推荐引擎需要很长时间进行微调。当然中小企业客户更注重精准投放的问题，大客户更注重社会效果，这两种需求相差很大，我们将尝试从中予以平衡。
概括来说，来自官方的主要是三个信息：
1. 新浪微博正在测试中小企业广告系统，即人们所熟知的类似于 Facebook 精准广告投放系统
2. 新浪微博中小广告系统目前面向 23 万微博企业账户，目标用户规模太小
3. 新浪微博新广告系统非常依赖大数据分析，新浪在这方面压力山大
这样，对于新浪与阿里的合作，新浪方面的需求就非常简单了：一是用户，阿里巴巴号称有超过 1000 万中小企业商户，这正是新浪需要的中小企业商户群体；二是阿里在大数据分析方面有丰富的技术积累，这正是新浪迫切需要的。只是由于这个中小企业广告系统还处在内测阶段，“卖相”不是特别好。
阿里能得到什么？冯大辉从阿里出来，比较了解阿里的需求，他提到的几个点：
流量入口。对于电商来说，入口永远不嫌多，况且在移动互联网时代，变现的渠道非常窄：广告，电商，游戏。新浪微博的会员服务半年来悄无声息，充分说明除了腾讯之外（增值服务），其他企业变现渠道跳不出这三种。
获取言论阵地、SNS 情结是意识形态方面的因素，在商业决策中重要性排在商业因素后面。
低仓进入和狙击腾讯。前者是战术手段，新浪微博估值是否处于低谷很难说，因为由周五新浪股价暴跌 15% 来看，投资者对于新浪微博商业化进展缓慢失望，及曹国伟所承认的微信对新浪微博的冲击，新浪微博的估值有可能进一步下降。狙击腾讯是阿里的目标，但腾讯电商还没有实质上威胁到阿里，这里还是归属为对“入口”的布局。
交易的主动权在于阿里。
不过，即使新浪微博如此这般好，考虑到 Facebook 在精准广告方面收入之微薄，阿里是否有信心与新浪微博一道来从头探索“信息流广告”？还是只把新浪微博作为一个流量入口？如果是后者，阿里显然不想花那么多钱。
一句话，阿里与新浪微博之间的合作可能性会很大。只是在时间点和合作深度上还需要看时机。
使用微信扫码关注爱范儿微信公众号
关注爱范儿微信号，连接热爱，关注这个时代最好的产品。
想让你的手机好用到哭？关注这个号就够了。
关注玩物志微信号，就是让你乱花钱。}