org.apache.cassandra.config.DatabaseDescriptor.getBroadcastRpcAddress()方法的使用及代码示例

本文整理了Java中org.apache.cassandra.config.DatabaseDescriptor.getBroadcastRpcAddress()方法的一些代码示例，展示了DatabaseDescriptor.getBroadcastRpcAddress()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。DatabaseDescriptor.getBroadcastRpcAddress()方法的具体详情如下：
包路径：org.apache.cassandra.config.DatabaseDescriptor
类名称：DatabaseDescriptor
方法名：getBroadcastRpcAddress

DatabaseDescriptor.getBroadcastRpcAddress介绍

[英]May be null, please use FBUtilities#getBroadcastRpcAddress() instead.
[中]可能为空，请改用FBUtilities#getBroadcastRpcAddress（）。

代码示例

代码示例来源：origin: jsevellec/cassandra-unit

public static InetAddress getBroadcastRpcAddress()
{
if (broadcastRpcAddress == null)
broadcastRpcAddress = DatabaseDescriptor.getBroadcastRpcAddress() == null
? DatabaseDescriptor.getRpcAddress()
: DatabaseDescriptor.getBroadcastRpcAddress();
return broadcastRpcAddress;
}

代码示例来源：origin: org.apache.cassandra/cassandra-all

public static InetAddress getBroadcastRpcAddress()
{
if (broadcastRpcAddress == null)
broadcastRpcAddress = DatabaseDescriptor.getBroadcastRpcAddress() == null
? DatabaseDescriptor.getRpcAddress()
: DatabaseDescriptor.getBroadcastRpcAddress();
return broadcastRpcAddress;
}

代码示例来源：origin: com.strapdata.cassandra/cassandra-all

public static InetAddress getBroadcastRpcAddress()
{
if (broadcastRpcAddress == null)
broadcastRpcAddress = DatabaseDescriptor.getBroadcastRpcAddress() == null
? DatabaseDescriptor.getRpcAddress()
: DatabaseDescriptor.getBroadcastRpcAddress();
return broadcastRpcAddress;
}

代码示例来源：origin: com.netflix.sstableadaptor/sstable-adaptor-cassandra

public static InetAddress getBroadcastRpcAddress()
{
if (broadcastRpcAddress == null)
broadcastRpcAddress = DatabaseDescriptor.getBroadcastRpcAddress() == null
? DatabaseDescriptor.getRpcAddress()
: DatabaseDescriptor.getBroadcastRpcAddress();
return broadcastRpcAddress;
}

代码示例来源：origin: com.facebook.presto.cassandra/cassandra-server

private void send(InetAddress endpoint, Event.NodeEvent event)
{
// If the endpoint is not the local node, extract the node address
// and if it is the same as our own RPC broadcast address (which defaults to the rcp address)
// then don't send the notification. This covers the case of rpc_address set to "localhost",
// which is not useful to any driver and in fact may cauase serious problems to some drivers,
// see CASSANDRA-10052
if (!endpoint.equals(FBUtilities.getBroadcastAddress()) &&
event.nodeAddress().equals(DatabaseDescriptor.getBroadcastRpcAddress()))
return;
send(event);
}

代码示例来源：origin: org.apache.cassandra/cassandra-all

public Ec2MultiRegionSnitch() throws IOException, ConfigurationException
{
super();
InetAddress localPublicAddress = InetAddress.getByName(awsApiCall(PUBLIC_IP_QUERY_URL));
logger.info("EC2Snitch using publicIP as identifier: {}", localPublicAddress);
localPrivateAddress = awsApiCall(PRIVATE_IP_QUERY_URL);
// use the Public IP to broadcast Address to other nodes.
DatabaseDescriptor.setBroadcastAddress(localPublicAddress);
if (DatabaseDescriptor.getBroadcastRpcAddress() == null)
{
logger.info("broadcast_rpc_address unset, broadcasting public IP as rpc_address: {}", localPublicAddress);
DatabaseDescriptor.setBroadcastRpcAddress(localPublicAddress);
}
}

代码示例来源：origin: jsevellec/cassandra-unit

public Ec2MultiRegionSnitch() throws IOException, ConfigurationException
{
super();
InetAddress localPublicAddress = InetAddress.getByName(awsApiCall(PUBLIC_IP_QUERY_URL));
logger.info("EC2Snitch using publicIP as identifier: {}", localPublicAddress);
localPrivateAddress = awsApiCall(PRIVATE_IP_QUERY_URL);
// use the Public IP to broadcast Address to other nodes.
DatabaseDescriptor.setBroadcastAddress(localPublicAddress);
if (DatabaseDescriptor.getBroadcastRpcAddress() == null)
{
logger.info("broadcast_rpc_address unset, broadcasting public IP as rpc_address: {}", localPublicAddress);
DatabaseDescriptor.setBroadcastRpcAddress(localPublicAddress);
}
}

代码示例来源：origin: com.strapdata.cassandra/cassandra-all

public Ec2MultiRegionSnitch() throws IOException, ConfigurationException
{
super();
InetAddress localPublicAddress = InetAddress.getByName(awsApiCall(PUBLIC_IP_QUERY_URL));
logger.info("EC2Snitch using publicIP as identifier: {}", localPublicAddress);
localPrivateAddress = awsApiCall(PRIVATE_IP_QUERY_URL);
// use the Public IP to broadcast Address to other nodes.
DatabaseDescriptor.setBroadcastAddress(localPublicAddress);
if (DatabaseDescriptor.getBroadcastRpcAddress() == null)
{
logger.info("broadcast_rpc_address unset, broadcasting public IP as rpc_address: {}", localPublicAddress);
DatabaseDescriptor.setBroadcastRpcAddress(localPublicAddress);
}
}

代码示例来源：origin: com.facebook.presto.cassandra/cassandra-server

/**
* Return the rpc address associated with an endpoint as a string.
* @param endpoint The endpoint to get rpc address for
* @return the rpc address
*/
public String getRpcaddress(InetAddress endpoint)
{
if (endpoint.equals(FBUtilities.getBroadcastAddress()))
return DatabaseDescriptor.getBroadcastRpcAddress().getHostAddress();
else if (Gossiper.instance.getEndpointStateForEndpoint(endpoint).getApplicationState(ApplicationState.RPC_ADDRESS) == null)
return endpoint.getHostAddress();
else
return Gossiper.instance.getEndpointStateForEndpoint(endpoint).getApplicationState(ApplicationState.RPC_ADDRESS).value;
}

代码示例来源：origin: com.facebook.presto.cassandra/cassandra-server

appStates.put(ApplicationState.NET_VERSION, valueFactory.networkVersion());
appStates.put(ApplicationState.HOST_ID, valueFactory.hostId(localHostId));
appStates.put(ApplicationState.RPC_ADDRESS, valueFactory.rpcaddress(DatabaseDescriptor.getBroadcastRpcAddress()));
appStates.put(ApplicationState.RELEASE_VERSION, valueFactory.releaseVersion());
logger.info("Starting up server gossip");