欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页

springcloud 分布式队列 bus rabbitmq

程序员文章站 2022-06-13 18:59:37
...

 

 ------------------------------------------------------------------------------------------------------------ 

springcloud (零) springboot 基础      下载

springcloud (一)服务注册中心 eureka   下载

springcloud (二)服务提供方 compute-service  下载

springcloud (三)消费者 Feign(类似 websevice)  下载

springcloud (四)客户端负载均衡 ribbon  下载

springcloud (五)断路由hystrix 下载

springcloud (六)分布式配置中心 config server & config client  下载client 下载server

springcloud (七) bus 分布式队列 rabbitmq 下载

springcloud (八) 服务网关 gateway zuul 下载

 ------------------------------------------------------------------------------------------------------------ 

rabbitmq 安装 windows   

 

 

运行结果:

springcloud 分布式队列  bus  rabbitmq
            
    
    博客分类: springcloudrabbitmq springcloud分布式队列busrabbitmq 
 

 

 

 

@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
            
    
    博客分类: springcloudrabbitmq springcloud分布式队列busrabbitmq springcloud 分布式队列  bus  rabbitmq
            
    
    博客分类: springcloudrabbitmq springcloud分布式队列busrabbitmq springcloud 分布式队列  bus  rabbitmq
            
    
    博客分类: springcloudrabbitmq springcloud分布式队列busrabbitmq 
 
 
 谢谢您的赞助,我会做的更好!

 

 

  • springcloud 分布式队列  bus  rabbitmq
            
    
    博客分类: springcloudrabbitmq springcloud分布式队列busrabbitmq 
  • 大小: 63.2 KB