| 网站首页 | 业界新闻 | 小组 | 威客 | 人才 | 下载频道 | 博客 | 代码贴 | 在线编程 | 编程论坛
欢迎加入我们,一同切磋技术
用户名:   
 
密 码:  
共有 2968 人关注过本帖
标题:异步tcp通讯程序中读写文件的问题--第一次发帖请多关照
取消只看楼主 加入收藏
jingzhao22visa
Rank: 1
等 级:新手上路
威 望:1
帖 子:343
专家分:0
注 册:2006-8-10
收藏
 问题点数:0 回复次数:22 
异步tcp通讯程序中读写文件的问题--第一次发帖请多关照
刚进公司实习,被分配做socket通讯的程序。实在搞不定,请大家帮忙。

情况:
程序中已经实现了C/S之间的信息发送与接收,收发无误。但是现在要求要将收到的数据放入一个.dat文件。我所使用的收发全部是异步调用。例如BeginConnect,BeginReceive。
部分程序代码如下:
public unsafe void OnReceiveData(IAsyncResult ar)
{ Sock = (Socket)ar.AsyncState;
try
{ int nBytesRec = Sock.EndReceive(ar);
if (nBytesRec > 0)
{
。。。。。。。。。。。。。
string ss = Encoding.BigEndianUnicode.GetString(Receive_Buffer, 0, nBytesRec);
listBox_Receive.Items.Add(ss);
AddintoFile(ss);///在此处调用一个函数将收到的字符串写入文件。
Sock.BeginReceive(Receive_Buffer, 0, Receive_Buffer.Length,
SocketFlags.None,
new AsyncCallback(OnReceiveData),
Sock);
}


private unsafe void AddintoFile(string ss) //struct结构在最底下。
{
Test_Struct data;
byte* p;
char[] bt;
IntPtr ip;
string strV = ss;

bt = strV.ToCharArray();
data.tel_id = 99887;
data.test_data = 99999;
//fixed(byte * t=data.Telegram)
//{
//byte* tempt = t;
System.Runtime.InteropServices.Marshal.Copy(bt, 0, (IntPtr)data.Telegram, bt.Length);

p = (byte*)&data;

try
{
stlc.AddToHead(ref *p, sizeof(Test_Struct), 1);
}
*********************************************************
stlc.AddToHead(ref *p, sizeof(Test_Struct), 1);
此处的AddToHead函数是别人给的一个dll里面的函数
ref *p 引用的byte数组。即是要写入文件的bytes
sizeof(Test_Struct) 要写进去的bytes的长度
这个函数经过测试,是可以用的。当然是在单线程的
工作环境下。在这个异步调用的程序代码下,我经过
设置断点,只能看到确实执行了该句插入,也没有抛出异常。
但是就是文件里面写不进去。
我查了一些东西,可能是因为垃圾回收的问题,需要
将指针固定。但是固定指针的时候一直报错。fixed()
语句中一直不能用,说不能引用固定长度的指针。
p = (byte*)&data; 。(IntPtr)data.Telegram
使用fixed的时候就这两个地方出错。
有没有人帮忙看一下。

如果没有说清楚,我再补充。
*********************************************************
catch (Exception et)
{
MessageBox.Show(et.Message);
}
// }

strV = string.Format("After add data. total {0} telegrams in list", stlc.Size);
MessageBox.Show(strV);


}

private unsafe struct Test_Struct
{
public int tel_id;
public fixed byte Telegram[2048];
public int test_data;
}
搜索更多相关主题的帖子: tcp 异步 通讯 发帖 
2006-08-10 09:27
jingzhao22visa
Rank: 1
等 级:新手上路
威 望:1
帖 子:343
专家分:0
注 册:2006-8-10
收藏
得分:0 
SharedTelList 控件
利用共享内存,在不同进程间交换数据报文。
文件:SharedTelList.Dll


命名空间:SharedTelList
对象名称:SharedTelList.SharedTelListCtrl
线程模型:自由线程或MultiThread Apartment

使用方法:
1、建立一个全局的SharedTelList.SharedTelListCtrl对象实例。
2、初始化该对象,BOOL InitSharedList(FileName,Name,MaxNum, MaxLen, bClear)

接收报文
3、定时或事件触发,检查该对象中的报文数量,当有报文时,用long GetFromHead(BYTE * Telegram)
接收报文,Telegram 是接收报文的内存缓冲区地址指针,该缓冲区长度必须大于等于最大报文长度,
返回实际报文的长度。

其它函数:
AddToHead(),将报文添加到队列头部

这个addintofile是我照着别人给的示例程序大部分抄过来的。

p = (byte*)&data; data 是Test——Struct 结构的一个实例。 我认为此处应该是指向该结构体示例的一个指针类型。telegram是该实例的一个数据成员
如下所示:
private unsafe struct Test_Struct
{
public int tel_id;
public fixed byte Telegram[2048];
public int test_data;
}

addtohead(ref byte Telegram,int Length int isOverWirte)
具体的我也只能看到这里。






2006-08-10 09:58
jingzhao22visa
Rank: 1
等 级:新手上路
威 望:1
帖 子:343
专家分:0
注 册:2006-8-10
收藏
得分:0 
经过我设置断点,参数ss确实已经传进去了。而且是server端所收到的那个string。
然后继续执行就是AddToHead函数了,这个我只能看见它执行,且没有报错。我就不知道该怎么办了。
后来觉得可能指针被垃圾回收掉了,想看看fixed 指针可不可以,但是fixed语句使用诸多限制,无法安上去。

感谢你的回答,请继续帮我看看吧。

2006-08-10 10:01
jingzhao22visa
Rank: 1
等 级:新手上路
威 望:1
帖 子:343
专家分:0
注 册:2006-8-10
收藏
得分:0 
有的,dll是另一个人写的,他顺便也写了一个示例程序。包括增加报文和读报文。
我现在就是基本完全用的他的代码。那个示例程序完全没有错。
代码如下:




private void btnClose_Click(object sender, EventArgs e)
{
this.Close();
} //关闭窗口

private void btnInit_Click(object sender, EventArgs e)
{
string strV;
stlc = new SharedTelList.CSharedTelListCtrl();
if (stlc.InitSharedList("D:\\NetTelTest.dat", "SharedTel", 200, 4096, 1) != 0)
{
strV = string.Format("Initialize Telegram list success! Total telegram in list = {0}", stlc.Size);
System.Windows.Forms.MessageBox.Show(strV);
}
else
{
System.Windows.Forms.MessageBox.Show("Initialize Telegram list Fail!");
}
} //初始化文件,在这里我把文件清空


private unsafe void btnAdd1_Click(object sender, EventArgs e) //增加报文,也就是我的addintofile的函数了。
{
Test_Struct data;
byte *p ;
char[] bt;
//IntPtr ip;
//int i=0;
string strV = "Hello, this is a test";
bt = strV.ToCharArray();
//bt = Encoding.ASCII.GetBytes(strV);
int l=bt.Length;
data.tel_id = 99887;
data.test_data = 99999;
System.Runtime.InteropServices.Marshal.Copy(bt, 0, (IntPtr)data.Telegram, bt.Length);
///Buffer.BlockCopy(bt, 0, data.Telegram, 0, bt.Length);
//data.Telegram = strV;
//ip = new IntPtr((void *)data.Telegram);
//System.Runtime.InteropServices.Marshal.Copy(bt,0,ip,bt.Length);


p = (byte *)&data;
try
{
stlc.AddToHead(ref *p, sizeof(Test_Struct),1);
}
catch (Exception et)
{
MessageBox.Show(et.Message);
}
strV = string.Format("After add data. total {0} telegrams in list", stlc.Size);
MessageBox.Show(strV);
}

注明:我刚刚又试了一下,可以写入文件,但是全部都是乱码。比如,它这里可以写入Hello, this is a test"可以写入。我的写进去全是乱码,自然也无法读出来。 但是我不知道为什么会这样子。因为我几乎只是把它的传入的参数给改了而已。

private unsafe void btnReadData_Click(object sender, EventArgs e) //按照id99887来读写,弹出对话框。unkonwn id telegram
{
Test_Struct data;
byte[] buf = new byte[4086];
int telid;
int l;
string strV;
string strV1;
IntPtr p = new IntPtr((void *)&data);


try
{
l = stlc.GetFromTail(ref buf[0],0);
if (l == 0)
{
return;
}
telid = BitConverter.ToInt32(buf, 0);
if (telid == 99887)
{
//fixed ( void * pt = (void *)&data)
{

//p = (void*)&data;
System.Runtime.InteropServices.Marshal.Copy(buf, 0, p, l);

}
IntPtr p1 = new IntPtr((void*)data.Telegram);
strV1 = System.Runtime.InteropServices.Marshal.PtrToStringAuto(p1);
strV = string.Format("telid = {0}, test_data = {1}, telegram = |{2}|", data.tel_id, data.test_data, strV1);
MessageBox.Show(strV);
}
else
{
strV = string.Format("Unknow id telegram");
MessageBox.Show(strV);

}
stlc.DelFromTail(1);
}
catch (Exception et)
{
MessageBox.Show (et.Message);
}
}

private void Form1_Load(object sender, EventArgs e)
{

}
}

public unsafe struct Test_Struct
{
public int tel_id;
public fixed byte Telegram[2048];
public int test_data;
}

}

2006-08-10 10:26
jingzhao22visa
Rank: 1
等 级:新手上路
威 望:1
帖 子:343
专家分:0
注 册:2006-8-10
收藏
得分:0 
哭了,我就说啊,我的代码几乎都没有变过啊。。。
我用的是string ss = Encoding.BigEndianUnicode.GetString(Receive_Buffer, 0, nBytesRec);
这个是可以发送字符和汉字的列。
他用的是:
string strV = ss;

bt = strV.ToCharArray(); //这个是要获得char[]数组的
data.tel_id = 99887;
data.test_data = 99999;
//fixed(byte * t=data.Telegram)
//{
//byte* tempt = t;
System.Runtime.InteropServices.Marshal.Copy(bt, 0, (IntPtr)data.Telegram, bt.Length); //byte[] 数组好像只能用这种形式来复制

p = (byte*)&data;

try
{
stlc.AddToHead(ref *p, sizeof(Test_Struct), 1);


反正我是不知道该怎么办了。。。。。
crying
昨天已经搞了一天了。。。

2006-08-10 10:59
jingzhao22visa
Rank: 1
等 级:新手上路
威 望:1
帖 子:343
专家分:0
注 册:2006-8-10
收藏
得分:0 
UlTraEdit。。。。。。。。。。
关于这个,不知道是什么列。。
还有。。。内码?
反正我有跟踪
快速监视什么的。。。

比如传送t字符 data.telegram监视下面就第一个被赋值。。 116
我自己用的时候就是那个不成功的传送。c-s可以成功,但是s中放入文件赋值都是对的,addtohead我就不知道了。
用他自己的示例,t 的字符也是data.telegram监视下面就第一个被赋值。。 116
其它的我就不知道了。


2006-08-10 11:04
jingzhao22visa
Rank: 1
等 级:新手上路
威 望:1
帖 子:343
专家分:0
注 册:2006-8-10
收藏
得分:0 
好,谢谢了。我发到你邮箱里。

2006-08-10 11:14
jingzhao22visa
Rank: 1
等 级:新手上路
威 望:1
帖 子:343
专家分:0
注 册:2006-8-10
收藏
得分:0 
bt = strV.ToCharArray(); //这个是要获得char[]数组的

這個改為bt = Encoding.UTF8.GetBytes(strV); 啊
但是他的程序里涌了这个System.Runtime.InteropServices.Marshal.Copy(bt, 0, (IntPtr)data.Telegram, bt.Length); 函数

这里写错了
//byte[] 数组好像只能用这种形式来复制
这里写错了
是要把转换以后的char数组复制到 (IntPtr)data.Telegram里面。所以不能改。

bt = strV.ToCharArray(); //这个是要获得char[]数组的
data.tel_id = 99887;
data.test_data = 99999;
//fixed(byte * t=data.Telegram)
//{
//byte* tempt = t;
System.Runtime.InteropServices.Marshal.Copy(bt, 0, (IntPtr)data.Telegram, bt.Length); //byte[] 数组好像只能用这种形式来复制



而且,我现在测试错误的时候都只发送字符串而已。甚至一个字符。
所以应该没有ascii和其它的问题吧
就是不知道dll内部程序会不会有问题。

2006-08-10 11:19
jingzhao22visa
Rank: 1
等 级:新手上路
威 望:1
帖 子:343
专家分:0
注 册:2006-8-10
收藏
得分:0 
谢了,我上网上查查看这个东西。


2006-08-10 11:24
jingzhao22visa
Rank: 1
等 级:新手上路
威 望:1
帖 子:343
专家分:0
注 册:2006-8-10
收藏
得分:0 
怎么了?
有什么问题吗?你是说那个有病毒?然后把你邮箱的邮件都删掉了?

2006-08-10 11:26
快速回复:异步tcp通讯程序中读写文件的问题--第一次发帖请多关照
数据加载中...
 
   



关于我们 | 广告合作 | 编程中国 | 清除Cookies | TOP | 手机版

编程中国 版权所有,并保留所有权利。
Powered by Discuz, Processed in 0.052638 second(s), 8 queries.
Copyright©2004-2024, BCCN.NET, All Rights Reserved