一区二区三区在线-一区二区三区亚洲视频-一区二区三区亚洲-一区二区三区午夜-一区二区三区四区在线视频-一区二区三区四区在线免费观看

服務器之家：專注于服務器技術及軟件下載分享
分類導航

PHP教程|ASP.NET教程|Java教程|ASP教程|編程技術|正則表達式|C/C++|IOS|C#|Swift|Android|VB|R語言|JavaScript|易語言|vb.net|

服務器之家 - 編程語言 - Java教程 - Spring中使用atomikos+druid實現經典分布式事務的方法

Spring中使用atomikos+druid實現經典分布式事務的方法

2019-06-30 21:07馮立彬 Java教程

這篇文章主要介紹了Spring中使用atomikos+druid實現經典分布式事務的方法，小編覺得挺不錯的，現在分享給大家，也給大家做個參考。一起跟隨小編過來看看吧

經典分布式事務，是相對互聯網中的柔性分布式事務而言，其特性為ACID原則，包括原子性（Atomictiy）、一致性（Consistency）、隔離性（Isolation）、持久性（Durabilit）：

  • 原子性：事務是一個包含一系列操作的原子操作。事務的原子性確保這些操作全部完成或者全部失敗。
  • 一致性：一旦事務的所有操作結束，事務就被提交。然后你的數據和資源將處于遵循業務規則的一直狀態。
  • 隔離性：因為同時在相同數據集上可能有許多事務處理，每個事務應該與其他事務隔離，避免數據破壞。
  • 持久性：一旦事務完成，他的結果應該能夠承受任何系統錯誤（想象一下在事務提交過程中機器的電源被切斷的情況）。通常，事務的結果被寫入持續性存儲。

XA是啥？

XA是由X/Open組織提出的分布式事務的架構（或者叫協議）。XA架構主要定義了（全局）事務管理器（Transaction Manager）和（局部）資源管理器（Resource Manager）之間的接口。XA接口是雙向的系統接口，在事務管理器（Transaction Manager）以及一個或多個資源管理器（Resource Manager）之間形成通信橋梁。也就是說，在基于XA的一個事務中，我們可以針對多個資源進行事務管理，例如一個系統訪問多個數據庫，或即訪問數據庫、又訪問像消息中間件這樣的資源。這樣我們就能夠實現在多個數據庫和消息中間件直接實現全部提交、或全部取消的事務。XA規范不是java的規范，而是一種通用的規范，

目前各種數據庫、以及很多消息中間件都支持XA規范。

JTA是滿足XA規范的、用于Java開發的規范。所以，當我們說，使用JTA實現分布式事務的時候，其實就是說，使用JTA規范，實現系統內多個數據庫、消息中間件等資源的事務。

JTA(Java Transaction API)，是J2EE的編程接口規范，它是XA協議的JAVA實現。它主要定義了：

  • 一個事務管理器的接口javax.transaction.TransactionManager，定義了有關事務的開始、提交、撤回等>操作。
  • 一個滿足XA規范的資源定義接口javax.transaction.xa.XAResource，一種資源如果要支持JTA事務，就需要讓它的資源實現該XAResource接口，并實現該接口定義的兩階段提交相關的接口。如果我們有一個應用，它使用JTA接口實現事務，應用在運行的時候，就需要一個實現JTA的容器，一般情況下，這是一個J2EE容器，像JBoss，Websphere等應用服務器。但是，也有一些獨立的框架實現了JTA，例如 Atomikos, bitronix 都提供了jar包方式的JTA實現框架。這樣我們就能夠在Tomcat或者Jetty之類的服務器上運行使用JTA實現事務的應用系統。在上面的本地事務和外部事務的區別中說到，JTA事務是外部事務，可以用來實現對多個資源的事務性。它正是通過每個資源實現的XAResource來進行兩階段提交的控制。感興趣的同學可以看看這個接口的方法，除了commit, rollback等方法以外，還有end(), forget(), isSameRM(), prepare()等等。光從這些接口就能夠想象JTA在實現兩階段事務的復雜性。

本篇以Spring MVC+Maven+Atomikos+Druid+MyBatis演示分布式事務的實現。

Mave 的pom.xml

<properties>
 <jdk.version>1.8</jdk.version>
 <!-- 注mysql的版本和druid的版本一定要搭配，否則會有問題，目前這兩個版本是搭配好的 -->
 <mysql.version>8.0.11</mysql.version>
 <druid.version>1.1.17</druid.version>
 <spring.version>5.1.8.RELEASE</spring.version>
 <cglib.version>3.2.12</cglib.version>
 <atomikos.version>5.0.0</atomikos.version>
 <aspectjweaver.version>1.9.4</aspectjweaver.version>
 <aspectjrt.version>1.5.4</aspectjrt.version>
 <jta.version>1.1</jta.version>
 <mybatise.version>3.2.0</mybatise.version>
 <mybatis.spring>1.2.0</mybatis.spring>
 <log4j.version>1.2.17</log4j.version>
 <junit.version>4.12</junit.version>
 <cglib.version>3.2.4</cglib.version>
</properties>
<dependencies>
 <dependency>
 <groupId>org.mybatis</groupId>
 <artifactId>mybatis</artifactId>
 <version>${mybatise.version}</version>
 </dependency>
 <dependency>
 <groupId>org.mybatis</groupId>
 <artifactId>mybatis-spring</artifactId>
 <version>${mybatis.spring}</version>
 </dependency>
 <dependency>
 <groupId>com.atomikos</groupId>
 <artifactId>atomikos-util</artifactId>
 <version>${atomikos.version}</version>
 </dependency>
 <dependency>
 <groupId>com.atomikos</groupId>
 <artifactId>transactions</artifactId>
 <version>${atomikos.version}</version>
 </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-api</artifactId>
 <version>${atomikos.version}</version>
 </dependency>
 <dependency>
 <groupId>javax.transaction</groupId>
 <artifactId>jta</artifactId>
 <version>${jta.version}</version>
 </dependency>
 <dependency>
 <groupId>cglib</groupId>
 <artifactId>cglib-nodep</artifactId>
 <version>${cglib.version}</version>
 </dependency>
 <dependency>
 <groupId>org.springframework</groupId>
 <artifactId>spring-test</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-tx</artifactId>
 <version>${spring.version}</version>
 </dependency>
 <dependency>
 <groupId>org.springframework</groupId>
 <artifactId>spring-beans</artifactId>
 <version>${spring.version}</version>
 </dependency>
 <dependency>
 <groupId>org.springframework</groupId>
 <artifactId>spring-jdbc</artifactId>
 <version>${spring.version}</version>
 </dependency>
 <dependency>
 <groupId>org.springframework</groupId>
 <artifactId>spring-webmvc</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-context-support</artifactId>
 <version>${spring.version}</version>
 </dependency>
 <!-- Spring Aop依賴jar -->
 <dependency>
 <groupId>org.aspectj</groupId>
 <artifactId>aspectjweaver</artifactId>
 <version>${aspectjweaver.version}</version>
 </dependency>

 <dependency>
 <groupId>aspectj</groupId>
 <artifactId>aspectjrt</artifactId>
 <version>${aspectjrt.version}</version>
 </dependency>
 <!-- CGLIB -->
 <dependency>
 <groupId>cglib</groupId>
 <artifactId>cglib</artifactId>
 <version>${cglib.version}</version>
 </dependency>
 <dependency>
 <groupId>mysql</groupId>
 <artifactId>mysql-connector-java</artifactId>
 <version>${mysql.version}</version>
 </dependency>
 <dependency>
 <groupId>com.alibaba</groupId>
 <artifactId>druid</artifactId>
 <version>${druid.version}</version>
 </dependency>
 <dependency>
 <groupId>junit</groupId>
 <artifactId>junit</artifactId>
 <version>${junit.version}</version>
 <scopte>test</scope>
 </dependency>
</dependencies>

spring-application-context.xml

<?xml version="1.0" encoding="UTF-8"?>
<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:tx="http://www.springframework.org/schema/tx"
  xmlns:context="http://www.springframework.org/schema/context"
  xmlns:aop="http://www.springframework.org/schema/aop"
  xmlns:mvc="http://www.springframework.org/schema/mvc"
  xmlns:task="http://www.springframework.org/schema/task"
  xsi:schemaLocation="http://www.springframework.org/schema/beans 
  http://www.springframework.org/schema/beans/spring-beans-3.1.xsd
  http://www.springframework.org/schema/mvc
  http://www.springframework.org/schema/mvc/spring-mvc-3.1.xsd
  http://www.springframework.org/schema/context 
  http://www.springframework.org/schema/context/spring-context-3.1.xsd
  http://www.springframework.org/schema/task http://www.springframework.org/schema/task/spring-task.xsd
  http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.1.xsd
  http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.1.xsd">
  
   <!-- 1. 數據源配置 -->
  <context:property-placeholder location="classpath*:*.properties" file-encoding="utf8" />
 <bean id="utf8" class="java.lang.String">
 <constructor-arg value="utf-8"></constructor-arg>
 </bean>
  <!-- 開啟異步任務（同時開啟定時器注解掃描） -->
  <task:annotation-driven />
  <!-- 使用@AspectJ風格的切面聲明 -->
  <!-- <aop:aspectj-autoproxy/> -->
  <!-- 使用Annotation自動注冊Bean -->
  <!-- 在主容器中不掃描@Controller注解，在SpringMvc中只掃描@Controller注解 -->
  <context:component-scan base-package="net.xiake6"><!-- base-package 如果多個，用“,”分隔 --> 
    <context:exclude-filter type="annotation" expression="org.springframework.stereotype.Controller" />
  </context:component-scan> 
  <!-- 引入Mybatis配置 -->
  <!-- <import resource="spring-mybatis-atomikos-druid.xml"/> -->
  <import resource="spring-mybatis-atomikos-druid.xml"/>
</beans>

spring-mybatis-atomikos-druid.xml

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
  xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 
  xmlns:jee="http://www.springframework.org/schema/jee"
  xmlns:tx="http://www.springframework.org/schema/tx" 
  xmlns:context="http://www.springframework.org/schema/context" 
  xmlns:aop="http://www.springframework.org/schema/aop"
  xsi:schemaLocation="http://www.springframework.org/schema/beans 
  http://www.springframework.org/schema/beans/spring-beans-3.0.xsd 
  http://www.springframework.org/schema/tx 
  http://www.springframework.org/schema/tx/spring-tx-3.0.xsd 
  http://www.springframework.org/schema/jee 
  http://www.springframework.org/schema/jee/spring-jee-3.0.xsd 
  http://www.springframework.org/schema/aop 
  http://www.springframework.org/schema/aop/spring-aop-3.0.xsd
  http://www.springframework.org/schema/context 
  http://www.springframework.org/schema/context/spring-context-3.0.xsd"
  default-lazy-init="true">  

 <context:annotation-config />
 <!-- 使用Druid使為XA數據源 -->
  <bean id="abstractXADataSource" class="com.atomikos.jdbc.AtomikosDataSourceBean" init-method="init" destroy-method="close" abstract="true">
    <property name="xaDataSourceClassName" value="com.alibaba.druid.pool.xa.DruidXADataSource"/>
    <property name="xaProperties">
      <props>
       <prop key="driverClassName">${jdbc.driverClassName}</prop>
       <!-- 配置初始化大小、最小、最大 -->
  <prop key="initialSize">10</prop>
  <prop key="minIdle">3</prop>
  <prop key="maxActive">100</prop>
  <!-- 配置獲取連接等待超時的時間 -->
  <prop key="maxWait">60000</prop>
  <!-- 配置間隔多久才進行一次檢測，檢測需要關閉的空閑連接，單位是毫秒 -->
  <prop key="timeBetweenEvictionRunsMillis">60000</prop>
  <!-- 配置一個連接在池中最小生存的時間，單位是毫秒 -->
  <prop key="minEvictableIdleTimeMillis">300000</prop>
  <prop key="validationQuery">SELECT 'x'</prop>
  <prop key="testWhileIdle">true</prop>
  <prop key="testOnBorrow">false</prop>
  <prop key="testOnReturn">false</prop>
  <!-- 配置監控統計攔截的filters -->
  <prop key="filters">stat</prop>
      </props>
    </property>
  </bean>
  <!-- 配置數據源一 -->
  <bean id="dataSourceOne" parent="abstractXADataSource">
    <property name="uniqueResourceName">
      <value>dataSourceOne</value>
    </property>
    <property name="xaProperties">
      <props>
        <prop key="url">${jdbc.url}</prop>
        <prop key="username">${jdbc.username}</prop>
        <prop key="password">${jdbc.password}</prop>
      </props>
    </property>
  </bean>
  <!--配置數據源二-->
  <bean id="dataSourceTwo" parent="abstractXADataSource">
    <property name="uniqueResourceName">
      <value>dataSourceTwo</value>
    </property>
    <property name="xaProperties">
      <props>
        <prop key="url">${jdbc.two.url}</prop>
        <prop key="username">${jdbc.two.username}</prop>
        <prop key="password">${jdbc.two.password}</prop>
      </props>
    </property>
  </bean>
  
  <!--mybatis的相關配置-->
  <bean id="sqlSessionFactoryOne" class="org.mybatis.spring.SqlSessionFactoryBean">
    <property name="dataSource" ref="dataSourceOne"/>
    <property name="mapperLocations" value="classpath*:mapping/ds1/*.xml"/>
  </bean>
  
  <bean id="sqlSessionFactoryTwo" class="org.mybatis.spring.SqlSessionFactoryBean">
    <property name="dataSource" ref="dataSourceTwo"/>
    <property name="mapperLocations" value="classpath*:mapping/ds2/*.xml"/>
  </bean>
  
  <!--配置mybatis映射文件自動掃描-->
  <bean class="org.mybatis.spring.mapper.MapperScannerConfigurer">
    <property name="basePackage" value="net.xiake6.dao.ds1"/>
    <property name="sqlSessionFactoryBeanName" value="sqlSessionFactoryOne"/>
  </bean>

  <bean class="org.mybatis.spring.mapper.MapperScannerConfigurer">
    <property name="basePackage" value="net.xiake6.dao.ds2"/>
    <property name="sqlSessionFactoryBeanName" value="sqlSessionFactoryTwo"/>
  </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.UserTransactionImp">
    <property name="transactionTimeout" value="3000"/>
  </bean>
  <!--JTA事務管理器-->
  <bean id="jtaTransactionManager" class="org.springframework.transaction.jta.JtaTransactionManager">
    <property name="transactionManager">
      <ref bean="atomikosTransactionManager"/>
    </property>
    <property name="userTransaction">
      <ref bean="atomikosUserTransaction"/>
    </property>
    <property name="allowCustomIsolationLevels" value="true"/>
  </bean>
  
  
  <aop:config proxy-target-class="true"> 
    <aop:advisor pointcut="execution(* *net.xiake6.service..*(..))" advice-ref="txAdvice" /> 
  </aop:config> 
  <tx:advice id="txAdvice" transaction-manager="jtaTransactionManager"> 
    <tx:attributes> 
      <tx:method name="insert*" propagation="REQUIRED" read-only="false" rollback-for="*Exception"/>
      <tx:method name="add*" propagation="REQUIRED" read-only="false" rollback-for="*Exception" /> 
      <tx:method name="save*" propagation="REQUIRED" read-only="false" rollback-for="*Exception" />  
      <tx:method name="delete*" propagation="REQUIRED" read-only="false" rollback-for="*Exception" /> 
      <tx:method name="del*" propagation="REQUIRED" read-only="false" rollback-for="*Exception" /> 
      <tx:method name="update*" propagation="REQUIRED" read-only="false" rollback-for="*Exception" />
      <tx:method name="select*" propagation="REQUIRED" read-only="true" />
      <tx:method name="query" propagation="REQUIRED" read-only="true" />
    </tx:attributes> 
  </tx:advice>
  
  <!-- 配置事務管理 -->
  <tx:annotation-driven transaction-manager="jtaTransactionManager" />
</beans>

jdbc.properties

#mysql 6.*以上
jdbc.driverClassName = com.mysql.cj.jdbc.Driver
jdbc.url = jdbc:mysql://127.0.0.1:3306/test?serverTimezone=UTC&useUnicode=true&characterEncoding=UTF-8&pinGlobalTxToPhysicalConnection=true&useSSL=false
jdbc.username =root
jdbc.password =root

jdbc.two.url = jdbc:mysql://127.0.0.1:3306/test?serverTimezone=UTC&useUnicode=true&characterEncoding=UTF-8&pinGlobalTxToPhysicalConnection=true&useSSL=false
jdbc.two.username =root
jdbc.two.password =root

jta.properties

com.atomikos.icatch.service=com.atomikos.icatch.standalone.UserTransactionServiceFactory
com.atomikos.icatch.console_file_name=tm.release.out
com.atomikos.icatch.log_base_name=tm.releaselog
com.atomikos.icatch.tm_unique_name=com.atomikos.spring.jdbc.tm.release
com.atomikos.icatch.console_log_level=INFO

TestInsert.java

@ContextConfiguration(value = {"classpath:spring-application-context.xml"})
@RunWith(SpringJUnit4ClassRunner.class)
public class TestInsert {
 private Logger logger = LoggerFactory.getLogger(TestInsert.class);
 @Autowired
 private BatchInsertService batchInsertService;

 @Test
 public void insert(){
 
 long startTime = System.currentTimeMillis();
 User user = new User();
 user.setName("User_"+(int)(Math.random()*100));
 user.setAge((int)(Math.random()*100));
 
 CustInfo info = new CustInfo();
 info.setPhone("123456789"+(int)(Math.random()*100));
 batchInsertService.insert(user,info);
 
 long endTime = System.currentTimeMillis();
 logger.info("共耗時：{}毫秒",endTime -startTime);
 }
}

BatchInsertService.java

@Service
public class BatchInsertService {
 private Logger logger = LoggerFactory.getLogger(BatchInsertService.class);
 @Autowired
 private UserService userService;
 @Autowired
 private CustInfoService custInfoService;
 @Transactional(rollbackFor= {Exception.class,RuntimeException.class})
 public void insert(User user,CustInfo custInfo) {
 int insertUser = userService.insert(user);
 logger.info("insertUser={}",insertUser);
 int insertCustInfo = custInfoService.insert(custInfo);
 logger.info("insertCustInfo={}",insertCustInfo);
 }
}

UserService.java

@Service
public class UserService {
 @Autowired
 private UserMapper userMapper;
 
 public int insert(User record) {
 int result = userMapper.insert(record);
 return result;
 }
 
}

CustInfoService.java

@Service
public class CustInfoService {
 @Autowired
 private CustInfoMapper custInfoMapper;

 public int insert(CustInfo record) {
 int result = custInfoMapper.insert(record);
 long now = System.currentTimeMillis();
 // 模擬一個異常
 if (now % 2 == 0) {
  throw new RuntimeException("CustInfoMapper throws test insert exception");
 }
 return result;
 }
}

Mapper和Bean等就不列出來了，完成的示例工程在github： https://github.com/fenglibin/DruidWithAtomikos

以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支持服務器之家。

延伸 · 閱讀

精彩推薦
  • Java教程JavaWeb 實現驗證碼功能(demo)

    JavaWeb 實現驗證碼功能(demo)

    在 WEB-APP 中一般應用于：登錄、注冊、買某票、秒殺等場景，大家都接觸過這個驗證碼操作，今天小編通過實例代碼給大家講解javaweb實現驗證碼功能，需要...

    java教程網12832020-08-05
  • Java教程SpringBoot引入Thymeleaf的實現方法

    SpringBoot引入Thymeleaf的實現方法

    這篇文章主要介紹了SpringBoot引入Thymeleaf的實現方法，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下...

    Bobby6472021-07-28
  • Java教程JAVA中通過自定義注解進行數據驗證的方法

    JAVA中通過自定義注解進行數據驗證的方法

    java 自定義注解驗證可自己添加所需要的注解，下面這篇文章主要給大家介紹了關于JAVA中通過自定義注解進行數據驗證的相關資料，文中通過示例代碼介紹...

    Decouple6362021-05-25
  • Java教程Java list.remove( )方法注意事項

    Java list.remove( )方法注意事項

    這篇文章主要介紹了Java list.remove( )方法注意事項,非常簡單易懂，需要的朋友可以參考下...

    妖久9552021-05-25
  • Java教程java 中鎖的性能提高辦法

    java 中鎖的性能提高辦法

    這篇文章主要介紹了java 中鎖的性能提高辦法的相關資料,需要的朋友可以參考下...

    Java之家3092020-08-13
  • Java教程Java之Springcloud Feign組件詳解

    Java之Springcloud Feign組件詳解

    這篇文章主要介紹了Java之Springcloud Feign組件詳解,本篇文章通過簡要的案例,講解了該項技術的了解與使用,以下就是詳細內容,需要的朋友可以參考下...

    深情以改10322021-11-12
  • Java教程springboot ehcache 配置使用方法代碼詳解

    springboot ehcache 配置使用方法代碼詳解

    EhCache是一個比較成熟的Java緩存框架，Springboot對ehcache的使用非常支持，所以在Springboot中只需做些配置就可使用，且使用方式也簡易，今天給大家分享spri...

    m1719309529412912021-09-16
  • Java教程淺談Java(SpringBoot)基于zookeeper的分布式鎖實現

    淺談Java(SpringBoot)基于zookeeper的分布式鎖實現

    這篇文章主要介紹了Java(SpringBoot)基于zookeeper的分布式鎖實現，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的...

    LJY_SUPER5742021-07-21
主站蜘蛛池模板： 欧美精品综合一区二区三区 | 91动漫在线观看 | 白丝打脚枪 | 国产成人精品视频午夜 | 亚洲国产精品ⅴa在线观看 亚洲国产高清一区二区三区 | 日本人欧美xx | 十大网站免费货源 | 精品牛牛影视久久精品 | 欧美亚洲国产成人不卡 | 国产精品日本一区二区三区在线看 | 精品精品国产yyy5857香蕉 | 美女视频黄a | 日本不卡1卡2卡三卡网站二百 | 处女呦呦| 99久久精品免费观看区一 | 精精国产xxxx视频在线播放器 | 成免费视频 | 国产精品玖玖玖影院 | 四虎在线精品观看免费 | 香蕉精品国产高清自在自线 | 久久综合久综合久久鬼色 | 成人黄色免费网站 | 国内交换一区二区三区 | 日韩国产欧美视频 | 娇妻与公陈峰姚瑶小说在线阅读 | 97久久久亚洲综合久久88 | 九九热在线观看视频 | 北岛玲在线视频 | 被调教的校花 | 石原莉奈被店长侵犯免费 | 动漫肉在线观看 | 被黑人同学彻底征服全文小说阅读 | 青青草原国产视频 | 91在线亚洲精品一区 | 婚前试爱全集免费观看 | 国产精品亚洲片在线观看麻豆 | 波多野结衣教师未删减版 | 亚欧美综合 | 欧美va在线观看 | 好吊色青青青国产综合在线观看 | 亚洲va天堂va国产va久久 |