SpringBoot学习笔记(11)SpringBoot中使用rabbitmq,activemq消息队列和rest服务的调用

<dependency>
     <groupId>org.springframework.bootgroupId>
     <artifactId>spring-boot-starter-activemqartifactId>
dependency>

package com.wangx.boot.util;

import org.apache.activemq.command.ActiveMQQueue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.jms.annotation.EnableJms;

import javax.jms.Destination;

@Configuration
@EnableJms
public class JMSConfiguration {

    @Bean
    public Destination createDestination () {
        return new ActiveMQQueue("com.wangx");
    }
}

package com.wangx.boot.mq;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jms.annotation.JmsListener;
import org.springframework.jms.core.JmsMessagingTemplate;
import org.springframework.stereotype.Component;

import javax.jms.Destination;
@Component
public class JMSComponent {

    @Autowired
    private JmsMessagingTemplate jmsMessagingTemplate;

    @Autowired
    private Destination destination;

    public void send (String message) {
        jmsMessagingTemplate.convertAndSend(destination, message);
    }

    @JmsListener(destination = "com.wangx")
    public void listener (String message) {
        System.out.println("接收到的消息：" + message);
    }
}

#spring.activemq.broker-url= 
#spring.activemq.password= 
#spring.activemq.user= 
#spring.activemq.packages.trust-all=false
#spring.activemq.packages.trusted=
#spring.activemq.pool.configuration.*= 
#spring.activemq.pool.enabled=false
#spring.activemq.pool.expiry-timeout=0
#spring.activemq.pool.idle-timeout=30000
#spring.activemq.pool.max-cOnnections=1

package com.wangx.boot.controller;

import com.wangx.boot.mq.JMSComponent;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;

@Controller
@RequestMapping("/mq")
public class JMSController {


    @Autowired
    private JMSComponent jmsComponent;

    @RequestMapping("/send")
    @ResponseBody
    public String send(String msg) {
        jmsComponent.send(msg);
        return msg;
    }
}

            org.springframework.boot
            spring-boot-starter-amqp
        

package com.wangx.boot.util;

import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class AMQConfiguration {

    @Bean
    public Queue queue() {
        return new Queue("hello", true);
    }

}

package com.wangx.boot.mq;

import org.springframework.amqp.core.AmqpTemplate;
import org.springframework.amqp.core.Queue;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

@Component
public class AMQComponent {

    @Autowired
    private AmqpTemplate amqpTemplate;

    public void send(String message) {
        amqpTemplate.convertAndSend("hello", message);
    }

    @RabbitListener(queues = "hello")
    public void receiveQueue(String text) {
        System.out.println("接受到：" + text);
    }
}

package com.wangx.boot.controller;

import com.wangx.boot.mq.AMQComponent;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;

@Controller
@RequestMapping("/amq")
public class AMQController {

    @Autowired
    private AMQComponent amqComponent;

    @RequestMapping("/send")
    @ResponseBody
    public String send(String  msg) {
        amqComponent.send(msg);
        return msg;
    }
}

            org.apache.httpcomponents
            httpclient

package com.wangx.boot.controller;

import com.wangx.boot.cache.CachingBook;
import com.wangx.boot.entity.Book;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;


@RestController
@RequestMapping("/api")
public class ApiController {

    @Autowired
    private CachingBook cachingBook;

    @RequestMapping(value = "/select", method = RequestMethod.GET)
    public Book get(@RequestParam(defaultValue = "遮天") String name) {
        Book book = cachingBook.findById(name);
        return book;
    }

    @RequestMapping(value = "/update", method = RequestMethod.GET)
    public Book update(@RequestParam(defaultValue = "遮天") String name) {
        Book bean = cachingBook.findById(name);
        bean.setAuthor("耳根");
        cachingBook.updateById(bean);
        return bean;
    }

    @RequestMapping(value = "/del", method = RequestMethod.GET)
    public String del(@RequestParam(defaultValue = "遮天") String name) {
        return cachingBook.deleteById(name);
    }
}

@Autowired
    private RestTemplateBuilder restTemplateBuilder;

        /**
         * get请求
         */
        @Test
        public void getForObject() {
            //发送get请求
            String res = restTemplateBuilder.build().getForObject("http://localhost:8080/api/select",String.class, "遮天");
            System.out.println(res);
            Map map = new HashMap();
            map.put("name", "遮天");
            //发送post请求
            res = restTemplateBuilder.build().postForObject("http://localhost:8080/api/update", map, String.class);
            System.out.println(res);
        }

String result = restTemplateBuilder.additionalCustomizers(new ProxyCustomizer()).build().getForObject("http://www.baidu.com", String.class);
        System.out.println(result);