------------------------------------------------------------------------------------------------------------
springcloud (零) springboot 基础 下载
springcloud (一)服务注册中心 eureka 下载
springcloud (二)服务提供方 compute-service 下载
springcloud (三)消费者 Feign(类似 websevice) 下载
springcloud (四)客户端负载均衡 ribbon 下载
springcloud (六)分布式配置中心 config server & config client 下载client 下载server
springcloud (七) bus 分布式队列 rabbitmq 下载
springcloud (八) 服务网关 gateway zuul 下载
------------------------------------------------------------------------------------------------------------
运行结果:
@SpringBootApplication public class SpringBootSampleApplication { public static void main(String[] args) throws Exception { SpringApplication.run(SpringBootSampleApplication.class, args); } }
@Component @RabbitListener(queues = "mqqueue") @EnableScheduling public class Reciever { @Bean public Sender mySender() { return new Sender(); } @Bean public Queue fooQueue() { return new Queue("mqqueue"); } @RabbitHandler public void process(@Payload String foo) { System.out.println(new Date() + "==== :" + foo); } }
public class Sender { @Autowired private RabbitTemplate rabbitTemplate; @Scheduled(fixedDelay = 1000L) public void send() { this.rabbitTemplate.convertAndSend("mqqueue", "baoyou"); } }
spring.rabbitmq.host=127.0.0.1 spring.rabbitmq.port=5672 spring.rabbitmq.username=baoy spring.rabbitmq.password=baoy
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd"> <modelVersion>4.0.0</modelVersion> <groupId>com.curiousby.cn</groupId> <artifactId>SpringCloudDemo-BUS-RabbitMQ</artifactId> <packaging>war</packaging> <version>0.0.1-SNAPSHOT</version> <name>SpringCloudDemo-Feign Maven Webapp</name> <url>http://maven.apache.org</url> <repositories> <repository> <id>spring-snapshots</id> <url>http://repo.spring.io/libs-snapshot</url> </repository> </repositories> <pluginRepositories> <pluginRepository> <id>spring-snapshots</id> <url>http://repo.spring.io/libs-snapshot</url> </pluginRepository> </pluginRepositories> <parent> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-parent</artifactId> <version>1.3.5.RELEASE</version> <relativePath/> <!-- lookup parent from repository --> </parent> <properties> <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding> <java.version>1.7</java.version> </properties> <dependencies> <!-- Compile --> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-amqp</artifactId> </dependency> <!-- Test --> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-test</artifactId> <scope>test</scope> </dependency> </dependencies> <dependencyManagement> <dependencies> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-dependencies</artifactId> <version>Brixton.RELEASE</version> <type>pom</type> <scope>import</scope> </dependency> </dependencies> </dependencyManagement> <build> <finalName>SpringCloudDemo-BUS-RabbitMQ</finalName> <plugins> <plugin> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-maven-plugin</artifactId> </plugin> <plugin> <groupId>org.apache.maven.plugins</groupId> <artifactId>maven-compiler-plugin</artifactId> <configuration> <source>1.7</source> <target>1.7</target> </configuration> </plugin> <plugin> <groupId>org.apache.maven.plugins</groupId> <artifactId>maven-surefire-plugin</artifactId> <configuration> <useSystemClassLoader>false</useSystemClassLoader> </configuration> </plugin> </plugins> </build> </project>
捐助开发者
在兴趣的驱动下,写一个免费
的东西,有欣喜,也还有汗水,希望你喜欢我的作品,同时也能支持一下。 当然,有钱捧个钱场(右上角的爱心标志,支持支付宝和PayPal捐助),没钱捧个人场,谢谢各位。
谢谢您的赞助,我会做的更好!
相关推荐
springcloud bus rabbitmq 分布式队列 http://knight-black-bob.iteye.com/blog/2356839
Spring Cloud分布式微服务实战视频...10个阶段,稳扎稳打,逐步迭代,亲历企业开发全流程让你全面掌握主流后端技术栈:Spring Cloud+MongoDB+Redis+RabbitMQ等,同时获得微服务、分布式、项目和微架构综合实战经验。
介绍Spring Cloud Stream与RabbitMQ集成的代码示例。Spring Cloud Stream是一个建立在Spring Boot和Spring Integration之上的框架,有助于创建事件驱动或消息驱动的微服务。
SpringCloud分布式微服务实战,打造大型自媒体3大业务平台视频教程,完整版15章,附源码下载。...全面掌握主流后端技术栈:Spring Cloud+MongoDB+Redis+RabbitMQ等,获得微服务、分布式、项目和微架构综合实战经验。
RabbitMQ实战 高效部署分布式消息队列 RabbitMQ实战 高效部署分布式消息队列
基于rabbit和本地消息表实现可靠消息一致性分布式事务,项目下载下来直接可以用了,已经包含了配置文件和数据库脚本,有问题的可以给我私信。项目架构springboot、nacos、rabbitMq、redis、MySQL
RabbitMQ实战 高效部署分布式消息队列 附带目录 高清完整版 PDF下载
spring cloud stream 整合 rabbitmq , 自定义消息通道,既能发消息,也能收消息
SpringCloud+RabbitMQ+Docker+Redis+搜索+分布式-个人笔记文档(基础篇)
spring-cloud之spring-cloud-stream,底层为rabbitmq实现,简单栗子,仅供参考。生产者、消费者配置及生产者、消费者代码实现。
spring-cloud-eureka Spring Cloud(一)服务的注册与发现(Eureka) spring-cloud-consul ...Spring Cloud(二) ...Spring Cloud(十一)高可用的分布式配置中心 Spring Cloud Bus 消息总线集成(RabbitMQ)
26.Spring Cloud Bus之RabbitMQ初窥 27.Spring Cloud Bus整合RabbitMQ 28.Spring Cloud Bus整合Kafka 29.Spring Cloud Stream初窥 30.Spring Cloud Stream使用细节 31.Spring Cloud系列勘误
简单介绍了如何在Spring Cloud中使用RabbitMQ和Kafka来完成消息发送与接收
spring cloud bus能管理和传播分布式系统间的消息,就像分布式执行器,可用于广播状态更改、时间推送等,也可以当做微服务间的通信通道 spring cloud bus在整个后端服务中起到联通的作用,比如我们需要更新整体配置...
RabbitMQ实战: 高效部署分布式消息队列,高质量文档分享,请珍惜!
spring-cloud-steam-rabbitmq
spring-cloud-config + spring-cloud-bus-amqp实现分布式集群配置动态更新,可更新实例对象,包含源码包+Rabbitmq安装包和安装说明
使用RabbitMQ+延迟队列实现分布式事务的最终一致性方案,demo以典型的订单+库存系统为例