js同步程序是如何向异步程序演变的
js的异步调用很重要,凡是涉及到网络调用和事件机制的代码都会用到它。第一眼看上去的时候异步调用很特别,和之前设计程序使用的同步调用方法很不一样。实质上他们之前的区别没有相像中那么大。本文尝试用几个例子说明同步程序是如何向异步程序演变的。
从C/C++的同步调用开始
1 使用C语言的编码方式实现调用访问远程的接口
view plaincopy to clipboardprint?
int get_data()
{
char bufCmd[]="cmd=1001&uin=123456¶m=abc";
char bufRcv[4096];
socket s = new Socket();
Connnect(s, ip, port);
send(s, bufCmd);
recv(s, bufRcv);
use(bufRcv);
return 0;
}
int get_data()
{
char bufCmd[]="cmd=1001&uin=123456¶m=abc";
char bufRcv[4096];
socket s = new Socket();
Connnect(s, ip, port);
send(s, bufCmd);
recv(s, bufRcv);
use(bufRcv);
return 0;
}
2 将通信过程封装成独立的函数,简化业务流程代码
view plaincopy to clipboardprint?
// 发包收包的过程
int send_and_recv(struct addr, char* bufCmd, char* bufRcv)
{
socket s = new Socket();
Connnect(s, addr.ip, addr.port);
send(s, bufCmd);
recv(s, bufRcv);
}
// 原来的业务流程
int get_data_v2()
{
char bufCmd[]="cmd=1001&uin=123456¶m=abc";
char bufRcv[4096];
// addr={ip, port}
send_and_recv(addr, bufCmd, bufRcv);
use(bufRcv);
return 0;
}
// 发包收包的过程
int send_and_recv(struct addr, char* bufCmd, char* bufRcv)
{
socket s = new Socket();
Connnect(s, addr.ip, addr.port);
send(s, bufCmd);
recv(s, bufRcv);
}
// 原来的业务流程
int get_data_v2()
{
char bufCmd[]="cmd=1001&uin=123456¶m=abc";
char bufRcv[4096];
// addr={ip, port}
send_and_recv(addr, bufCmd, bufRcv);
use(bufRcv);
return 0;
}
3 将通信过程变成异步调用
view plaincopy to clipboardprint?
// 变成异步调用以后,原来的调用过程分成了两段
// 前半段组装参数调用发包过程
// 后半段处理返
// 这里假设send_and_recv是一个异步的网络通信函数
void get_data_v3()
{
char bufCmd[]="cmd=1001&uin=123456¶m=abc";
char bufRcv[4096];
send_and_recv_async(addr, bufCmd, bufRcv, callback); } // end of get_data_v4
// definition of call back function
int callback(char* bufRcv) {
use(bufRcv);
return 0;
}
// 变成异步调用以后,原来的调用过程分成了两段
// 前半段组装参数调用发包过程
// 后半段处理返
// 这里假设send_and_recv是一个异步的网络通信函数
void get_data_v3()
{
char bufCmd[]="cmd=1001&uin=123456¶m=abc";
char bufRcv[4096];
send_and_recv_async(addr, bufCmd, bufRcv, callback); } // end of get_data_v4
// definition of call back function
int callback(char* bufRcv) {
use(bufRcv);
return 0;
}
4 假设处理结果的时候依赖外部参数
view plaincopy to clipboardprint?
// 这里原来的业务流程需要外部传进来的两个参数(a,b)来决定如何处理结果
int get_data_v4(int a, int b)
{
char bufCmd[]="cmd=1001&uin=123456¶m=abc";
char bufRcv[4096];
send_and_recv(addr, bufCmd, bufRcv);
use(bufRcv, a, b);
return 0;
}
// 这里原来的业务流程需要外部传进来的两个参数(a,b)来决定如何处理结果
int get_data_v4(int a, int b)
{
char bufCmd[]="cmd=1001&uin=123456¶m=abc";
char bufRcv[4096];
send_and_recv(addr, bufCmd, bufRcv);
use(bufRcv, a, b);
return 0;
}
5 加上参数依赖后再变成异步调用
view plaincopy to clipboardprint?
// 需要参数的异步调用需要将参数透传到后半段的回调函数中
void get_data_v5(int a, int b)
{
char bufCmd[]="cmd=1001&uin=123456¶m=abc";
char bufRcv[4096];
send_and_recv_async(addr, bufCmd, bufRcv, callback); } // end of get_data_v5
// definition of call back function
int callback(char* bufRcv, int a, int b) {
use(bufRcv, a, b);
return 0;
}
// 需要参数的异步调用需要将参数透传到后半段的回调函数中
void get_data_v5(int a, int b)
{
char bufCmd[]="cmd=1001&uin=123456¶m=abc";
char bufRcv[4096];
send_and_recv_async(addr, bufCmd, bufRcv, callback); } // end of get_data_v5
// definition of call back function
int callback(char* bufRcv, int a, int b) {
use(bufRcv, a, b);
return 0;
}
6 使用一个closure对象打包过程中的参数
view plaincopy to clipboardprint?
// 为了统一回调函数的形式并且缩短回调的参数列表,将这种需要透传的参数只有一个
// 统一的数据结构打包
void get_data_v6(int a, int b)
{
char bufCmd[]="cmd=1001&uin=123456¶m=abc";
char bufRcv[4096];
send_and_recv(addr, bufCmd, bufRcv, callback); } // end of get_data_v6
// definition of call back function