Статьи

Весенние JTA-транзакции с несколькими ресурсами в Tomcat на примере Atomikos

Январь 29, 2019

В этом руководстве мы покажем вам, как реализовать транзакции с несколькими ресурсами JTA на сервере Tomcat , используя Atomikos Transaction Manager . Диспетчер транзакций Atomicos обеспечивает поддержку распределенных транзакций. Это многоэтапные транзакции, часто использующие несколько баз данных, которые должны фиксироваться согласованным образом. Распределенные транзакции описываются XA standard . XA определяет, как менеджер транзакций (например, Atomikos) может сообщать базе данных, какая работа выполняется в рамках какой-либо транзакции, и как проводить протокол двухфазной фиксации (2PC) в конце каждой транзакции.

Здесь мы создадим простые классы Entity, сопоставленные с двумя разными базами данных, и попытаемся сохранить объекты этих классов в базах данных, используя одну распределенную транзакцию. Мы также увидим, что произойдет, когда одна из основных транзакций отката.

Нашей предпочтительной средой разработки является Eclipse . Мы используем версию Eclipse Juno (4.2) вместе с плагином Maven Integration версии 3.1.0. Вы можете скачать Eclipse отсюда и Maven Plugin для Eclipse отсюда . Установка плагина Maven для Eclipse выходит за рамки данного руководства и не будет обсуждаться. Мы также используем Spring версии 3.2.3 и JDK 7_u_21.

Tomcat 7 — это используемый сервер приложений. Версия Hibernate — 4.1.9, а база данных, используемая в примере — MySQL Database Server 5.6.

Давайте начнем,

1. Создайте новый проект Maven

Перейдите в Файл -> Проект -> Maven -> Проект Maven.

New-Maven-проект

На странице мастера «Выберите имя проекта и местоположение» убедитесь, что опция «Создать простой проект (пропустить выбор архетипа») не отмечена , нажмите «Далее», чтобы продолжить со значениями по умолчанию.

новый проект

Здесь должен быть добавлен архетип maven для создания веб-приложения. Нажмите «Добавить архетип» и добавьте архетип. Установите переменную «Archetype Group Id» на "org.apache.maven.archetypes" , переменную «Archetype ardact Id» на "maven-archetype-webapp" и «Archetype Version» на "1.0" . Нажмите «ОК», чтобы продолжить.

Maven-архетип-WebApp

На странице мастера «Введите идентификатор артефакта» вы можете определить имя и основной пакет вашего проекта. Задайте для переменной «Group Id» значение "com.javacodegeeks.snippets.enterprise" а для переменной «Artifact Id» — значение "springexample" . Вышеупомянутые варианты выбора составляют основной пакет проекта как "com.javacodegeeks.snippets.enterprise.springexample" а имя проекта — "springexample" . Установите для переменной «Package» значение "war" , чтобы создать файл war для развертывания на сервере tomcat. Нажмите «Готово», чтобы выйти из мастера и создать свой проект.

война

Структура проекта Maven показана ниже:

Веб-проект-исследователь

    Он состоит из следующих папок:

  • Папка / src / main / java, которая содержит исходные файлы для динамического содержимого приложения,
  • Папка / src / test / java содержит все исходные файлы для модульных тестов,
  • Папка / src / main / resources содержит файлы конфигурации,
  • Папка / target содержит скомпилированные и упакованные результаты,
  • Папка / src / main / resources / webapp / WEB-INF содержит дескрипторы развертывания для веб-приложения,
  • pom.xml — это файл объектной модели проекта (POM). Единственный файл, который содержит все связанные с проектом конфигурации.

2. Добавьте зависимость Spring 3.2.3

  • Найдите раздел «Свойства» на странице «Обзор» редактора POM и внесите следующие изменения:
    Создайте новое свойство с именем org.springframework.version и значением 3.2.3.RELEASE .
  • Перейдите на страницу «Зависимости» редактора POM и создайте следующие зависимости (вы должны заполнить поля «GroupId», «Artifact Id» и «Version» раздела «Сведения о зависимостях» на этой странице):
    Идентификатор группы: org.springframework Идентификатор артефакта: spring-web Версия: $ {org.springframework.version}

В качестве альтернативы вы можете добавить зависимости Spring в файл Maven pom.xml , непосредственно отредактировав его на странице «Pom.xml» редактора POM, как показано ниже:

pom.xml:

01
02
03
04
05
06
07
08
09
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
<project xmlns="http://maven.apache.org/POM/4.0.0"; xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <groupId>com.javacodegeeks.snippets.enterprise</groupId>
    <artifactId>springexample</artifactId>
    <version>0.0.1-SNAPSHOT</version>
 
    <dependencies>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-core</artifactId>
            <version>${spring.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-context</artifactId>
            <version>${spring.version}</version>
        </dependency>
    </dependencies>
 
    <properties>
        <spring.version>3.2.3.RELEASE</spring.version>
    </properties>
</project>

Как видите, Maven декларативно управляет библиотечными зависимостями. Создается локальный репозиторий (по умолчанию в папке {user_home} /. M2), и все необходимые библиотеки загружаются и помещаются туда из общедоступных репозиториев. Кроме того, внутрибиблиотечные зависимости автоматически разрешаются и обрабатываются.

3. Добавьте все необходимые зависимости

Все зависимости, необходимые для настройки менеджера транзакций atomicos, устанавливаются здесь.
pom.xml

001
002
003
004
005
006
007
008
009
010
011
012
013
014
015
016
017
018
019
020
021
022
023
024
025
026
027
028
029
030
031
032
033
034
035
036
037
038
039
040
041
042
043
044
045
046
047
048
049
050
051
052
053
054
055
056
057
058
059
060
061
062
063
064
065
066
067
068
069
070
071
072
073
074
075
076
077
078
079
080
081
082
083
084
085
086
087
088
089
090
091
092
093
094
095
096
097
098
099
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
  <modelVersion>4.0.0</modelVersion>
  <groupId>com.javacodegeeks.snippets.enterprise</groupId>
  <artifactId>springexample</artifactId>
  <packaging>war</packaging>
  <version>0.0.1</version>
  <name>springexample Maven Webapp</name>
  <url>http://maven.apache.org</url>
    <build>
    <finalName>springexample</finalName>
  </build>
  <dependencies>
  <dependency>
    <groupId>org.springframework</groupId>
    <artifactId>spring-core</artifactId>
    <version>${spring.version}</version>
  </dependency>
 
  <dependency>
    <groupId>org.springframework</groupId>
    <artifactId>spring-context</artifactId>
    <version>${spring.version}</version>
  </dependency>
 
  <dependency>
    <groupId>org.springframework</groupId>
    <artifactId>spring-tx</artifactId>
    <version>${spring.version}</version>
  </dependency>
 
  <dependency>
    <groupId>org.springframework</groupId>
    <artifactId>spring-orm</artifactId>
    <version>${spring.version}</version>
  </dependency>
 
  <dependency>
    <groupId>org.springframework</groupId>
    <artifactId>spring-web</artifactId>
    <version>${spring.version}</version>
  </dependency>
 
  <dependency>
    <groupId>org.springframework</groupId>
    <artifactId>spring-webmvc</artifactId>
    <version>${spring.version}</version>
  </dependency>
 
  <dependency>
    <groupId>org.hibernate</groupId>
    <artifactId>hibernate-entitymanager</artifactId>
    <version>${hibernate.version}</version>
    <exclusions>
      <exclusion>
        <groupId>cglib</groupId>
        <artifactId>cglib</artifactId>
      </exclusion>
      <exclusion>
        <groupId>dom4j</groupId>
        <artifactId>dom4j</artifactId>
      </exclusion>
    </exclusions>
  </dependency>
 
  <dependency>
    <groupId>javax.servlet</groupId>
    <artifactId>javax.servlet-api</artifactId>
    <version>3.0.1</version>
    <scope>provided</scope>
  </dependency>
 
  <dependency>
    <groupId>com.atomikos</groupId>
    <artifactId>transactions-jta</artifactId>
    <version>${atomikos.version}</version>
  </dependency>
 
  <dependency>
    <groupId>com.atomikos</groupId>
    <artifactId>transactions-jdbc</artifactId>
    <version>${atomikos.version}</version>
  </dependency>
 
  <dependency>
    <groupId>com.atomikos</groupId>
    <artifactId>transactions-hibernate3</artifactId>
    <version>${atomikos.version}</version>
    <exclusions>
      <exclusion>
        <artifactId>hibernate</artifactId>
        <groupId>org.hibernate</groupId>
      </exclusion>
    </exclusions>
  </dependency>
 
  <dependency>
    <groupId>dom4j</groupId>
    <artifactId>dom4j</artifactId>
    <version>1.6.1</version>
  </dependency>
 
  <dependency>
    <groupId>mysql</groupId>
    <artifactId>mysql-connector-java</artifactId>
    <version>5.1.25</version>
  </dependency>
  </dependencies>
 
<properties>
  <spring.version>3.2.3.RELEASE</spring.version>
  <hibernate.version>4.1.9.Final</hibernate.version>
  <atomikos.version>3.8.0</atomikos.version>
</properties>
   
</project>

4. Создайте классы сущностей

EmployeeA.java и EmployeeB.java являются классами сущностей. Они используют аннотации javax.persistence для отображения в таблицу, EMPLOYEEA и EMPLOYEEB в разных базах данных. В частности, аннотация @Entity указывает, что каждый класс является сущностью. Аннотация @Table определяет первичную таблицу для аннотированного объекта. Аннотация @Column используется для указания сопоставленного столбца для постоянного поля, тогда как аннотация @Id определяет поле первичного ключа каждого объекта.

EmployeeA.java

01
02
03
04
05
06
07
08
09
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
package com.javacodegeeks.snippets.enterprise.model;
 
import javax.persistence.Column;
import javax.persistence.Entity;
import javax.persistence.Id;
import javax.persistence.Table;
 
@Entity
@Table(name = "EMPLOYEEA")
public class EmployeeA {
 
    @Id
    @Column(name = "ID", nullable = false)
    private String id;
 
    @Column(name = "NAME", nullable = false)
    private String name;
 
    @Column(name = "AGE", nullable = false)
    private long age;
     
    public EmployeeA() {
    }
 
    public String getId() {
        return id;
    }
 
    public void setId(String id) {
        this.id = id;
    }
 
    public String getName() {
        return name;
    }
 
    public void setName(String name) {
        this.name = name;
    }
 
    public long getAge() {
        return age;
    }
 
    public void setAge(long age) {
        this.age = age;
    }
 
}

EmployeeB.java

01
02
03
04
05
06
07
08
09
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
package com.javacodegeeks.snippets.enterprise.model;
 
import javax.persistence.Column;
import javax.persistence.Entity;
import javax.persistence.Id;
import javax.persistence.Table;
 
@Entity
@Table(name = "EMPLOYEEB")
public class EmployeeB {
 
    @Id
    @Column(name = "ID", nullable = false)
    private String id;
 
    @Column(name = "NAME", nullable = false)
    private String name;
 
    @Column(name = "AGE", nullable = false)
    private long age;
     
    public EmployeeB() {
    }
 
    public String getId() {
        return id;
    }
 
    public void setId(String id) {
        this.id = id;
    }
 
    public String getName() {
        return name;
    }
 
    public void setName(String name) {
        this.name = name;
    }
 
    public long getAge() {
        return age;
    }
 
    public void setAge(long age) {
        this.age = age;
    }
 
}

5. Создайте классы DAO

Реализованными объектами доступа к данным являются классы EmployeeADAOImpl.java и EmployeeBDAOImpl.java . Они @Service аннотацией @Service , которая @Service , что они являются компонентами Spring Beans, и, следовательно, позволяет Spring автоматически их обнаруживать. Они оба используют javax.persistence.EntityManager для взаимодействия с базами данных.

Экземпляр EntityManager связан с контекстом постоянства. Постоянный контекст — это набор экземпляров объекта, в котором для любого постоянного идентификатора объекта существует уникальный экземпляр объекта. В контексте постоянства экземпляры сущности и их жизненный цикл управляются. EntityManager API используется для создания и удаления постоянных экземпляров сущностей, для поиска сущностей по их первичному ключу и для запросов к сущностям. EntityManager настраивается в файле persistence.xml , который описан
в пункте 8.1.
Набор сущностей, которыми может управлять данный экземпляр EntityManager, определяется единицей постоянства. Модуль персистентности определяет набор всех классов, которые связаны или группируются приложением, и которые должны быть размещены в их сопоставлении с одной базой данных.

EntityManager внедряется в каждом DAO с @PersistenceContext аннотации @PersistenceContext , в которой @PersistenceContext имя каждого модуля персистентности, как определено в файле persistence.xml .
Базовый метод persist реализован в обоих DAO с использованием API-метода EntityManager persist(Object entity) из EntityManager для создания объекта в базе данных.

DAO и их интерфейсы показаны ниже:

EmployeeADAO.java

1
2
3
4
5
6
7
8
package com.javacodegeeks.snippets.enterprise.dao;
 
import com.javacodegeeks.snippets.enterprise.model.EmployeeA;
 
public interface EmployeeADAO {
     
          void persistEmployee(EmployeeA employee);      
}

EmployeeADAO Impl.java

01
02
03
04
05
06
07
08
09
10
11
12
13
14
15
16
17
18
19
20
package com.javacodegeeks.snippets.enterprise.dao;
 
import javax.persistence.EntityManager;
import javax.persistence.PersistenceContext;
 
import org.springframework.stereotype.Service;
 
import com.javacodegeeks.snippets.enterprise.model.EmployeeA;
 
@Service
public class EmployeeADAOImpl implements EmployeeADAO {
 
    @PersistenceContext(unitName="PersistenceUnitA")
    private EntityManager entityManager;
 
    public void persistEmployee(EmployeeA employee) {
        entityManager.persist(employee);
    }
 
}

СотрудникBDAO .java

1
2
3
4
5
6
7
8
9
package com.javacodegeeks.snippets.enterprise.dao;
 
import com.javacodegeeks.snippets.enterprise.model.EmployeeB;
 
public interface EmployeeBDAO {
     
          void persistEmployee(EmployeeB employee) throws Exception;
           
}

EmployeeBDAO Impl.java

01
02
03
04
05
06
07
08
09
10
11
12
13
14
15
16
17
18
19
20
21
package com.javacodegeeks.snippets.enterprise.dao;
 
 
import javax.persistence.EntityManager;
import javax.persistence.PersistenceContext;
 
import org.springframework.stereotype.Service;
 
import com.javacodegeeks.snippets.enterprise.model.EmployeeB;
 
@Service
public class EmployeeBDAOImpl implements EmployeeBDAO {
 
    @PersistenceContext(unitName="PersistenceUnitB")
    private EntityManager entityManager;
 
    public void persistEmployee(EmployeeB employee) throws Exception {
        entityManager.persist(employee);
//      throw new Exception();
    }
}

6. Создайте класс обслуживания

Классы EmployeeADAOImpl.java и EmployeeBDAOImpl.java внедряются в класс EmployeeServiceImpl.java . Таким образом, в persistEmployees(EmployeeA employeeA, EmployeeB employeeB) реализованном здесь, методы DAO вызываются для выполнения базового взаимодействия с базой данных. Класс EmployeeServiceImpl.java также @Service аннотацией @Service , которая @Service , что это Spring Bean, и, следовательно, позволяет Spring автоматически его обнаруживать.

Аннотация @Transactional помещается перед методом, чтобы обозначить, что транзакция создается при вызове метода. Транзакция является глобальной транзакцией, управляемой контейнером, и будет настроена в файле конфигурации Spring.
EmployeeService.java

01
02
03
04
05
06
07
08
09
10
package com.javacodegeeks.snippets.enterprise.service;
 
import com.javacodegeeks.snippets.enterprise.model.EmployeeA;
import com.javacodegeeks.snippets.enterprise.model.EmployeeB;
 
public interface EmployeeService {
 
    void persistEmployees(EmployeeA employeeA, EmployeeB employeeB) throws Exception;
     
}

EmployeeServiceImpl.java

01
02
03
04
05
06
07
08
09
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
package com.javacodegeeks.snippets.enterprise.service;
 
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
 
import com.javacodegeeks.snippets.enterprise.dao.EmployeeADAO;
import com.javacodegeeks.snippets.enterprise.dao.EmployeeBDAO;
import com.javacodegeeks.snippets.enterprise.model.EmployeeA;
import com.javacodegeeks.snippets.enterprise.model.EmployeeB;
 
@Service("employeeService")
public class EmployeeServiceImpl implements EmployeeService{
 
    @Autowired
    EmployeeADAO employeeADAO;
     
    @Autowired
    EmployeeBDAO employeeBDAO;
     
    @Transactional(rollbackFor=Exception.class)
    public void persistEmployees(EmployeeA employeeA, EmployeeB employeeB) throws Exception {
        System.out.println("Persist A");
        employeeADAO.persistEmployee(employeeA);
        System.out.println("Persist A OK - persist B");
        employeeBDAO.persistEmployee(employeeB);
        System.out.println("Persist B okk");
    }
 
}

7. Создайте сервлет для запуска приложения

Класс AppServlet.java — это простой сервлет, который реализует org.springframework.web.HttpRequestHandler и переопределяет его handleRequest(HttpServletRequest req, HttpServletResponse resp) . Служба EmployeeService вводится здесь через аннотацию @Autowire . Он используется в handleRequest(HttpServletRequest req, HttpServletResponse resp) API handleRequest(HttpServletRequest req, HttpServletResponse resp) для сохранения нового EmployeeA и нового объекта EmployeeB . Метод также возвращает сообщение об успехе, если метод возвращает успешно, и сообщение об откате, если метод выдает исключение.

AppServlet.java

01
02
03
04
05
06
07
08
09
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
package com.javacodegeeks.snippets.enterprise.servlet;
 
import java.io.IOException;
import java.io.PrintWriter;
 
import javax.servlet.ServletException;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
 
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import org.springframework.web.HttpRequestHandler;
 
import com.javacodegeeks.snippets.enterprise.model.EmployeeA;
import com.javacodegeeks.snippets.enterprise.model.EmployeeB;
import com.javacodegeeks.snippets.enterprise.service.EmployeeService;
 
@Component("appServlet")
public class AppServlet implements HttpRequestHandler {
 
    @Autowired
    private EmployeeService employeeService;
 
    public void handleRequest(HttpServletRequest req, HttpServletResponse resp)
            throws ServletException, IOException {
        EmployeeA em1 = new EmployeeA();
        em1.setId("123");
        em1.setName("John");
        em1.setAge(35);
        EmployeeB em2 = new EmployeeB();
        em2.setId("123");
        em2.setName("Mary");
        em2.setAge(31);
 
        try {
            employeeService.persistEmployees(em1, em2);
             resp.setContentType("text/html");
                PrintWriter out = resp.getWriter();
                out.println("<html>");
                out.println("<head>");
                out.println("<title>Hello World!</title>");
                out.println("</head>");
                out.println("<body>");
                out.println("<h1>Java Code Geeks </h1>");
                out.println("<h2>Both employees are inserted!</h2>");
                out.println("</body>");
                out.println("</html>");
        } catch (Exception e) {
             resp.setContentType("text/html");
                PrintWriter out = resp.getWriter();
                out.println("<html>");
                out.println("<head>");
                out.println("<title>Hello World!</title>");
                out.println("</head>");
                out.println("<body>");
                out.println("<h1>Java Code Geeks </h1>");
                out.println("<h2>Transaction Rollback!</h2>");
                out.println("</body>");
                out.println("</html>");
            e.printStackTrace();
        }
    }
}

8. Настройте приложение

8.1. Настройка постоянных единиц

Как упоминалось выше, entityManager и связанный с ним модуль персистентности для каждой базы данных настраиваются в файле persistence.xml . Здесь мы определяем две единицы постоянства. В каждом элементе persistence-unit мы определяем класс сущности, связанный с единицей постоянства. Свойство hibernate.transaction.manager_lookup_class имеет значение com.atomikos.icatch.jta.hibernate3.TransactionManagerLookup . Свойство hibernate.transaction.factory_class имеет значение org.hibernate.transaction.CMTTransactionFactory .
persistence.xml

01
02
03
04
05
06
07
08
09
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
<?xml version="1.0" encoding="UTF-8"?>
<persistence version="2.0"
  xmlns="http://java.sun.com/xml/ns/persistence"
  xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  xsi:schemaLocation="http://java.sun.com/xml/ns/persistence
  http://java.sun.com/xml/ns/persistence/persistence_2_0.xsd">
 
 <persistence-unit name="PersistenceUnitA" transaction-type="JTA">
  <class>com.javacodegeeks.snippets.enterprise.model.EmployeeA</class>
  <properties>
   <property name="hibernate.transaction.manager_lookup_class"
   value="com.atomikos.icatch.jta.hibernate3.TransactionManagerLookup" />
   <property name="hibernate.transaction.factory_class"
   value="org.hibernate.transaction.CMTTransactionFactory" />
  </properties>
 </persistence-unit>
   
 <persistence-unit name="PersistenceUnitB" transaction-type="JTA">
  <class>com.javacodegeeks.snippets.enterprise.model.EmployeeB</class>
  <properties>
   <property name="hibernate.transaction.manager_lookup_class"
   value="com.atomikos.icatch.jta.hibernate3.TransactionManagerLookup" />
   <property name="hibernate.transaction.factory_class"
   value="org.hibernate.transaction.CMTTransactionFactory" />
  </properties>
 </persistence-unit>
   
</persistence>

8.2 Настройка контейнера Spring

Файл applicationContext.xml является файлом конфигурации Spring.

Элемент <context:component-scan/> используется для установки пакета, который содержит все классы, которые контейнер должен сканировать для обнаружения bean-компонентов Spring.
Элемент <tx:annotation-driven/> также используется для того, чтобы Spring был осведомлен о @ Transactional и мог обнаруживать аннотации @Transactional для настройки соответствующих bean-компонентов с транзакционным поведением.
Элемент <jta-transaction-manager/> используется для обнаружения основного сервера и выбора менеджера транзакций, доступного для платформы.

В dataSourceA и dataSourceB мы определяем источники данных. com.atomikos.jdbc.AtomikosDataSourceBean является классом, установленным здесь. Он использует пул соединений с поддержкой Atomikos JTA. У него есть два свойства для настройки. Класс com.mysql.jdbc.jdbc2.optional.MysqlXADataSource установлен в свойство xaDataSourceClass , тогда как в xaProperties мы можем задать свойства (имя, пары значений) для настройки XADataSource .

В entityManagerFactoryA и entityManagerFactoryB мы устанавливаем класс org.springframework.orm.jpa.LocalContainerEntityManagerFactoryBean . Это FactoryBean который создает JPA EntityManagerFactory соответствии со стандартным контрактом начальной загрузки контейнера JPA. Мы можем установить местоположение persistence.xml в его свойстве persistenceXmlLocation . Мы можем установить имя единицы сохраняемости, используемой для создания этого EntityManagerFactory , в свойстве persistenceUnitName . Свойство datasource является ссылкой на соответствующий компонент datasource . Для свойства jpaVendorAdapter задано значение org.springframework.orm.jpa.vendor.HibernateJpaVendorAdapter , которое является реализацией для Hibernate EntityManager .

И, наконец, определяется компонентactionManager с использованием org.springframework.transaction.jta.JtaTransactionManager . Он содержит два свойства для настройки. Менеджер transactionManager и atomikosTransactionManager . Это ссылки на два компонента класса com.atomikos.icatch.jta.J2eeUserTransaction класса com.atomikos.icatch.jta.J2eeUserTransaction соответственно.
applicationContext.xml

01
02
03
04
05
06
07
08
09
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
<beans xmlns="http://www.springframework.org/schema/beans"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:p="http://www.springframework.org/schema/p"
    xmlns:aop="http://www.springframework.org/schema/aop" xmlns:context="http://www.springframework.org/schema/context"
    xmlns:jee="http://www.springframework.org/schema/jee" xmlns:tx="http://www.springframework.org/schema/tx"
    xmlns:task="http://www.springframework.org/schema/task"
    xsi:schemaLocation="http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.2.xsd http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.2.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.2.xsd http://www.springframework.org/schema/jee http://www.springframework.org/schema/jee/spring-jee-3.2.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.2.xsd http://www.springframework.org/schema/task http://www.springframework.org/schema/task/spring-task-3.2.xsd">
 
    <context:component-scan base-package="com.javacodegeeks.snippets.enterprise.*" />
    <tx:annotation-driven />
    <tx:jta-transaction-manager />
     
    <bean id="dataSourceA" class="com.atomikos.jdbc.AtomikosDataSourceBean" init-method="init" destroy-method="close">
    <property name="uniqueResourceName"><value>DataSourceA</value></property>
    <property name="xaDataSourceClassName"><value>com.mysql.jdbc.jdbc2.optional.MysqlXADataSource</value></property>
    <property name="xaProperties">
        <props>
        <prop key="databaseName">companyA</prop>
        <prop key="serverName">localhost</prop>
        <prop key="port">3306</prop>
        <prop key="user">root</prop>
        <prop key="password">root</prop>
        <prop key="url">jdbc:mysql://localhost:3306/companyA</prop>
        </props>
    </property>
    <property name="minPoolSize"><value>1</value></property>
</bean>
     
<bean id="dataSourceB" class="com.atomikos.jdbc.AtomikosDataSourceBean" init-method="init" destroy-method="close">
    <property name="uniqueResourceName"><value>DataSourceB</value></property>
    <property name="xaDataSourceClassName"><value>com.mysql.jdbc.jdbc2.optional.MysqlXADataSource</value></property>
    <property name="xaProperties">
        <props>
        <prop key="databaseName">companyB</prop>
        <prop key="serverName">localhost</prop>
        <prop key="port">3306</prop>
        <prop key="user">root</prop>
        <prop key="password">root</prop>
        <prop key="url">jdbc:mysql://localhost:3306/companyB</prop>
        </props>
    </property>
    <property name="minPoolSize"><value>1</value></property>
</bean>
 
<bean id="entityManagerFactoryA" class="org.springframework.orm.jpa.LocalContainerEntityManagerFactoryBean">
    <property name="persistenceXmlLocation">
            <value>classpath*:persistence.xml</value>
    </property>
        <property name="persistenceUnitName" value="PersistenceUnitA" />
        <property name="dataSource" ref="dataSourceA" />
        <property name="jpaVendorAdapter">
            <bean class="org.springframework.orm.jpa.vendor.HibernateJpaVendorAdapter">
                <property name="showSql" value="true" />
                <property name="databasePlatform" value="org.hibernate.dialect.MySQL5InnoDBDialect" />
            </bean>
        </property>
    </bean>
    <bean id="entityManagerFactoryB" class="org.springframework.orm.jpa.LocalContainerEntityManagerFactoryBean">
    <property name="persistenceXmlLocation">
            <value>classpath*:persistence.xml</value>
    </property>
        <property name="persistenceUnitName" value="PersistenceUnitB" />
        <property name="dataSource" ref="dataSourceB" />
        <property name="jpaVendorAdapter">
            <bean class="org.springframework.orm.jpa.vendor.HibernateJpaVendorAdapter">
                <property name="showSql" value="true" />
                <property name="databasePlatform" value="org.hibernate.dialect.MySQL5InnoDBDialect" />
            </bean>
        </property>
    </bean>
 
    <bean id="atomikosTransactionManager" class="com.atomikos.icatch.jta.UserTransactionManager" init-method="init" destroy-method="close">
        <property name="forceShutdown" value="false" />
    </bean>
 
    <bean id="atomikosUserTransaction" class="com.atomikos.icatch.jta.J2eeUserTransaction">
        <property name="transactionTimeout" value="300" />
    </bean>
 
    <bean id="transactionManager" class="org.springframework.transaction.jta.JtaTransactionManager"
        depends-on="atomikosTransactionManager,atomikosUserTransaction">
        <property name="transactionManager" ref="atomikosTransactionManager" />
        <property name="userTransaction" ref="atomikosUserTransaction" />
        <property name="allowCustomIsolationLevels" value="true" />
    </bean>
 
</beans>

8.3 Настройка дескриптора развертывания веб-приложения

Файл web.xml — это файл, который определяет все в вашем приложении, что сервер должен знать. Здесь устанавливаются сервлеты и другие компоненты, такие как фильтры или прослушиватели, параметры инициализации, ограничения безопасности, управляемые контейнером, ресурсы, страницы приветствия и т. Д.

Элемент servlet объявляет AppServlet и класс org.springframework.web.context.support.HttpRequestHandlerServlet который его реализует. Элемент servlet-mapping указывает /appServlet URL /appServlet который вызывает сервлет в браузере. В элементе context-param мы устанавливаем параметр contextConfigLocation , где определяется местоположение файла applicationContext.xml . В элементе listener Bootstrap настроен для запуска applicationContext.xml Spring. Элемент resource-ref устанавливается в обоих источниках данных, чтобы определить справочное имя поиска для ресурсов. Это позволяет коду сервлета искать ресурсы по «виртуальному» имени, которое сопоставляется с фактическим местоположением во время развертывания.

web.xml

01
02
03
04
05
06
07
08
09
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
<?xml version="1.0" encoding="UTF-8"?>
<web-app xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xmlns="http://java.sun.com/xml/ns/javaee" xmlns:web="http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd"
    xsi:schemaLocation="http://java.sun.com/xml/ns/javaee http://java.sun.com/xml/ns/javaee/web-app_3_0.xsd"
    id="WebApp_ID" version="3.0">
 
    <display-name>javacodegeeks</display-name>
 
    <context-param>
        <param-name>contextConfigLocation</param-name>
        <param-value>
            /WEB-INF/applicationContext.xml
        </param-value>
    </context-param>
 
    <listener>
        <listener-class>org.springframework.web.context.ContextLoaderListener</listener-class>
    </listener>
 
    <servlet>
        <display-name>AppServlet</display-name>
        <servlet-name>appServlet</servlet-name>
        <servlet-class>org.springframework.web.context.support.HttpRequestHandlerServlet</servlet-class>
    </servlet>
 
    <servlet-mapping>
        <servlet-name>appServlet</servlet-name>
        <url-pattern>/appServlet</url-pattern>
    </servlet-mapping>
 
    <resource-ref>
        <description>MySQL DS</description>
        <res-ref-name>jdbc/DataSourceA</res-ref-name>
        <res-type>javax.sql.DataSource</res-type>
        <res-auth>Container</res-auth>
    </resource-ref>
 
    <resource-ref>
        <description>MySQL DS</description>
        <res-ref-name>jdbc/DataSourceB</res-ref-name>
        <res-type>javax.sql.DataSource</res-type>
        <res-auth>Container</res-auth>
    </resource-ref>
 
</web-app>

9. Запустите приложение в Tomcat.

Чтобы запустить приложение в tomcat, сначала нужно построить проект. Произведенная war помещается в папку веб-приложений Tomcat. Затем мы запускаем сервер. После удара по

localhost:8080/springexample/appServlet

в браузере мы можем проверить на MySQL, что в обеих базах данных, companyA и companyB таблицы EmployeeA и EmployeeB имеют одну запись. Сообщение, возвращаемое в браузере, показано ниже:

успех

10. Откат дела

Теперь давайте посмотрим, что произойдет, если одна из двух транзакций потерпит неудачу. Мы изменим метод persistEmployee(EmployeeB employee) класса EmployeeBDAOImpl.java чтобы создать Exception .

EmployeeBDAO Impl.java

01
02
03
04
05
06
07
08
09
10
11
12
13
14
15
16
17
18
19
20
package com.javacodegeeks.snippets.enterprise.dao;
 
import javax.persistence.EntityManager;
import javax.persistence.PersistenceContext;
 
import org.springframework.stereotype.Service;
 
import com.javacodegeeks.snippets.enterprise.model.EmployeeB;
 
@Service
public class EmployeeBDAOImpl implements EmployeeBDAO {
 
    @PersistenceContext(unitName="PersistenceUnitB")
    private EntityManager entityManager;
 
    public void persistEmployee(EmployeeB employee) throws Exception {
//      entityManager.persist(employee);
        throw new Exception();
    }
}

Мы снова строим проект и помещаем новый файл war файл веб-приложений tomcat. После повторного запуска tomcat результат будет ниже:

отмена

Это вызвано тем, что, поскольку одна из транзакций выдает исключение, распределенная транзакция также откатывается.

Это был пример транзакций с несколькими ресурсами JTA на сервере Tomcat с использованием Atomikos Transaction Manager.
Загрузите проект Eclipse этого учебника: SpringJTAatomicosTomcatExample.zip

51
Share: