专注收集记录技术开发学习笔记、技术难点、解决方案
网站信息搜索 >> 请输入关键词:
您当前的位置: 首页 > Erlang

解决erlang和java同时操作一张表,造成锁表有关问题

发布时间:2011-06-29 17:49:00 文章来源:www.iduyao.cn 采编人员:星星草
解决erlang和java同时操作一张表,造成锁表问题

作者:张昌昌

1、问题描述

     Erlang端通过odbc去写oracle一张表,同时java通过jdbc驱动也去写这张表,当同时多次发生这种写操作时,这个表就被锁。

2、问题解决

     思路:利用适配器原理,适配erlang和java的数据库连接,让erlang端对数据表的操作与java端对该数据表的操作,分时序顺序进行,其中一端在进行写操作时上锁

                  另一端就不能操作,直到他操作完成释放锁,另一端才能操作。

                  该适配器采用java编写,通过otp.jar让erlang与java进行通信,erlang和java对数据表操作的连接都要从该适配器入

    实现方式:

   (1)java端

public class ConnectionAdaptor {
   private static final ConnectionAdaptor instance = new ConnectionAdaptor("javaNode","theMailbox","secret");
   private OtpNode node;
   private static OtpMbox mbox;
   private ReentrantLock lock = new ReentrantLock();
   public static ConnectionAdaptor getInstance(){
  return instance;
   }
   private ConnectionAdaptor(String nodeName,String mboxName,String cookie){
  super();
  try{
  node=new OtpNode(nodeName,cookie);
  }catch(IOException e){
  e.printStackTrace();
  }
  System.out.print(node);
  mbox = node.createMbox(mboxName);
   }
   
   private void process(){
  while(true){
  try{
  OtpErlangObject msg = mbox.receive();
  OtpErlangTuple t = (OtpErlangTuple)msg;
  OtpErlangPid from = (OtpErlangPid)t.elementAt(0);
      String name = ((OtpErlangString)t.elementAt(1)).stringValue();
      if(name.equals("write_start"))
      adaptor(1);
  }catch(Exception e){
}
  }
   }
   public static void main(String[] args){
  
  //启动一个线程用于erlang消息的侦听
  new Thread(){
  public void run(){
  ConnectionAdaptor.getInstance().process();
  }
  }.start();
  //启动一个线程进行java端的数据表操作
  new Thread(){
  public void run()
  {
  for(int i=0;i<10;i++)
  {
  try{
  try{
  ConnectionAdaptor.getInstance().adaptor(2);
  }catch(Exception e){
  e.printStackTrace();
  }
  }catch(Exception e)
  {
  e.printStackTrace();
  }
  }
  }
  }.start();
   }
   
   public void adaptor(int type){
  lock.lock();
  if (type == 1)
  {
  while(true)
  {
  OtpErlangObject msg = mbox.receive();
  OtpErlangTuple t = (OtpErlangTuple)msg;
  OtpErlangPid from = ((OtpErlangString)t.elementAt(1)).stringValue();
  if(name.equals("write_end"))
  {
  System.out.println("erlang write table end");
  lock.unlock();
  }
  }
  }
  else
  {
  Thread.sleep(5000);
  System.out.println("java write table end");
  lock.unlock();
  }
   }
}

erlang端:

   -module(erl_to_java).
-export([write_table/0,start/1]).
write_table() ->
   {theMailbox,javaNode@zcc}!{self(),"write_start"},
   timer:sleep(5000),
   {theMailbox,javaNode@zcc}!{self(),"write_end"}.
   
start(N) ->
   case N =:= 0 of
      true -> ok;
      false -> write_table(),start(N-1)
   end.

3、时序图

      

4、问题总结

        (1)java单例模式

        (2)java与erlang通信

        (3)java线程间锁机制

           首先利用单例模式获取一个适配器对象,然后启动一个线程执行process(),侦听来自erlang端的写表消息,一旦有erlang发出写表请求,需加锁,在erlang进程中执行

写表操作后,向java进程发送写表结束请求,然后java进程释放锁,一旦有java端写表操作,便获取锁进行写表操作,之后释放锁,在java写表期间,erlang的写表操作必须等待,直到锁释放,反之亦然。

5、使用方法

        (1)运行该适配器的java端需要安装erl的运行环境,需要导入OtpErlang.jar包;

        (2)erlang端节点启动时,要和适配器单例创建时的cookie保持一致,同时

          erl -sname erlangNode -setcookie secret -pa "erl_to_java.bin所在的路径" -eval "net_adm:ping(javaNode@zcc)"

友情提示:
信息收集于互联网,如果您发现错误或造成侵权,请及时通知本站更正或删除,具体联系方式见页面底部联系我们,谢谢。

其他相似内容:

热门推荐: