Skip to content

SpringCloud Quick Start

流浪诗人丶 edited this page Jan 9, 2018 · 3 revisions
  • run EurekaServerApplication.java
  • 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

    <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&amp;characterEncoding=utf8"/>
              <property name="driverClassName" value="com.mysql.jdbc.Driver"/>
              <property name="password" value="Wgj@555888"/>
              <property name="username" value="xiaoyu"/>
          </bean>
      </property>
    </bean>
  • run SpringCloudAccountApplication.java
  • run SpringCloudInventoryApplication.java
  • run SpringcloudOrderApplication.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>