cd https://github.com/yu199195/myth/tree/master/myth-demo/myth-demo-dubbo
Modifiy application.yml on Indicator Item And Modifiy you jdbc url And choose you Message Oriented Middleware
spring: datasource: driver-class-name: com.mysql.jdbc.Driver url: jdbc:mysql://192.168.1.68:3306/myth_account?useUnicode=true&characterEncoding=utf8 username: xiaoyu password: Wgj@555888 #activemq: # broker-url: tcp://120.76.52.162:61616 # user: happylife # password: happylifeplat01 # trust-all: true #rabbitmq: # host: localhost # port: 5672 # username: guest # password: guest rocketmq: namesrvAddr: 192.168.1.148:9876 consumerGroupName: account instanceName: account #kafka: # consumer: # bootstrap-servers: localhost:9092 # group-id: test # auto-offset-reset: earliest # enable-auto-commit: true # auto-commit-interval: 100 # key-deserializer: org.apache.kafka.common.serialization.StringDeserializer # value-deserializer: org.apache.kafka.common.serialization.ByteArrayDeserializer
- Modifiy applicationContext.xml on Indicator Item And choose repositorySupport and modifiy it
- If you use database compensation , You have to create a new database for example:myth
xml <context:component-scan base-package="com.github.myth.*"/> <aop:aspectj-autoproxy expose-proxy="true"/> <bean id="mythTransactionBootstrap" class="com.github.myth.core.bootstrap.MythTransactionBootstrap"> <property name="repositorySuffix" value="account-service"/> <property name="serializer" value="kryo"/> <property name="coordinatorQueueMax" value="5000"/> <property name="coordinatorThreadMax" value="8"/> <property name="rejectPolicy" value="Abort"/> <property name="blockingQueueType" value="Linked"/> <property name="repositorySupport" value="db"/> <property name="mythDbConfig"> <bean class="com.github.myth.common.config.MythDbConfig"> <property name="url" value="jdbc:mysql://192.168.1.68:3306/myth?useUnicode=true&characterEncoding=utf8"/> <property name="driverClassName" value="com.mysql.jdbc.Driver"/> <property name="password" value="Wgj@555888"/> <property name="username" value="xiaoyu"/> </bean> </property> </bean>
Modifiy spring-dubbo.xml on Indicator Item And modifiy zookeeper url
```xml
run DubboInventoryApplication.java
run DubboOrderApplication.java
this mq sender so befer:- in applicationContext.xml choose import you mq sender config
<import resource="spring-rocketmq.xml"/> <!--<import resource="spring-rabbitmq.xml"/>--> <!--<import resource="spring-kafka.xml"/>--> <!--<import resource="spring-activemq.xml"/>-->
- modifiy you mq config for example
<bean id="defaultMQProducer" class="org.apache.rocketmq.client.producer.DefaultMQProducer" init-method="start" destroy-method="shutdown"> <constructor-arg name="producerGroup" value="producerGroup" /> <property name="namesrvAddr" value="192.168.1.148:9876" /> <property name="retryTimesWhenSendFailed" value="10" /> </bean>
<bean id="rocketmqSendService" class="com.github.myth.rocketmq.service.RocketmqSendServiceImpl"> <property name="defaultMQProducer" ref="defaultMQProducer"/> </bean>
- in applicationContext.xml choose import you mq sender config