Boost asio异步TCP通讯及tcp粘包解包解决方案

Boost asio异步TCP通讯及tcp粘包解包解决方案

Boost asio异步TCP通讯及tcp粘包解包解决方案

Sphinx调用命令列表 [Shell/批处理],Spring连接MySQL、Oracle和SQL Server的数 sql防注入的登录注册 [SQL],Struts 2剔除Ongl表达式危险的数据类型。

SVG绘制圆弧

svn 小冲突解决 笔记

tableview 全面自定制

int main()

{

namespace ip = boost::asio::ip;

boost::asio::io_service io_service;

// Server binds to any address and any port.

ip::udp::socket socket(io_service,

ip::udp::endpoint(ip::udp::v4(), 0));

socket.set_option(boost::asio::socket_base::broadcast(true));

// Broadcast will go to port 8888.

ip::udp::endpoint broadcast_endpoint(ip::address_v4::broadcast(), 8888);

// Broadcast data.

//boost::array<char, 4> buffer;

char* buf = "测试代码";

socket.send_to(boost::asio::buffer(buf,strlen(buf)+1), broadcast_endpoint); }

//jQuery地区三级联动选择输入

//jquery实现网站列表切换效果（2种方法）

//js动画完美框架 [文件] skiplist.cpp ~ 5KB

/* skip list */

#include <stdio.h>

#include <stdlib.h>

/* implementation dependent declarations */

typedef enum {

STATUS_OK,

STATUS_MEM_EXHAUSTED,

STATUS_DUPLICATE_KEY,

STATUS_KEY_NOT_FOUND

} statusEnum;

// js实现鼠标hover时tab自动切换

typedef int keyType; /* type of key */

/* user data stored in tree */

typedef struct {

int stuff; /* optional related data */

} recType;

Boost asio异步TCP通讯及tcp粘包解包解决方案

#define compLT(a,b) (a < b)

#define compEQ(a,b) (a == b)

/* levels range from (0 .. MAXLEVEL) */

#define MAXLEVEL 15

typedef struct nodeTag {

keyType key; /* key used for searching */

recType rec; /* user data */

struct nodeTag *forward[1]; /* skip list forward pointer */

} nodeType;

[代码] [Google Go]代码

package main

import (

"io/ioutil"

"net/http"

"net/"

"fmt"

"encoding/json"

)

//----------------------------------

// 黄金数据调用示例代码 － 聚合数据

// 在线接口文档：www/docs/29

//----------------------------------

const APPKEY = "*******************" //您申请的APPKEY

func main(){

//1.上海黄金交易所

Request1()

//2.上海期货交易所

Request2()

//3.银行账户黄金

Request3()

}

//1.上海黄金交易所

func Request1(){

//请求地址

Boost asio异步TCP通讯及tcp粘包解包解决方案

juhe :="web:8080/finance/gold/shgold"

//初始化参数

param:=.Values{}

//配置请求参数,方法内部已处理encode问题,中文参数可以直接传参

param.Set("key",APPKEY) //APP Key

param.Set("v","") //JSON格式版本(0或1)默认为0

//发送请求

data,err:=Get(juhe,param)

if err!=nil{

fmt.Errorf("请求失败,错误信息:\r\n%v",err)

}else{

var netReturn map[string]interface{}

json.Unmarshal(data,&netReturn)

if netReturn["error_code"].(float64)==0{

fmt.Printf("接口返回result字段是:\r\n%v",netReturn["result"]) }

}

}

//2.上海期货交易所

func Request2(){

//请求地址

juhe :="web:8080/finance/gold/shfuture"

//初始化参数

param:=.Values{}

//配置请求参数,方法内部已处理encode问题,中文参数可以直接传参

param.Set("key",APPKEY) //APP Key

param.Set("v","") //JSON格式版本(0或1)默认为0

//发送请求

data,err:=Get(juhe,param)

if err!=nil{

fmt.Errorf("请求失败,错误信息:\r\n%v",err)

}else{

var netReturn map[string]interface{}

json.Unmarshal(data,&netReturn)

if netReturn["error_code"].(float64)==0{

Boost asio异步TCP通讯及tcp粘包解包解决方案

fmt.Printf("接口返回result字段是:\r\n%v",netReturn["result"]) }

}

}

//3.银行账户黄金

func Request3(){

//请求地址

juhe :="web:8080/finance/gold/bankgold"

//初始化参数

param:=.Values{}

//配置请求参数,方法内部已处理encode问题,中文参数可以直接传参

param.Set("key",APPKEY) //APP Key

//发送请求

data,err:=Get(juhe,param)

if err!=nil{

fmt.Errorf("请求失败,错误信息:\r\n%v",err)

}else{

var netReturn map[string]interface{}

json.Unmarshal(data,&netReturn)

if netReturn["error_code"].(float64)==0{

fmt.Printf("接口返回result字段是:\r\n%v",netReturn["result"]) }

}

}

// get 网络请求

func Get(api string,params .Values)(rs[]byte ,err error){

var *.

,err=.Parse(api)

if err!=nil{

fmt.Printf("解析错误:\r\n%v",err)

return nil,err

}

//如果参数中有中文参数,这个方法会进行Encode

.RawQuery=params.Encode()

resp,err:=http.Get(.String())

if err!=nil{

fmt.Println("err:",err)

return nil,err

Boost asio异步TCP通讯及tcp粘包解包解决方案

}

defer resp.Body.Close()

return ioutil.ReadAll(resp.Body)

}

// post 网络请求 ,params 是.Values类型

func Post(api string, params .Values)(rs[]byte,err error){

resp,err:=http.PostForm(api, params)

if err!=nil{

return nil ,err

}

defer resp.Body.Close()

return ioutil.ReadAll(resp.Body)

}

代码描述：基于GO的黄金数据接口调用代码实例

关联数据：黄金数据