微服务和分布式交易

git clone https://github.com/tiian/lixa-docker.git

 cd lixa-docker/examples/PythonJavaREST

 docker build -f Dockerfile-client -t rest-client .

 docker build -f Dockerfile-server -t rest-server .
检查生成的图像，你应该看到类似以下内容的图像：
 docker images | grep rest

 rest-server          latest              81eda2af0fd4        25 hours ago        731MB

 rest-client          latest              322a3a26e040        25 hours ago        390MB
启动MySQL，PostgreSQL和LIXA状态服务器（lixad）：
 docker run --rm -e MYSQL_ROOT_PASSWORD=mysecretpw -p 3306:3306 -d lixa/mysql

 docker run --rm -e POSTGRES_PASSWORD=lixa -p 5432:5432 -d lixa/postgres -c 'max_prepared_transactions=10'

 docker run --rm -p 2345:2345 -d lixa/lixad
检查启动的容器，你应该看到类似以下内容的内容：
 docker ps | grep lixa

 16099992bd82        lixa/lixad          "/home/lixa/lixad-en…"   6 seconds ago       Up 3 seconds        0.0.0.0:2345->2345/tcp              sharp_yalow

 15297ed6ebb1        lixa/postgres       "docker-entrypoint.s…"   13 seconds ago      Up 9 seconds        0.0.0.0:5432->5432/tcp              unruffled_brahmagupta

 3275a2738237        lixa/mysql          "docker-entrypoint.s…"   21 seconds ago      Up 18 seconds       0.0.0.0:3306->3306/tcp, 33060/tcp   sharp_wilson

1 docker run -ti --rm -e MAVEN_OPTS="-Djava.library.path=/opt/lixa/lib" -e LIXA_STATE_SERVERS="tcp://192.168.123.35:2345/default" -e PQSERVER="192.168.123.35" -p 18080:8080 rest-server

 Mar 24, 2019 9:21:45 PM org.glassfish.grizzly.http.server.NetworkListener start
 
  INFO: Started listener bound to [0.0.0.0:8080]
 
  Mar 24, 2019 9:21:45 PM org.glassfish.grizzly.http.server.HttpServer start
 
  INFO: [HttpServer] Started.
 
  Jersey app started with WADL available at http://0.0.0.0:8080/xta/application.wadl

 Hit enter to stop it...

 docker run -ti --rm -e SERVER="192.168.123.35" -e LIXA_STATE_SERVERS="tcp://192.168.123.35:2345/default" rest-client

 ***** REST service called: xid='1279875137.c5b6d8bf7d584065b4ee29d62fe35ab5.ac3d62eb862b49fe6a50bfee46d142b9', oper='delete' *****
 
  2019-03-24 21:23:04.047857 [1/139693866854144] INFO: LXC000I this process is starting a new LIXA transaction manager (lixa package version is 1.7.6)
 
  Created a subordinate branch with XID '1279875137.c5b6d8bf7d584065b4ee29d62fe35ab5.ac3d62eb862b49fe9de52bd41657494a'
 
  PostgreSQL: executing SQL statement >DELETE FROM authors WHERE id=1804<
 
  Executing first phase of commit (prepare)

 Returning 'PREPARED' to the client

 Executing second phase of commit

 ***** REST service called: xid='1279875137.91f1712af1164dd38dcc0b14d58819d2.ac3d62eb862b49fe6a50bfee46d142b9', oper='insert' *****

 Created a subordinate branch with XID '1279875137.91f1712af1164dd38dcc0b14d58819d2.ac3d62eb862b49fe20cca6a7fc7c4802'

 PostgreSQL: executing SQL statement >INSERT INTO authors VALUES(1804, 'Hawthorne', 'Nathaniel')<

 Executing first phase of commit (prepare)

 Returning 'PREPARED' to the client

 Executing second phase of commit
还有Python客户端控制台中的其他消息：
  2019-03-24 21:23:03.909808 [1/140397122036736] INFO: LXC000I this process is starting a new LIXA transaction manager (lixa package version is 1.7.6)
 
  ***** REST client *****
 
  MySQL: executing SQL statement >DELETE FROM authors WHERE id=1840<
 
  Calling REST service passing: xid='1279875137.c5b6d8bf7d584065b4ee29d62fe35ab5.ac3d62eb862b49fe6a50bfee46d142b9', oper='delete'

  Server replied >PREPARED<

 Executing transaction commit

 ***** REST client *****

 MySQL: executing SQL statement >INSERT INTO authors VALUES(1840, 'Zola', 'Emile')<

 Calling REST service passing: xid='1279875137.91f1712af1164dd38dcc0b14d58819d2.ac3d62eb862b49fe6a50bfee46d142b9', oper='insert'

 Server replied >PREPARED<

 Executing transaction commit

 # initialize XTA environment
 
  Xta_init()
 
  # create a new MySQL connection
 
  # Note: using MySQLdb functions
 
  rm = MySQLdb.connect(host=hostname, user="lixa", password="passw0rd", db="lixa")

 # create a new XTA Transaction Manager object

 tm = TransactionManager()

 # create an XA resource for MySQL

 # second parameter "MySQL" is descriptive

 # third parameter "localhost,0,lixa,,lixa" identifies the specific database

 xar = MysqlXaResource(rm._get_native_connection(), "MySQL",

       hostname + "/lixa")

 # Create a new XA global transaction and retrieve a reference from

 # the TransactionManager object

 tx = tm.createTransaction()

 # Enlist MySQL resource to transaction

 tx.enlistResource(xar)

 sys.stdout.write("***** REST client *****\n")

 # Start a new XA global transaction with multiple branches

 tx.start(True)

 # Execute DELETE statement

 sys.stdout.write("MySQL: executing SQL statement >" + delete_stmt + "<\n")

 cur = rm.cursor()

 cur.execute(delete_stmt)

 # Retrieving xid

 xid = tx.getXid().toString()

 # Calling server passing xid

 sys.stdout.write("Calling REST service passing: xid='" + xid + "', oper='delete'\n")

 r = requests.post("http://" + hostname + ":18080/xta/myresource",

      data={'xid':xid, 'oper':'delete'})

 sys.stdout.write("Server replied >" + r.text + "<\n")

 # Commit the transaction

 sys.stdout.write("Executing transaction commit\n")

 tx.commit()

 // 1. create an XA Data Source
  
   xads = new PGXADataSource();
  
  // 2. set connection parameters (one property at a time)
  
   xads.setServerName(System.getenv("PQSERVER"));
  
   xads.setDatabaseName("lixa");
 
  xads.setUser("lixa");
 
  xads.setPassword("passw0rd");
 
  // 3. get an XA Connection from the XA Data Source
 
  xac = xads.getXAConnection();
 
  // 4. get an XA Resource from the XA Connection
 
  xar = xac.getXAResource();
 
  // 5. get an SQL Connection from the XA Connection
 
  conn = xac.getConnection();
 
 //
 
  // XTA code
 
  //
 
  // Create a mew XTA Transaction Manager
 
  tm = new TransactionManager();
 
  // Create a new XA global transaction using the Transaction
 
  // Manager as a factory
 
  tx = tm.createTransaction();
 
  // Enlist PostgreSQL resource to transaction
 
  tx.enlistResource(xar, "PostgreSQL",
 
  System.getenv("PQSERVER") + ";u=lixa;db=lixa");
 
  // create a new branch in the same global transaction
 
 tx.branch(xid);
 
  System.out.println("Created a subordinate branch " +
 
  "with XID '" + tx.getXid().toString() + "'");
 
  //
 
  // Create and Execute a JDBC statement for PostgreSQL
 
  //
 
  System.out.println("PostgreSQL: executing SQL statement >" +
 
  sqlStatement + "<");
 
 // create a Statement object
 
  stmt = conn.createStatement();
 
  // Execute the statement
 
  stmt.executeUpdate(sqlStatement);
 
  // close the statement
 
  stmt.close();
 
  // perform first phase of commit (PREPARE ONLY)
 
  System.out.println("Executing first phase of commit (prepare)");
 
  tx.commit(true);
 
  // start a backgroud thread: control must be returned to the client
 
  // but finalization must go on in parallel
 
  new Thread(new Runnable() {
 
  @Override
 
  public void run() {
 
  try {
 
      // perform second phase of commit
 
      System.out.println("Executing second phase of commit");

     tx.commit(false);

     // Close Statement, SQL Connection and XA

     // Connection for PostgreSQL

     stmt.close();
     
     conn.close();

    xac.close();

 } catch  (XtaException e) {

     System.err.println("XtaException: LIXA ReturnCode=" +

 e.getReturnCode() + " ('" +

 e.getMessage() + "')");

 e.printStackTrace();

 } catch (Exception e) {

 e.printStackTrace();

 }

 }

 }).start();

 System.out.println("Returning 'PREPARED' to the client");

 return "PREPARED";