В этом руководстве мы покажем вам, как реализовать транзакции с несколькими ресурсами 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.
На странице мастера «Выберите имя проекта и местоположение» убедитесь, что опция «Создать простой проект (пропустить выбор архетипа») не отмечена , нажмите «Далее», чтобы продолжить со значениями по умолчанию.
Здесь должен быть добавлен архетип maven для создания веб-приложения. Нажмите «Добавить архетип» и добавьте архетип. Установите переменную «Archetype Group Id» на "org.apache.maven.archetypes"
, переменную «Archetype ardact Id» на "maven-archetype-webapp"
и «Archetype Version» на "1.0"
. Нажмите «ОК», чтобы продолжить.
На странице мастера «Введите идентификатор артефакта» вы можете определить имя и основной пакет вашего проекта. Задайте для переменной «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" < 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" < 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 > < 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" xsi:schemaLocation="http://java.sun.com/xml/ns/persistence < 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
|
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" 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" ?> 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