关于Delegate【代理、委托】是C#中一个非常重要的概念,向前可以推演到C++的指针,向后可以延续到匿名方法、lambda表达式。
现在我就从一个最简单最实用的一个小例子出发分析一下Delegate的使用。
现在有两个窗体Form1和Form2。
两个按钮Button1(Form)和Button2(Form2)。
Form1的代码:
private void button1_Click(object sender, EventArgs e)
{
Form2 frm = new Form2(textBox1.Text);
frm.SetProperty += new Form2.DelegateText(SetProperty2);
frm.ShowDialog();
}
private void SetProperty2()
{
MessageBox.Show("ok");
}
Form2的代码:
public delegate void DelegateText();
public DelegateText SetProperty;
private void button2_Click(object sender, EventArgs e)
{
SetProperty();
}
分析者两段简短的代码,可以看出一些Delegate的好处,之前我写这个功能的时候是将form1的对象传给form2,点击form2之后再铜鼓from1的对象调用form1的public方法,这样的代码总觉得很别扭,也就是所谓的类型不安全,需要公开所要调用的方法,还需要将form1的对象传递至form2中,显然不是最佳的方案。
现在有了Delegate问题就迎刃而解了,相当于new form2的时候,我让form2代替我去更新属性的操作,这样我的方法不需要暴露出来,而form2也只能调用这一个方法,也就达到了所谓的类型安全的说法,此虽是个小例子,但是却能管中窥豹,看到一些Delegate的好处。
如果不同的观点请各位博友留言讨论。
OceanBase的序列化协议是一种可扩展的协议,其基本单元为:
<TYPE_FLAG_FILED><Content>
一个完整的数据包是形如下面的内容:
<TYPE_FLAG_FILED><Content><TYPE_FLAG_FILED><Content><TYPE_FLAG_FILED><Content>.......<TYPE_FLAG_FILED><Content>
例如:
<RESERVE_PARAM_FIELD><readmode:1, trans_id:102><BASIC_FIELD_PARAM><tid:1024, cid:21, other:abc>....
接收端解析方式:
bool more = true; while(more) { MyClass.deserialize(buf, pos, flag); switch(flag) { case RESERVE_PARAM_FIELD: deserialize_readmode(); deserialize_trans_id(); break; case BASIC_FIELD_PARAM: deserialize_tid_cid(); deserialize_other(); break; case END_PARAM: more = false; break; } }
通过这种方式,可以很方便的加入新的域,而不影响与老版本程序的兼容性。新版本程序可以处理老版本程序发来的数据包,即:向后兼容。
OceanBase中大量使用了这种方式来处理,但我觉得,过于泛滥。因为: 兼容性有必要,但是没必要细化到每一个域。只要用一个比较粗的域来区分新旧版本即可,对于同一个版本内用RESERVE_PARAM_FIELD,BASIC_FIELD_PARAM这种区分每个域没必要,只需要按照约定顺序解析数据即可。
#include <stdio.h>
#include <string.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <sys/file.h>
#include <sys/time.h>
#include <errno.h>
#include <unistd.h>
#include <stdlib.h>
static int get_random_fd (void)
{
static int fd = -2;
if (fd == -2)
{
fd = open ("/dev/random", O_RDONLY | O_NONBLOCK);
if (fd == -1)
fd = open ("/dev/urandom", O_RDONLY | O_NONBLOCK);
}
return fd;
}
void get_random_bytes(void* buf, int nbytes)
{
int i, fd = get_random_fd();
int lose_counter = 0;
char *cp = (char*)buf;
struct timeval tv;
static unsigned seed = 0;
if (fd >= 0)
{
while (nbytes > 0)
{
i = read (fd, cp, nbytes);
if ((i < 0) &&
((errno == EINTR) || (errno == EAGAIN)))
continue;
if (i <= 0)
{
if (lose_counter++ == 8)
break;
continue;
}
nbytes -= i;
cp += i;
lose_counter = 0;
}
}
for (i = 0; i < nbytes; i++)
{
if (seed == 0)
{
gettimeofday(&tv, 0);
seed = (getpid() << 16) ^ getuid() ^ tv.tv_sec ^ tv.tv_usec;
}
*cp++ = rand_r(&seed) & 0xFF;
}
return;
}
int main()
{
return 0;
}