分类:
2008-10-17 13:22:43
显然,多进程技术是用来提高应用的并发性,进而提高整个系统的执行效率,那么如何在PL/SQL中实现多进程的通信呢?其实,PL/SQL其设计的初衷主要是增强SQL语句的功能,而没有考虑到其他编程语言的高级功能,所以在PL/SQL中实现多进程通信只能借助于提供的两个开发包:DBMS_PIPE和DBMS_ALERT。
1.DBMS_PIPE
该包提供多进程之间管道通信的方法,比如连接到同一个数据库的两个独立会话之间可以通过管道进行通信,另外也可以在过程和Pro*C之间进行通信,这样就大大地增强了PL/SQL的处理能力。该包主要提供两对函数:
pack_message(v_msg varchar2)-----将v_msg信息打包放入到缓冲器中,准备发送;
send_message(v_pipename varchar2)-----发送名为v_pipename的管道的缓冲器;
unpack_message(v_msg varchar2)-----将信息解析到v_msg中;
receive_message(v_pipename varchar2)----接受名为v_pipename的管道的缓冲器;
其执行的原理是:首先建立有名管道(这点熟悉unix很清楚),管道的发送端和接受端都有相应的缓冲器进行接受和发送处理,要注意的是,文本信息必须打包来发送,通过解析来读取信息。
为了理解前面的描述,下面列举一个两个会话之间通信的实例。
发送进程:
declare
v_pipename varchar2(30):='pipe1';
v_status integer;
begin
dbms_pipe.pack_message(' hello,this is sending process!');
v_status:=dbms_pipe.send_message(v_pipename);
if v_status !=0 then
dbms_output.put_line('error!');
end if;
end;
/
接受进程:
declare v_pipename varchar2(30):='pipe1'; v_status integer; v_msg varchar2(20); begin v_status:=dbms_pipe.receive_message(v_pipename); if v_status !=0 then dbms_output.put_line('error'); end if; dbms_pipe.unpack_message(v_msg); dbms_output.put_line(v_msg); end; / |
[1]