文档简介：
连接实例化
ConnectionFactory factory = new ConnectionFactory();
// "guest"/"guest" by default, limited to localhost connections
factory.setUsername(userName);
factory.setPassword(password);
factory.setVirtualHost(virtualHost);
factory.setHost(hostName);
factory.setPort(portNumber);
Connection conn = factory.newConnection();
SSL连接实例化
//填写keycert密钥
char[] keyPassphrase = "rabbit".toCharArray();
KeyStore ks = KeyStore.getInstance("PKCS12");
//填写keycert密钥路径
ks.load(new FileInputStream("path\\to\\rabbit-client.keycert.p12"), keyPassphrase);
KeyManagerFactory kmf = KeyManagerFactory.getInstance("SunX509");
kmf.init(ks, keyPassphrase);
// 填写keystore密钥
char[] trustPassphrase = "rabbitstore".toCharArray();
KeyStore tks = KeyStore.getInstance("JKS");
// 填写keystore密钥路径
tks.load(new FileInputStream("path\\to \\rabbitstore"), trustPassphrase);
TrustManagerFactory tmf = TrustManagerFactory.getInstance("SunX509");
tmf.init(tks);
SSLContext c = SSLContext.getInstance("TLSv1.2");
c.init(kmf.getKeyManagers(), tmf.getTrustManagers(), null);
ConnectionFactory factory = new ConnectionFactory();
factory.setUsername(userName);
factory.setPassword(password);
factory.setVirtualHost(virtualHost);
factory.setHost(hostName);
factory.setPort(portNumber);
factory.useSslProtocol(c);
Connection connection = factory.newConnection();
Factory参数说明
|
setAutomaticRecoveryEnabled(boolean automaticRecovery) |
启用或禁用自动连接恢复。 |
|
setChannelRpcTimeout(int channelRpcTimeout) |
设置通道中RPC调用的继续超时。 |
|
setChannelShouldCheckRpcResponseType(boolean channelShouldCheckRpcResponseType) |
设置为true时，渠道将检查响应类型（例如 |
|
setClientProperties(Map<String,Object> clientProperties) |
替换将在后续连接启动期间发送到服务器的客户端属性表。 |
|
setConnectionRecoveryTriggeringCondition(Predicate<ShutdownSignalException> connectionRecoveryTriggeringCondition) |
允许决定是否触发自动连接恢复。 |
|
setConnectionTimeout(int timeout) |
设置TCP连接超时时间。 |
|
setCredentialsProvider(CredentialsProvider credentialsProvider) |
设置自定义凭据提供程序。 |
|
setErrorOnWriteListener(ErrorOnWriteListener errorOnWriteListener) |
设置连接在尝试写入套接字时出现IO错误时调用的侦听器。 |
|
setExceptionHandler(ExceptionHandler exceptionHandler) |
设置异常处理程序以用于新创建的连接。 |
|
setHandshakeTimeout(int timeout) |
设置AMQP0-9-1协议握手超时。 |
|
setHeartbeatExecutor(ScheduledExecutorService executor) |
设置执行程序以用于发送心跳帧。 |
|
|
|
|
setMetricsCollector(MetricsCollector metricsCollector) |
|
|
setNetworkRecoveryInterval(int networkRecoveryInterval) |
设置连接恢复间隔。 |
|
setNetworkRecoveryInterval(long networkRecoveryInterval) |
设置连接恢复间隔。 |
|
setNioParams(NioParams nioParams) |
使用NIO时设置参数。 |
|
setPassword(String password) |
设置密码。 |
|
setPort(int port) |
设置目标端口。 |
|
setRecoveryDelayHandler(RecoveryDelayHandler recoveryDelayHandler) |
设置自动连接恢复延迟处理程序。 |
|
setRequestedChannelMax(int requestedChannelMax) |
设置请求的最大频道数 |
|
setRequestedFrameMax(int requestedFrameMax) |
设置请求的最大帧大小 |
|
setRequestedHeartbeat(int requestedHeartbeat) |
设置请求的心跳超时。 |
|
setSaslConfig(SaslConfig saslConfig) |
设置要在验证时使用的sasl配置 |
|
setSharedExecutor(ExecutorService executor) |
将执行程序设置为默认情况下用于新创建连接的使用者操作调度。 |
|
setShutdownExecutor(ExecutorService executor) |
设置执行程序以用于连接关闭。 |
|
setShutdownTimeout(int shutdownTimeout) |
设置关机超时时间。 |
|
setSocketConfigurator(SocketConfigurator socketConfigurator) |
设置套接字配置器。 |
|
setSocketFactory(SocketFactory factory) |
设置用于创建新连接套接字的套接字工厂。 |
|
setSslContextFactory(SslContextFactory sslContextFactory) |
创建SSL上下文的工厂。 |
|
setThreadFactory(ThreadFactory threadFactory) |
设置用于实例化新线程的线程工厂。 |
|
setTopologyRecoveryEnabled(boolean topologyRecovery) |
启用或禁用拓扑恢复 |
|
setTopologyRecoveryExecutor(ExecutorService topologyRecoveryExecutor) |
设置执行程序以用于并行拓扑恢复。 |
|
setTopologyRecoveryFilter(TopologyRecoveryFilter topologyRecoveryFilter) |
将过滤器设置为在拓扑恢复中包括/排除实体。 |
|
setTopologyRecoveryRetryHandler(RetryHandler topologyRecoveryRetryHandler) |
设置重试处理程序以进行拓扑恢复。 |
|
setTrafficListener(TrafficListener trafficListener) |
流量侦听器已通知入站和出站Command。 |
|
设置AMQP URI中的字段的便捷方法：主机，端口，用户名，密码和虚拟主机。 |
|
|
设置AMQP URI中的字段的便捷方法：主机，端口，用户名，密码和虚拟主机。 |
|
|
setUsername(String username) |
设置用户名。 |
|
setVirtualHost(String virtualHost) |
设置虚拟主机。 |
|
setWorkPoolTimeout(int workPoolTimeout) |
工作池排队的超时时间（以毫秒为单位）。 |
|
使用阻塞IO与服务器进行通信。 |
|
|
useNio() |
使用非阻塞IO（NIO）与服务器进行通信。 |
|
使用默认的TLS协议集和信任的TrustManager配置TLS的便捷方法。 |
|
|
useSslProtocol(String protocol) |
使用提供的协议和非常信任的TrustManager来配置TLS的便捷方法。 |
|
useSslProtocol(String protocol, TrustManager trustManager) |
配置TLS的便捷方法。 |
|
useSslProtocol(SSLContext context) |
使用初始化设置TLS SSLContext。 |
