网上不是有很多资源下载的么? 谁说 2ccc没有. 上面不是有个huigezi的源码么.?
下面我帖上的是jingtao的代码...
<<INTENET屏幕极速传输开发文档>>目录
一:传统的屏幕传输方法与缺点
二:极速屏幕传输的方法与实现
三:程序流程图与细节
四:后记
附录:
一:压缩方法简介
二:传统的屏幕传输方法代码
三:服务端客户端公共代码列表
<<网络极速屏幕传输>>开发文档
一:传统的屏幕传输方法与缺点
传统的屏幕传输采用的是这样的方法: 抓取屏幕--à传输--à显示图像,此为完成传输一幅的过程.不断重复此过程即可实现屏幕监控.但是这种方法因为图像数据容量大,而网络实际信道容量是有限的,所以效果很不理想,具体表现就是每幅图像之间间隔时间长.后来发展到抓取屏幕-à压缩数据-à传输-à解压缩-à显示图像.这样做速度的确有所提高.但是在INTENET上面效果仍然不好.
二:极速屏幕传输的方法与实现
针对上面的情况,我们研究屏幕图像后发现,实际应用中屏幕变化的时候经常变的只是一小部分区域.有时侯(比如说浏览文本文件的时候)屏幕根本不作任何变化.而传统方法只是机械的重复传输整个屏幕的内容.如果我们每次只发送变化的区域部分,那么速度就会显著提高.
在INTENET上面的测试结果如下:客户端
湖北武汉)ISDN64KB上网局域网接入. 服务端:中山大学宽带接入的.服务端屏幕800X600X256色.屏幕变化不大的时候(比如说在用QQ在聊天),1~2秒钟可以看到一幅.如果变化大的话(比如说新开一个网页)要四秒钟甚至更长时间.
为了减少数据量,除了压缩图像外,可以先把图像转化为256色.我们使用了一个自定义函数来抓取屏幕然后转化为256色. My_GetScreenToBmp(DrawCur:Boolean;StreamName:TMemoryStream);注意函数里面的的Mybmp.PixelFormat:=pf8bit; 它的作用就是转化屏幕为256色图像.
关于如何比较:比如说我们第一副图像的数据为abcdefg,第二副图像数据为abcdefh,把数据相同的数据位标记为0,不同的记录下来.那么对比后可以得到第三副图像的数据为000000g.还原的时候,把第三副图像与第二幅图像比较,就可以得到第一幅图像数据abcdefg.
为什么比较后压缩数据会变小: .可以作个比较:一个文件全部为字符0,另外一个文件字符为不规则字符.压缩前两个文件一样大小,压缩后差别却很大.具体原理见附录.
下面是程序流程图:具体实现请参考代码.
四:后记
因为时间关系,很多地方没有做.还有需要改进的地方:
1:目前只是比较整个屏幕的变化.即使屏幕无变化的话也有几十个字节的数据量(全部为0).可以在发送前比较后作判断:如果无变化那么就发信息叫服务端重新输出原来的内容一次即可而不用重新传输一次.
2: 目前只是比较整个屏幕的变化.即使是屏幕某个小区域变化也把其它无变化的添加进去了.如果改为把屏幕切割称成为4X4块再比较的话速度更快.比如说现在屏幕只是第16块变化了一点,那么我们只要发送此块即可.
3:选择好的压缩算法.我们现在用的是LHARC压缩算法.我们知道:凡是压缩算法肯定是以牺牲CPU时间来达到目的的.LHARC算法不是最好的算法.
4:本算法只适应INTENET.因为,在局部网的话传输789KB的内容与传输536字节(不到1KB)速度是没有多大区别的.而且数据比较后还压缩.压缩就得占用时间.但是在INTENET上面,传输789KB跟传输536字节的区别是非常大的.
附录:
一:压缩方法简介
1、压缩(Encode)
??假设我们有一些数据:
a b a b a b a b c d d d a a b c d b a
怎么样才能使上面的数据变短呢?一般来说毫无规律的字符数据中经常回出现一些重复的串,象上面的“ab”“cd”,如果能将数据中重复出现的串用一个简短的代码表示出来不就做到了数据压缩了吗?但是我们并不知道到底哪些串会重复,难道要事先将所有数据扫描一遍吗?而且有这种情况,比如说当遇到“a b c d e”串时,到底是把它看成一个串还是将它分成“a b”+“c d e”或其它呢?
有时候想得太复杂不是件好事,可以把事情想得简单一些,我们完全可以在逐个读入数据的时候动态创建一个表来记录数据中重复的串,考虑到我们输出的是代表相应串的代码,假设压缩的是一字节为单位的字符串,所以在建立表时必须先把0 — 255代表的单个字符先放到表中,保证在压缩的时候一定能找到重复的串(至少跟自己本身重复嘛),然后再根据逐个读入的字符来添加我们的表项。当然记录重复串的表不能无限扩大,当大到了一定程度必须将其清空重新来过,所以要保留一个表项(256)为表清空标识,另外为了让我们在解压的时候知道什么时候解压结束,还要保留一个数据结束标识(257),下面就看看压缩的过程。首先初始化表,底49-53项的内容分别是“a”、“b”、“c”、“d”第256,257项留空,初始位置为第258项步骤:
1)每次将读入当前字符和前一次找到重复的字符串叠加生成新串(后称当前串)并在表中查找。
2)如果找到相同的串则跳到第一步继续查找以期待更长的重复串。
3)找不到重复串时将上一次匹配的重复串的相应代码输出,并将“当前串”做为新串添加到表中。
4)将“当前串”设为本次读入的字符,(不用找都知道肯定在表中),在表中找到重复串所以重复第一步。
读入的字符 上次的当前串 串叠加结果 查找重复项 输出代码 新添加表项 当前串重新赋值
a 无 a 97(a)
b a ab 无 97 258:ab 98(b)
a b ba 无 98 259:ba 97(a)
b a ab 258(ab)
a ab aba 无 258 260:aba 97(a)
b a ab 258(ab)
a ab aba 260(aba)
b aba abab 无 260 261:abab 98(b)
c b bc 无 98 262:bc 99(c)
d c cd 无 99 263:cd 100(d)
d d dd 无 100 264:dd 100(d)
d d dd 264(dd)
a dd dda 无 264 265:dda 97(a)
a a aa 无 97 266:aa 97(a)
b a ab 258(ab)
c ab abc 无 258 267:abc 99(c)
d c cd 263(cd)
b cd cdb 无 263 268
cdb) 98(b)
a b ba 259(ba)
结束 259
流结束标志
表1
上面的压缩步骤应该是很容易理解吧?不过别以为这样就可以了,仔细观察一下就知道了,输出代码部分有超过255的数据,就是说不能用一个字节来表示,那怎么办呢?其实这样的话我们要摈弃传统的思想,不要把输出流看成是以字节为单位的字符串流,而要用位(bit)来做单位,在表项小于512时每次输出的代码占用9bit,大于等于512小于1024时占10bit依此类推动态增加每次输出代码所占用的位数,如果表过长其输出代码就要占用足够多的位数,现在该知道为什么当表到了一定程度就要清空了吧,通常表项数最大为4096项。
2、解压缩(Decode)
??解压缩和压缩的过程很相似,也是动态地生成一个串表然后根据读入的代码将压缩数据还原,虽然不太好理解但是解压缩的实现过程要比压缩过程简单得多,为什么这么说?首先观察一下压缩代码生成的特征,每输出一次代码则表中必定新建了一个表项,为了让解压缩时和压缩时创建的表一致,所以我们在读入一个代码时就要在表中新建立一个表项,看看下面的解压缩过程:
注意:在做字符串合并时只合并一个字符, 即如果当前读入的代码表示的字符串是“ab”的话我们只将“a”合并到原字符串末,如果当前读入的代码表示的字符串表项还未建立,则使用原来(即上一次读入的字符串)内容。
输出数据 读入的字符 combine new table
a a
a b ab 258:ab
b 258(ab) bab 259:ba
258(ab) 260(空,用原值ab) abab 260:aba
260(aba) b ab 261:abab
b c bc 262:bc
c d cd 263:cd
d 264(空,用原值d) dd 264:dd
264(dd) a da 265:da
a 258(ab) aab 266:aa
258(ab) 263(cd) abcd 267:abc
263(cd) 259(ba) cdba 268:cdb
259(ba) END
解压缩过程
??上面的实现步骤非常简单吧,只不过有些步骤(如只合并一个字符)不太容易理解为什么要这么做?但是只从程序编写的角度来说是件轻而易举的事情。
3、程序实现
编程上面最困难的就是讨厌的位处理了,因为编译器的限制对变量的处理是以8bit的倍数为单位的,就是说要想实现任意位数代码流必须经过很多的位移、位与操作,比如说:
|--01--||--02--||--03--||--04--||--05--||--06--|
123456781234567812345678123456781234567812345678
-------------^
假设当前代码流已经输出了13bit(即接下来的输出代码将从第02个字节的第6位开始)
|--01--||--02--||--03--||--04--||--05--||--06--|
123456781234567812345678123456781234567812345678
-------------*******010011101011^
现在获得下一个输出代码为010011101011共有12bit。由最大4096可只输出代码最长为12bit,最多跨度为三个字节,如果直接跟接下来的三个字节进行位与操作显然错位了。
|--01--||--02--||--03--||--04--||--05--||--06--|
123456781234567812345678123456781234567812345678
-------------010011101011^
必须先进行位移操作再位与操作,不难计算出需要位移的位数为:
24-代码位数-(输出流位置%8)=24-12-13%8=7
表2
??解压缩时就是以上步骤的逆运算:
|--01--||--02--||--03--||--04--||--05--||--06--|
123456781234567812345678123456781234567812345678
--------*****010011101011*******
^
设当前位置是第13bit,下一个代码长度为12bit,因为代码最多可能跨字节数为3,所以先把后3个字节的内容读出存到一个长整型变量中得到*****010011101011*******然后左移当前代码位置%8=13%8=5位再向右移24-代码位数=24-12=12位即可得到010011101011。
表3
二:传统的屏幕传输方法
利用流实现网络传输屏幕图像(作者:陈经韬.此文已经发表于<<电脑商情报>>)
大家应该见过很多网管程序,这类程序其中有一个功能就是监控远程电脑的屏幕。实际上,这也是利用流操作来实现的。下面我们给出一个例子,这个例子分两个程序,一个服务端,一个是客户端。程序编译后可以直接在单机、局部网或者互联网上使用。程序中已经给出相应注释。后面我们再来作具体分析。
新建一个工程,在Internet面版上拖一个ServerSocket控件到窗口,该控件主要用于监听客户端,用来与客户端建立连接和通讯。设置好监听端口后调用方法Open或者Active:=True即开始工作。注意:跟前面的NMUDP不同,当Socket开始监听后就不能再改变它的端口,要改变的话必须先调用Close或设置Active为False,否则将会产生异常。另外,如果该端口已经打开的话,就不能再用这个端口了。所以程序运行尚未退出就不能再运行这个程序,否则也会产生异常,即弹出出错窗口。实际应用中可以通过判断程序是否已经运行,如果已经运行就退出的方法来避免出错。
当客户端有数据传入,将触发ServerSocket1ClientRead事件,我们可以在这里对接收的数据进行处理。在本程序中,主要是接收客户端发送过来的字符信息并根据事先的约定来进行相应操作。
程序全部代码如下:
unit Unit1;{服务端程序}
interface
uses
Windows, Messages, SysUtils, Classes, Graphics, Controls, Forms, Dialogs, JPEG,ExtCtrls, ScktComp;
type
TForm1 = class(TForm)
ServerSocket1: TServerSocket;
procedure ServerSocket1ClientRead(Sender: TObject;Socket: TCustomWinSocket);
procedure FormCreate(Sender: TObject);
procedure FormClose(Sender: TObject; var Action: TCloseAction);
private
procedure Cjt_GetScreen(var Mybmp: TBitmap; DrawCur: Boolean);
{自定义抓屏函数,DrawCur表示抓鼠标图像与否}
{ Private declarations }
public
{ Public declarations }
end;
var
Form1: TForm1;
MyStream: TMemorystream;{内存流对象}
implementation
{$R *.DFM}
procedure TForm1.Cjt_GetScreen(var Mybmp: TBitmap; DrawCur: Boolean);
var
Cursorx, Cursory: integer;
dc: hdc;
Mycan: Tcanvas;
R: TRect;
DrawPos: TPoint;
MyCursor: TIcon;
hld: hwnd;
Threadld: dword;
mp: tpoint;
pIconInfo: TIconInfo;
begin
Mybmp := Tbitmap.Create; {建立BMPMAP }
Mycan := TCanvas.Create; {屏幕截取}
dc := GetWindowDC(0);
try
Mycan.Handle := dc;
R := Rect(0, 0, screen.Width, screen.Height);
Mybmp.Width := R.Right;
Mybmp.Height := R.Bottom;
Mybmp.Canvas.CopyRect(R, Mycan, R);
finally
releaseDC(0, DC);
end;
Mycan.Handle := 0;
Mycan.Free;
if DrawCur then {画上鼠标图象}
begin
GetCursorPos(DrawPos);
MyCursor := TIcon.Create;
getcursorpos(mp);
hld := WindowFromPoint(mp);
Threadld := GetWindowThreadProcessId(hld, nil);
AttachThreadInput(GetCurrentThreadId, Threadld, True);
MyCursor.Handle := Getcursor();
AttachThreadInput(GetCurrentThreadId, threadld, False);
GetIconInfo(Mycursor.Handle, pIconInfo);
cursorx := DrawPos.x - round(pIconInfo.xHotspot);
cursory := DrawPos.y - round(pIconInfo.yHotspot);
Mybmp.Canvas.Draw(cursorx, cursory, MyCursor); {画上鼠标}
DeleteObject(pIconInfo.hbmColor);{GetIconInfo 使用时创建了两个bitmap对象. 需要手工释放这两个对象}
DeleteObject(pIconInfo.hbmMask);{否则,调用他后,他会创建一个bitmap,多次调用会产生多个,直至资源耗尽}
Mycursor.ReleaseHandle; {释放数组内存}
MyCursor.Free; {释放鼠标指针}
end;
end;
procedure TForm1.FormCreate(Sender: TObject);
begin
ServerSocket1.Port := 3000; {端口}
ServerSocket1.Open; {Socket开始侦听}
end;
procedure TForm1.FormClose(Sender: TObject; var Action: TCloseAction);
begin
if ServerSocket1.Active then ServerSocket1.Close; {关闭Socket}
end;
procedure TForm1.ServerSocket1ClientRead(Sender: TObject;
Socket: TCustomWinSocket);
var
S, S1: string;
MyBmp: TBitmap;
Myjpg: TJpegimage;
begin
S := Socket.ReceiveText;
if S = 'cap' then {客户端发出抓屏幕指令}
begin
try
MyStream := TMemorystream.Create;{建立内存流}
MyBmp := TBitmap.Create;
Myjpg := TJpegimage.Create;
Cjt_GetScreen(MyBmp, True); {True表示抓鼠标图像}
Myjpg.Assign(MyBmp); {将BMP图象转成JPG格式,便于在互联网上传输}
Myjpg.CompressionQuality := 10; {JPG文件压缩百分比设置,数字越大图像越清晰,但数据也越大}
Myjpg.SaveToStream(MyStream); {将JPG图象写入流中}
Myjpg.free;
MyStream.Position := 0;{注意:必须添加此句}
s1 := inttostr(MyStream.size);{流的大小}
Socket.sendtext(s1); {发送流大小}
finally
MyBmp.free;
end;
end;
if s = 'ready' then {客户端已准备好接收图象}
begin
MyStream.Position := 0;
Socket.SendStream(MyStream); {将流发送出去}
end;
end;
end.
上面是服务端,下面我们来写客户端程序。新建一个工程,添加Socket控件ClientSocket、图像显示控件Image、一个 Panel 、一个Edit、两个 Button和一个状态栏控件StatusBar1。注意:把Edit1和两个 Button放在Panel1上面。ClientSocket的属性跟ServerSocket差不多,不过多了一个Address属性,表示要连接的服务端IP地址。填上IP地址后点“连接”将与服务端程序建立连接,如果成功就可以进行通讯了。点击“抓屏”将发送字符给服务端。因为程序用到了JPEG图像单元,所以要在Uses中添加Jpeg.
全部代码如下:
unit Unit2{客户端};
interface
uses
Windows,Messages,SysUtils,Classes,Graphics,Controls,Forms,Dialogs,StdCtrls,ScktComp,ExtCtrls,Jpeg, ComCtrls;
type
TForm1 = class(TForm)
ClientSocket1: TClientSocket;
Image1: TImage;
StatusBar1: TStatusBar;
Panel1: TPanel;
Edit1: TEdit;
Button1: TButton;
Button2: TButton;
procedure Button1Click(Sender: TObject);
procedure ClientSocket1Connect(Sender: TObject;
Socket: TCustomWinSocket);
procedure Button2Click(Sender: TObject);
procedure ClientSocket1Error(Sender: TObject; Socket: TCustomWinSocket;
ErrorEvent: TErrorEvent; var ErrorCode: Integer);
procedure ClientSocket1Read(Sender: TObject; Socket: TCustomWinSocket);
procedure FormCreate(Sender: TObject);
procedure FormClose(Sender: TObject; var Action: TCloseAction);
procedure ClientSocket1Disconnect(Sender: TObject;
Socket: TCustomWinSocket);
private
{ Private declarations }
public
{ Public declarations }
end;
var
Form1: TForm1;
MySize: Longint;
MyStream: TMemorystream;{内存流对象}
implementation
{$R *.DFM}
procedure TForm1.FormCreate(Sender: TObject);
begin
{-------- 下面为设置窗口控件的外观属性 ------------- }
{注意:把Button1、Button2和Edit1放在Panel1上面}
Edit1.Text := '127.0.0.1';
Button1.Caption := '连接主机';
Button2.Caption := '抓屏幕';
Button2.Enabled := false;
Panel1.Align := alTop;
Image1.Align := alClient;
Image1.Stretch := True;
StatusBar1.Align:=alBottom;
StatusBar1.SimplePanel := True;
{----------------------------------------------- }
MyStream := TMemorystream.Create; {建立内存流对象}
MySize := 0; {初始化}
end;
procedure TForm1.Button1Click(Sender: TObject);
begin
if not ClientSocket1.Active then
begin
ClientSocket1.Address := Edit1.Text; {远程IP地址}
ClientSocket1.Port := 3000; {Socket端口}
ClientSocket1.Open; {建立连接}
end;
end;
procedure TForm1.Button2Click(Sender: TObject);
begin
Clientsocket1.Socket.SendText('cap'); {发送指令通知服务端抓取屏幕图象}
Button2.Enabled := False;
end;
procedure TForm1.ClientSocket1Connect(Sender: TObject;
Socket: TCustomWinSocket);
begin
StatusBar1.SimpleText := '与主机' + ClientSocket1.Address + '成功建立连接!';
Button2.Enabled := True;
end;
procedure TForm1.ClientSocket1Error(Sender: TObject;
Socket: TCustomWinSocket; ErrorEvent: TErrorEvent;
var ErrorCode: Integer);
begin
Errorcode := 0; {不弹出出错窗口}
StatusBar1.SimpleText := '无法与主机' + ClientSocket1.Address + '建立连接!';
end;
procedure TForm1.ClientSocket1Disconnect(Sender: TObject;
Socket: TCustomWinSocket);
begin
StatusBar1.SimpleText := '与主机' + ClientSocket1.Address + '断开连接!';
Button2.Enabled := False;
end;
procedure TForm1.ClientSocket1Read(Sender: TObject;
Socket: TCustomWinSocket);
var
MyBuffer: array[0..10000] of byte; {设置接收缓冲区}
MyReceviceLength: integer;
S: string;
MyBmp: TBitmap;
MyJpg: TJpegimage;
begin
StatusBar1.SimpleText := '正在接收数据......';
if MySize = 0 then {MySize为服务端发送的字节数,如果为0表示为尚未开始图象接收}
begin
S := Socket.ReceiveText;
MySize := Strtoint(S); {设置需接收的字节数}
Clientsocket1.Socket.SendText('ready'); {发指令通知服务端开始发送图象}
end
else
begin {以下为图象数据接收部分}
MyReceviceLength := socket.ReceiveLength; {读出包长度}
StatusBar1.SimpleText := '正在接收数据,数据大小为:' + inttostr(MySize);
Socket.ReceiveBuf(MyBuffer, MyReceviceLength); {接收数据包并读入缓冲区内}
MyStream.Write(MyBuffer, MyReceviceLength); {将数据写入流中}
if MyStream.Size >= MySize then {如果流长度大于需接收的字节数,则接收完毕}
begin
MyStream.Position := 0;
MyBmp := tbitmap.Create;
MyJpg := tjpegimage.Create;
try
MyJpg.LoadFromStream(MyStream); {将流中的数据读至JPG图像对象中}
MyBmp.Assign(MyJpg); {将JPG转为BMP}
StatusBar1.SimpleText := '正在显示图像';
Image1.Picture.Bitmap.Assign(MyBmp); {分配给image1元件 }
finally {以下为清除工作 }
MyBmp.free;
MyJpg.free;
Button2.Enabled := true;
{ Socket.SendText('cap');添加此句即可连续抓屏 }
MyStream.Clear;
MySize := 0;
end;
end;
end;
end;
procedure TForm1.FormClose(Sender: TObject; var Action: TCloseAction);
begin
MyStream.Free; {释放内存流对象}
if ClientSocket1.Active then ClientSocket1.Close; {关闭Socket连接}
end;
end.
程序原理:运行服务端开始侦听,再运行客户端,输入服务端IP地址建立连接,然后发一个字符通知服务端抓屏幕。服务端调用自定义函数Cjt_GetScreen抓取屏幕存为BMP,把BMP转换成JPG,把JPG写入内存流中,然后把流发送给客户端。客户端接收到流后做相反操作,将流转换为JPG再转换为BMP然后显示出来。
注意:因为Socket的限制,不能一次发送过大的数据,只能分几次发。所以程序中服务端抓屏转换为流后先发送流的大小,通知客户端这个流共有多大,客户端根据这个数字大小来判断是否已经接收完流,如果接收完才转换并显示。
三:服务端客户端公共代码列表:
1: Lh5Unit.pas:LHArc压缩解压缩单元文件
2: My_StreamManage.pas:抓屏幕,比较流和还原流单元
(全文完)