RabbitMQ之（2）发送端

喜欢ヅ旅行 2021-09-28 03:48 188阅读 0赞

package rabbitmq;
    
    import java.io.IOException;
    
    import org.apache.log4j.LogManager;
    import org.apache.log4j.Logger;
    
    import com.rabbitmq.client.MessageProperties;
    /**
     * @ClassName: RabbitMQSend 
     * @Description: RabbitMQ发送端
     * @author wxy 
     * @date 2019年1月24日 下午1:30:33 
     */
    public class RabbitMQSend extends RabbitMQConnection{
    	private static final Logger LOG = LogManager.getLogger(RabbitMQSend.class);
    
    	public RabbitMQSend() {
    		super();
    	}
    
    	public RabbitMQSend(String rabbitmq_url, int rabbitmq_port, String userName, String password,
    			String rabbit_queue_name) {
    		super(rabbitmq_url, rabbitmq_port, userName, password, rabbit_queue_name);
    	}
    	
    	public void sendMessage(String message) {
    		initConnection();
    		try {
    			LOG.info("发送消息：" + message);
    			LOG.info("队列标识：" + rabbit_queue_name);
    			channel.basicPublish("", rabbit_queue_name, MessageProperties.PERSISTENT_TEXT_PLAIN, message.getBytes());
    		} catch (Exception e) {
    			LOG.error(e);
    			this.close();
    			try {
    				getChannel().basicPublish("", rabbit_queue_name, MessageProperties.PERSISTENT_TEXT_PLAIN, message.getBytes());
    			} catch (IOException e1) {
    				LOG.error(e);
    			}
    		}
    	}
    	
    	public static void main(String[] args) {
    		RabbitMQSend send = new RabbitMQSend();
    		LOG.info("开始发送消息：");
    		send.sendMessage("hello");
    	}
    	
    }

发表评论取消回复

表情：

评论列表（有 0 条评论，188人围观）

还没有评论，来说两句吧...

相关阅读

相关【RabbitMQ笔记（五）】之RabbitMQ发送消息与接受消息的可靠性

本文章由公号【开发小鸽】发布！欢迎关注！！！老规矩–妹妹镇楼： ![20200721223424816.JPG][] 一． Rabbitmq发送消息的可

雨点打透心脏的1/2处/ 2023年10月07日 15:05/ 0 赞/ 69 阅读

相关 2.1.2 客户端消息发送线程

-------------------- 2.1.2 客户端消息发送线程 > 追加消息到记录收集器时按照分区进行分组，并放到 batches集合中，每个分区的队列都保存

╰半夏微凉°/ 2023年01月12日 15:53/ 0 赞/ 54 阅读

相关 c# RabbitMQ 发送消息

参考地址：《[C\使用RabbitMQ][C_RabbitMQ]》 C\操作RabbitMQ需要引用RabbitMQ的DLL，地址是：[http://www.rabbitmq

傷城~/ 2022年10月02日 15:59/ 0 赞/ 210 阅读

相关 RabbitMQ：RabbitMQ+Sping整合发送异步消息

> RabbitMQ：RabbitMQ+Sping整合发送异步消息（一） XML配置方式： 1.【配置文件】： application-async.xml

痛定思痛。/ 2022年05月18日 01:10/ 0 赞/ 287 阅读

相关 RabbitMQ：Spring + RabbitMQ整合发送同步消息

> RabbitMQ：Spring + RabbitMQ整合发送同步消息注：[RabbitMQ系列代码实例github地址][RabbitMQ_github]

朴灿烈づ我的快乐病毒、/ 2022年05月18日 00:41/ 0 赞/ 295 阅读

相关 springboot2之邮件发送

一.引言本文会实现以下几个功能,具体的demo请参考github项目地址[链接][Link 1] 发送文本邮件发送HTML邮件

叁歲伎倆/ 2022年04月08日 09:50/ 0 赞/ 383 阅读

相关 013 RabbitMQ消息发送

1.发送 @Component public class MqSenderTest extends OrderApplicationTests {

ゝ一纸荒年。/ 2022年03月09日 10:58/ 0 赞/ 265 阅读

相关【RabbitMq 篇二】-RabbitMq 发送与消费

前言本文介绍RabbitMq各个消息类型，以及用使用Fanout 类型进行消息的发送和消费，让大家对RabbitMq有一个简单的认识。正文使用所

╰+攻爆jí腚メ/ 2022年01月14日 12:17/ 0 赞/ 451 阅读

相关 RabbitMQ之（3）接收端

package rabbitmq; import org.apache.log4j.LogManager; import org.apache

逃离我推掉我的手/ 2021年09月28日 03:50/ 0 赞/ 179 阅读

相关 RabbitMQ之（2）发送端

package rabbitmq; import java.io.IOException; import org.apache.lo

喜欢ヅ旅行/ 2021年09月28日 03:48/ 0 赞/ 189 阅读