vlambda博客
学习文章列表

    <dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-data-jpa</artifactId>
    </dependency>

    <dependency>
      <groupId>org.hsqldb</groupId>
      <artifactId>hsqldb</artifactId>
      <scope>runtime</scope>
    </dependency>

      $spring –-version
      Spring CLI v2.0.0.M1

        @RestController
        class HelloworldController {
          @RequestMapping("/")
          String sayHello(){
            return "Hello World!"
          }
        }

      $spring run myfirstapp.groovy 
      2016-12-16 13:04:33.208  INFO 29126 --- [ runner-0]  
      s.b.c.e.t.TomcatEmbeddedServletContainer : Tomcat started on
      port(s):  
      8080 (http)
      2016-12-16 13:04:33.214  INFO 29126 --- [ runner-0]  
      o.s.boot.SpringApplication : Started application in 4.03 
      seconds (JVM running for 104.276)

        Hello World!

        <parent>
          <groupId>org.springframework.boot</groupId>
          <artifactId>spring-boot-starter-parent</artifactId>
          <version>2.0.0.M1</version>
        </parent>

        <activemq.version>5.14.5</activemq.version>
        <commons-collections.version>3.2.2
        </commons-collections.version>
        <hibernate.version>5.2.10.Final</hibernate.version>
        <jackson.version>2.9.0.pr3</jackson.version>
        <mssql-jdbc.version>6.1.0.jre8</mssql-jdbc.version>
        <spring.version>5.0.0.RC1</spring.version>
        <spring-amqp.version>2.0.0.M4</spring-amqp.version>
        <spring-security.version>5.0.0.M1</spring-security.version>
        <thymeleaf.version>3.0.6.RELEASE</thymeleaf.version>
        <tomcat.version>8.5.15</tomcat.version>

        <dependencies>
          <dependency>
           <groupId>org.springframework.boot</groupId>
           <artifactId>spring-boot-starter-web</artifactId>
          </dependency>
          <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
           <scope>test</scope>
          </dependency>
        </dependencies> 

        <java.version>1.8</java.version>

        @SpringBootApplication
        public class Application {
          public static void main(String[] args) {
            SpringApplication.run(Application.class, args);
          }
        }

        @Configuration
        @EnableAutoConfiguration
        @ComponentScan
        public class Application {

        @RestController
        class GreetingController{
          @GetMapping("/")
          Greet greet(){
            return new Greet("Hello World!");
          }
        }
        class Greet{
          private String message;
          public Greet() {}
          public Greet(String message){
            this.message = message;
          }
          //add getter and setter
        }

$ maven install

$java -jar target/bootrest-0.0.1-SNAPSHOT.jar

        @RequestMapping("/greeting")
        @ResponseBody
        public HttpEntity<Greet> greeting(@RequestParam(value = "name", 
          required = false, defaultValue = "HATEOAS") String name) {
           Greet greet = new Greet("Hello " + name);
           greet.add(linkTo(methodOn(GreetingController.class)
             .greeting(name)).withSelfRel());
           return new ResponseEntity<Greet>(greet, HttpStatus.OK);
        } 

        greet.add(linkTo(methodOn(
          GreetingController.class).greeting(name)).withSelfRel());

        class Greet extends ResourceSupport{

    @RestController
    class GreetingController{
      @CrossOrigin
      @RequestMapping("/")
      Greet greet(){
        return new Greet("Hello World!");
      }
    }

    @CrossOrigin("http://mytrustedorigin.com")

    <dependency>
      <groupId>io.springfox</groupId>
      <artifactId>springfox-swagger2</artifactId>
      <version>2.6.1</version>
    </dependency>

<dependency>
      <groupId>io.springfox</groupId>
      <artifactId>springfox-swagger-ui</artifactId>
      <version>2.6.1</version>
    </dependency>

    @SpringBootApplication
    @EnableSwagger2
    public class Application {

        @Entity
        class Customer  {
@Id
          @GeneratedValue(strategy = GenerationType.AUTO)

          private Long id;
          private String name;
          private String email; 

        @RepositoryRestResource
        interface CustomerRespository extends JpaRepository 
        <Customer,Long>{
          Optional<Customer> findByName(@Param("name") String name);
        }

        @SpringBootApplication
        public class Application {
          public static void main(String[] args) {
            SpringApplication.run(Application.class, args);
          }
          @Bean
         CommandLineRunner init(CustomerRespository repo) {
           return (evt) ->    {
             repo.save(new Customer("Adam","[email protected]"));
             repo.save(new Customer("John","[email protected]"));
              repo.save(new Customer("Smith","[email protected]"));
             repo.save(new Customer("Edgar","[email protected]"));
              repo.save(new Customer("Martin","[email protected]"));
              repo.save(new Customer("Tom","[email protected]"));
              repo.save(new Customer("Sean","[email protected]"))
           };
}
        } 

        @RestController
        class CustomerController{
@Autowired
          CustomerRegistrar customerRegistrar;

          @RequestMapping( path="/register", method =
           RequestMethod.POST)
Customer register(@RequestBody Customer customer){
            return customerRegistrar.register(customer);
          }
        }

        @Component 
        class CustomerRegistrar {
CustomerRespository customerRespository;

          @Autowired
          CustomerRegistrar(CustomerRespository customerRespository){                                                       
            this.customerRespository = customerRespository;
          }
          // ideally repository will return a Mono object
          public Mono<Customer> register(Customer customer){
            if(customerRespository
              .findByName(customer.getName())
              .isPresent())
              System.out.println("Duplicate Customer.
                No Action required");
            else {
              customerRespository.save(customer);
            }
            return Mono.just(customer);
          }
        }

        @Component 
        @Lazy
        class CustomerRegistrar {
CustomerRespository customerRespository;
          Sender sender;

          @Autowired
          CustomerRegistrar(CustomerRespository customerRespository, 
          Sender sender){
            this.customerRespository = customerRespository; 
            this.sender = sender;
         }
         // ideally repository will return a Mono object
          public Mono<Customer> register(Customer customer){
            if(customerRespository.findByName(
              customer.getName()).isPresent())
              System.out.println("Duplicate Customer.
              No Action required");
            else {
              customerRespository.save(customer);
              sender.send(customer.getEmail());
            }
            return Mono.just(customer); //HARD CODED BECOSE THERE 
              IS NO REACTIVE REPOSITORY.
          }
        } 

        @Component 
        @Lazy
        class Sender {
@Autowired
          RabbitMessagingTemplate template;
          @Bean
          Queue queue() {  
            return new Queue("CustomerQ", false);
          }
          public void send(String message){
           template.convertAndSend("CustomerQ", message);
    }
        }

        spring.rabbitmq.host=localhost
        spring.rabbitmq.port=5672
        spring.rabbitmq.username=guest
        spring.rabbitmq.password=guest 

        @Component
        class Receiver {
@Autowired
          Mailer mailer;

          @Bean
          Queue queue() {
            return new Queue("CustomerQ", false);
          }

          @RabbitListener(queues = "CustomerQ")
          public void processMessage(String email)  {
            System.out.println(email);
            mailer.sendMail(email);
          }
        }

        @Component 
        class Mailer  {
@Autowired
          private  JavaMailSender  javaMailService;

          public void sendMail(String email) {
          SimpleMailMessage mailMessage=new SimpleMailMessage();
            mailMessage.setTo(email);
            mailMessage.setSubject("Registration");
            mailMessage.setText("Successfully Registered");                
            javaMailService.send(mailMessage); 
          }
        }

      $ java -jar fakeSMTP-2.0.jar

        spring.rabbitmq.host=localhost
        spring.rabbitmq.port=5672
        spring.rabbitmq.username=guest
        spring.rabbitmq.password=guest
        spring.mail.host=localhost
        spring.mail.port=2525