`
terryfeng
  • 浏览: 503983 次
  • 性别: Icon_minigender_1
  • 来自: 北京
社区版块
存档分类
最新评论

RabbitMQ 安装配置和简单实例

阅读更多

安装ErLang运行环境

image

配置运行环境变量

image

启动服务

地址在:complete-rabbitmq-bundle-1.7.0\rabbitmq-server-windows-1.7.0\rabbitmq_server-1.7.0\sbin

image

image

一段实例代码

 

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Windows.Forms;
using RabbitMQ.Client;

namespace rabbits
{
    public partial class Form1 : Form
    {
        public Form1()
        {
            InitializeComponent();
        }
        IConnection conn;
        IModel channel;
        private void button1_Click(object sender, EventArgs e)
        {
            conn = new ConnectionFactory().CreateConnection(Protocols.DefaultProtocol, this.textBox1.Text);
            channel = conn.CreateModel();
            channel.ExchangeDeclare(this.textBox2.Text, ExchangeType.Direct);
            channel.QueueDeclare(this.textBox3.Text);
            channel.QueueBind(this.textBox3.Text, this.textBox2.Text, "", false, null);

        }

        private void button2_Click(object sender, EventArgs e)
        {
            byte[] message = System.Text.Encoding.UTF8.GetBytes(this.richTextBox1.Text);
            IBasicProperties props = channel.CreateBasicProperties();
            props.ContentType = "text/plain";
            props.DeliveryMode = 2;

            channel.BasicPublish(this.textBox2.Text, "", props, message);

        }

        private void button3_Click(object sender, EventArgs e)
        {
            bool noask = false;
            BasicGetResult result = channel.BasicGet(this.textBox3.Text, noask);
            if (result == null)
            {
                
            }
            else
            {
                IBasicProperties props = result.BasicProperties;
                byte[] body = result.Body;
                this.richTextBox2.Text = System.Text.Encoding.UTF8.GetString(body);
                channel.BasicAck(result.DeliveryTag, false);
                    
            }
        }

        private void Form1_FormClosing(object sender, FormClosingEventArgs e)
        {
            if (this.channel != null && this.channel.IsOpen)
            {
                this.channel.Dispose();
            }
            if (this.conn != null && this.conn.IsOpen)
            {
                this.conn.Dispose();
            }
        }

        
    }
}

分享到:
评论
1 楼 luedipiaofeng 2010-11-02  
很有帮助的 

相关推荐

    Django+celery+rabbitmq配置文档

    ### Django+Celery+RabbitMQ配置文档 #### 一、环境搭建与配置 ##### 1.1 系统环境 - **操作系统**: Ubuntu 14.04 - **开发工具**: PyCharm 5.0 - **虚拟环境**: 使用虚拟环境隔离项目依赖,避免环境冲突。 #####...

    android上RabbitMQ发送简单例子

    在本例中,我们将探讨如何在Android上设置和使用RabbitMQ,以及如何创建一个简单的测试Demo。 首先,我们关注的是"rabbitmq windows服务器安装 文档 - 副本.doc",这是一个关于在Windows环境下安装RabbitMQ的指南。...

    rabbitmq简单java实例

    这个简单的Java实例展示了RabbitMQ的基本用法,包括创建连接、声明队列、发送和接收消息。在实际应用中,可能需要处理更多复杂情况,如错误处理、确认机制、持久化等。通过深入了解RabbitMQ的特性,你可以更好地利用...

    RabbitMQ配置及其使用(java)

    1. 引言 在软件开发中,消息队列(Message Queue,MQ)扮演着重要的角色,它通过引入异步处理机制,提升了系统的响应速度和整体吞吐量。...正确配置和使用RabbitMQ,能够有效优化系统架构,提高系统的稳定性和效率。

    RabbitMq与Spring整合实例

    这个实例展示了如何在Spring应用中使用RabbitMQ进行简单的消息通信。实际上,RabbitMQ和Spring整合后,你可以实现更复杂的消息模式,如工作队列、发布/订阅、延迟消息等,以满足不同场景的需求。同时,RabbitMQ还...

    Java工程师RabbitMQ安装指南

    对于Mac OS环境,安装RabbitMQ相对简单,通过Homebrew工具可以轻松完成: 1. **更新Homebrew**: ``` brew update ``` 2. **安装RabbitMQ**: ``` brew install rabbitmq ``` 3. **启动RabbitMQ**: ``` ...

    Java使用RabbitMq的一个简单demo

    这个例子展示了RabbitMQ的基本用法,实际应用中可以根据需求设置更复杂的路由规则、交换机类型和队列属性。 总之,RabbitMQ作为消息中间件,能有效地解耦应用程序,提高系统的可扩展性和容错性。Java开发者可以通过...

    RabbitMQ实战指南-rabbitmq-action.zip

    RabbitMQ通过实现AMQP,使得跨语言和平台的通信变得简单。 3. **节点与集群**: RabbitMQ运行在称为节点的服务器上,可以单独运行,也可以组成集群以提高可用性和扩展性。 4. **虚拟主机**: 虚拟主机是RabbitMQ中的...

    spring amqp 配置实现rabbitmq 路由

    Spring AMQP提供了一组API和抽象,使得在Spring应用中配置和使用RabbitMQ变得简单。要配置RabbitMQ路由,我们需要理解两个核心概念:Exchange和Queue。 1. **Exchange**:交换机是RabbitMQ中的核心组件,它的作用是...

    SpringBoot+redis+RabbitMq整合实例

    在IT行业中,Spring Boot、Redis和RabbitMQ是三个非常重要的技术组件,它们分别用于简化Java应用程序开发、数据缓存和消息队列处理。本文将详细介绍如何将这三者整合在一起,以构建一个高效、可扩展的应用系统。 ...

    rabbitmq(java实例)

    可以通过官方网站下载RabbitMQ并按照指南进行安装和启动。 总的来说,RabbitMQ提供了一个强大且灵活的平台,可以有效地处理分布式系统的通信问题。结合Java和Maven,我们可以轻松地在Eclipse中构建可靠的、可扩展的...

    rabbitmq+java简单例子

    ### rabbitmq+java简单例子知识点解析 #### 一、RabbitMQ简介 RabbitMQ 是一个开源的消息代理软件,它支持多种消息协议,包括 AMQP(Advanced Message Queuing Protocol)。RabbitMQ 可以帮助开发者在分布式系统...

    【学习资源】rabbitmq实例代码

    在学习这个例子时,你可以了解到如何配置RabbitMQ的连接参数,创建生产者和消费者,以及理解消息的发送和接收流程。这通常涉及到RabbitMQ的API调用,如创建通道(Channel)、声明交换机(Exchange)和队列(Queue)...

    RabbitMQ消费者和生产者简单实现

    为了运行这些示例,你需要确保本地已经安装并运行了RabbitMQ服务器,并且你的Java应用能正确配置连接参数。文件名`RabbitMQTest`可能包含了这些示例代码的完整实现,或者是一个测试脚本,用于启动和测试生产者和消费...

    rabbitmq.net 各种实例

    RabbitMQ 是一个开源的消息队列系统,基于 AMQP(Advanced Message Queuing Protocol)协议实现,广泛用于...通过实例学习和实践,我们可以灵活地利用RabbitMQ解决各种消息通信问题,提高系统的可靠性和可扩展性。

    rabbitMQ 死信队列 完整例子

    接下来,我们将通过一个简单的Java示例来演示如何配置和使用RabbitMQ的死信队列。 1. **创建基本队列与交换机** 在这个例子中,我们首先需要创建一个普通队列和交换机。队列是消息的接收者,而交换机负责将消息...

    RebbitMQ Hello World(maven项目+RebbitMQ jar包+RabbitMQ安装文件)

    这个简单的例子展示了如何使用RabbitMQ进行基本的发送和接收消息操作。 **总结** RebbitMQ Hello World项目结合了Maven和RabbitMQ 3.6.6版本的jar包,为初学者提供了一个快速上手的起点。通过这个项目,你可以学习...

    rabbitmq-demo学习实例

    在这个“rabbitmq-demo学习实例”中,我们将探讨RabbitMQ的核心概念,包括交换机类型和与Spring框架的集成。 首先,让我们深入了解RabbitMQ中的交换机(Exchange)。交换机是RabbitMQ中的关键组件,它负责接收生产...

    rabbitMQ的配置

    在这个配置指南中,我们将深入探讨如何配置RabbitMQ的生产端和消费端,以及如何实现消息的延时发送。 首先,我们需要在本地或服务器上安装RabbitMQ。这通常包括下载RabbitMQ服务器,安装并启动服务。在Ubuntu系统中...

Global site tag (gtag.js) - Google Analytics