Java连接RabbitMQ之创建连接

依赖包:

 1 <dependencies>
 2     <dependency>
 3       <groupId>junit</groupId>
 4       <artifactId>junit</artifactId>
 5       <version>4.12</version>
 6       <scope>test</scope>
 7     </dependency>
 8
 9     <!-- https://mvnrepository.com/artifact/com.rabbitmq/amqp-client -->
10     <dependency>
11       <groupId>com.rabbitmq</groupId>
12       <artifactId>amqp-client</artifactId>
13       <version>5.1.2</version>
14     </dependency>
15     <!-- https://mvnrepository.com/artifact/org.slf4j/slf4j-nop -->
16     <dependency>
17       <groupId>org.slf4j</groupId>
18       <artifactId>slf4j-nop</artifactId>
19       <version>1.7.25</version>
20     </dependency>
21
22   </dependencies>

源码:

 1 package org.study.utils;
 2
 3 import com.rabbitmq.client.Connection;
 4 import com.rabbitmq.client.ConnectionFactory;
 5
 6 import java.io.IOException;
 7 import java.util.concurrent.TimeoutException;
 8
 9 /**
10  * 获取rabbitmq连接
11  */
12 public class ConnectionUtils {
13     public static Connection getConnection() throws IOException, TimeoutException {
14         ConnectionFactory factory = new ConnectionFactory();
15         factory.setHost("10.15.1.26");
16         factory.setPort(5672);
17         factory.setVirtualHost("/test_host");
18         factory.setUsername("admin");
19         factory.setPassword("admin");
20         Connection connection = factory.newConnection();
21         return connection;
22     }
23 }

原文地址:https://www.cnblogs.com/gongxr/p/9639489.html

时间: 2024-11-07 21:19:27

Java连接RabbitMQ之创建连接的相关文章

Java中通过方法创建一个http连接并请求

1.Java代码创建一个连接并请求该连接返回的数据 doGet()方法,execute()方法中调用 package demo2.x.com; import java.io.BufferedReader; import java.io.InputStream; import java.io.InputStreamReader; import java.net.HttpURLConnection; import java.net.URL; import javax.print.attribute.

javax.transaction.xa.XAException: java.sql.SQLException: 无法创建 XA 控制连接。(SQL 2000,SQL2005,SQL2008)

javax.transaction.xa.XAException: java.sql.SQLException:无法创建 XA 控制连接.错误: 未能找到存储过程'master..xp_sqljdbc_xa_init'. 配置JTA  SQL Server XADataSource参考:http://technet.microsoft.com/zh-cn/library/aa342335.aspx 来源:http://blog.csdn.net/gjf8510/article/details/1

Java创建连接池连接不同数据库

在一个应用里面,可能涉及到连接多个不同数据库进行操作,而每次连接写不同的实现会很麻烦.前面已经会了用JDBC连接数据库,那么利用反射和工厂模式,可以实现连接不同的数据库,这样处理起来将会很方便.同时建造数据库连接池,处理多个业务数据处理. 那么具体怎么实现呢,下面一起来看一下: 整体结构如下: 第一步,先处理连接不同数据库 1.首先,将数据库配置信息创建一个公用类:JdbcUrl.java 主数据库可以用默认的构造方法,如果是连接其他库,则通过传递参数的方式来处理. 数据库参数有如下几个: 1

RabbitMQ学习第一记:用java连接RabbitMQ

1.什么是RabbitMQ MQ(Message Queue):消息队列,是服务端设计的一个可以存储大量消息的队列,并提供客户端操作队列的方法:生产队列(向队列中添加数据).消费队列(从队列中取数据).RabbitMQ就是基于消息队列的一个典型应用.RabbitMQ除了普通的生产消费功能,还有一些高级功能:公平分发 ,轮询分发,路由模式,通配符模式,发布订阅,队列持久化. 2.java实现RabbitMQ的连接 2.1.RabbitMQ客户端jar包 <dependency><group

java下tcp的socket连接案例

package cn.stat.p4.ipdemo; import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader; import java.io.PrintWriter; import java.net.ServerSocket; import java.net.Socket; public class serverDemo { /** * @param args * @t

java下tcp的socket连接

serverDemo package cn.stat.p4.ipdemo; import java.io.IOException; import java.io.InputStream; import java.io.OutputStream; import java.net.ServerSocket; import java.net.Socket; public class serverDemo { /** * @param args * @throws IOException */ publ

使用代理创建连接池 proxyPool

配置文件properties 1 url=jdbc:mysql://127.0.0.1:3306/mine?characterEncoding=UTF-8 2 user=root 3 password=1234 4 driverClass=com.mysql.jdbc.Driver 主要代码 1 package JDBCUtils; 2 3 import java.io.IOException; 4 import java.io.InputStream; 5 import java.lang.r

Mondiran创建连接

以前使用jdbc创建连接的时候使用的url是这样的形式:jdbc:mysql://hostname:port/database?key1=value1&key2=value2,在URL需要以"jabc:mysql"开头的,其中需要声明数据库服务器的地址和端口.数据库名还有一些其它的属性,以"?"分割,每一个属性使用"&"字符分割,但是mondrian作为OLAP服务器和mysql这类的关系型数据库还是有所区别的,毕竟它本身不保存任

spring创建连接池的几种方式

spring使用连接池有很多种方式,jdbc(不使用连接池),c3p0,dbcp,jndi,下面将分别贴代码介绍这几种:  1.jdbc方式 使用的是DriverManagerDataSource,DriverManagerDataSource建立连接是只要有连接就新建一个connection,  根本没有连接池的作用 <bean id="dataSource" class="org.springframework.jdbc.datasource.DriverManag