org.eclipse.californium.core.network.Endpoint.getAddress()方法的使用及代码示例

x33g5p2x  于2022-01-19 转载在 其他  
字(8.9k)|赞(0)|评价(0)|浏览(142)

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

Endpoint.getAddress介绍

[英]Gets the address this endpoint is associated with.
[中]获取与此终结点关联的地址。

代码示例

代码示例来源：origin: eclipse/hono

  1. @Override
  2. protected final int getActualPort() {
  3.   int port = Constants.PORT_UNCONFIGURED;
  4.   final Endpoint endpoint = secureEndpoint;
  5.   if (endpoint != null) {
  6.     port = endpoint.getAddress().getPort();
  7.   }
  8.   return port;
  9. }

代码示例来源：origin: eclipse/hono

  1. @Override
  2. protected final int getActualInsecurePort() {
  3.   int port = Constants.PORT_UNCONFIGURED;
  4.   final Endpoint endpoint = insecureEndpoint;
  5.   if (endpoint != null) {
  6.     port = endpoint.getAddress().getPort();
  7.   }
  8.   return port;
  9. }

代码示例来源：origin: eclipse/californium

  1. /**
  2.  * Returns the endpoint with a specific socket address.
  3.  * @param address the socket address
  4.  * @return the endpoint 
  5.  */
  6. @Override
  7. public Endpoint getEndpoint(InetSocketAddress address) {
  8.   Endpoint endpoint = null;
  9.   for (Endpoint ep : endpoints) {
  10.     if (ep.getAddress().equals(address)) {
  11.       endpoint = ep;
  12.       break;
  13.     }
  14.   }
  15.   return endpoint;
  16. }

代码示例来源：origin: eclipse/californium

  1. /**
  2.  * Returns the endpoint with a specific port.
  3.  * @param port the port
  4.  * @return the endpoint 
  5.  */
  6. @Override
  7. public Endpoint getEndpoint(int port) {
  8.   Endpoint endpoint = null;
  9.   for (Endpoint ep : endpoints) {
  10.     if (ep.getAddress().getPort() == port) {
  11.       endpoint = ep;
  12.     }
  13.   }
  14.   return endpoint;
  15. }

代码示例来源：origin: org.eclipse.californium/californium-core

  1. /**
  2.  * Returns the endpoint with a specific socket address.
  3.  * @param address the socket address
  4.  * @return the endpoint 
  5.  */
  6. @Override
  7. public Endpoint getEndpoint(InetSocketAddress address) {
  8.   Endpoint endpoint = null;
  9.   for (Endpoint ep : endpoints) {
  10.     if (ep.getAddress().equals(address)) {
  11.       endpoint = ep;
  12.       break;
  13.     }
  14.   }
  15.   return endpoint;
  16. }

代码示例来源：origin: org.eclipse.californium/californium-core

  1. /**
  2.  * Returns the endpoint with a specific port.
  3.  * @param port the port
  4.  * @return the endpoint 
  5.  */
  6. @Override
  7. public Endpoint getEndpoint(int port) {
  8.   Endpoint endpoint = null;
  9.   for (Endpoint ep : endpoints) {
  10.     if (ep.getAddress().getPort() == port) {
  11.       endpoint = ep;
  12.     }
  13.   }
  14.   return endpoint;
  15. }

代码示例来源：origin: eclipse/leshan

  1. public InetSocketAddress getAddress() {
  2.   return endpointsManager.getEndpoint(null).getAddress();
  3. }

代码示例来源：origin: eclipse/californium

  1. private synchronized void createDefaultEndpoint() {
  2.   if (default_endpoint != null)
  3.     return;
  4.   default_endpoint = new CoapEndpoint();
  5.   try {
  6.     default_endpoint.start();
  7.     LOGGER.log(Level.INFO, "Created implicit default endpoint {0}", default_endpoint.getAddress());
  8.   } catch (IOException e) {
  9.     LOGGER.log(Level.SEVERE, "Could not create default endpoint", e);
  10.   }
  11. }

代码示例来源：origin: org.eclipse.californium/californium-core

  1. private synchronized void createDefaultEndpoint() {
  2.   if (default_endpoint != null) return;
  3.   
  4.   default_endpoint = new CoapEndpoint();
  5.   
  6.   try {
  7.     default_endpoint.start();
  8.     LOGGER.log(Level.INFO, "Created implicit default endpoint " + default_endpoint.getAddress());
  9.   } catch (IOException e) {
  10.     LOGGER.log(Level.SEVERE, "Could not create default endpoint", e);
  11.   }
  12. }

代码示例来源：origin: eclipse/californium

  1. /**
  2.  * Creates a URI string for a resource hosted on an endpoint.
  3.  * 
  4.  * @param endpoint The endpoint the resource is hosted on.
  5.  * @param path The path of the resource on the endpoint.
  6.  * @return The URI string.
  7.  */
  8. public static String getUri(final Endpoint endpoint, final String path) {
  9.   return getUri(endpoint.getAddress(), path);
  10. }

代码示例来源：origin: eclipse/leshan

  1. @Override
  2.   public T buildResponse(Response coapResponse) {
  3.     // TODO we need to fix that by removing the Client dependency from LwM2MResponseBuilder or by creating a
  4.     // LwM2mBootstrapResponseBuilder
  5.     Registration registration = new Registration.Builder("fakeregistrationid", endpointName, destination,
  6.         destination.isSecure() ? secureEndpoint.getAddress() : nonSecureEndpoint.getAddress()).build();
  7.     // Build LwM2m response
  8.     LwM2mResponseBuilder<T> lwm2mResponseBuilder = new LwM2mResponseBuilder<>(coapRequest, coapResponse,
  9.         registration, model, null, decoder);
  10.     request.accept(lwm2mResponseBuilder);
  11.     return lwm2mResponseBuilder.getResponse();
  12.   }
  13. };

代码示例来源：origin: eclipse/leshan

  1. @Override
  2.   public T buildResponse(Response coapResponse) {
  3.     // TODO we need to fix that by removing the Client dependency from LwM2MResponseBuilder or by creating a
  4.     // LwM2mBootstrapResponseBuilder
  5.     Registration registration = new Registration.Builder("fakeregistrationid", endpointName, destination,
  6.         destination.isSecure() ? secureEndpoint.getAddress() : nonSecureEndpoint.getAddress()).build();
  7.     // Build LwM2m response
  8.     LwM2mResponseBuilder<T> lwm2mResponseBuilder = new LwM2mResponseBuilder<>(coapRequest, coapResponse,
  9.         registration, model, null, decoder);
  10.     request.accept(lwm2mResponseBuilder);
  11.     return lwm2mResponseBuilder.getResponse();
  12.   }
  13. };

代码示例来源：origin: eclipse/californium

  1. @Before
  2. public void setupEndpoints() throws Exception {
  3.   client = new CoapEndpoint(new InetSocketAddress(InetAddress.getLoopbackAddress(), 0), config);
  4.   client.addInterceptor(clientInterceptor);
  5.   client.start();
  6.   System.out.println("Client binds to port " + client.getAddress().getPort());
  7.   server = createLockstepEndpoint(client.getAddress());
  8. }

代码示例来源：origin: eclipse/californium

  1. private synchronized void createTcpEndpoint() {
  2.   if (default_tcp_endpoint != null)
  3.     return;
  4.   NetworkConfig config = NetworkConfig.getStandard();
  5.   TcpClientConnector connector = new TcpClientConnector(config.getInt(NetworkConfig.Keys.TCP_WORKER_THREADS),
  6.       config.getInt(NetworkConfig.Keys.TCP_CONNECT_TIMEOUT),
  7.       config.getInt(NetworkConfig.Keys.TCP_CONNECTION_IDLE_TIMEOUT));
  8.   default_tcp_endpoint = new CoapEndpoint(connector, config);
  9.   try {
  10.     default_tcp_endpoint.start();
  11.     LOGGER.log(Level.INFO, "Created implicit tcp endpoint {0}", default_tcp_endpoint.getAddress());
  12.   } catch (IOException e) {
  13.     LOGGER.log(Level.SEVERE, "Could not create tcp endpoint", e);
  14.   }
  15. }

代码示例来源：origin: eclipse/californium

  1. private synchronized void createSecureTcpEndpoint() {
  2.   if (default_secure_tpc_endpoint != null)
  3.     return;
  4.   NetworkConfig config = NetworkConfig.getStandard();
  5.   TlsClientConnector connector = new TlsClientConnector(config.getInt(NetworkConfig.Keys.TCP_WORKER_THREADS),
  6.       config.getInt(NetworkConfig.Keys.TCP_CONNECT_TIMEOUT),
  7.       config.getInt(NetworkConfig.Keys.TCP_CONNECTION_IDLE_TIMEOUT));
  8.   default_secure_tpc_endpoint = new CoapEndpoint(connector, config);
  9.   try {
  10.     default_secure_tpc_endpoint.start();
  11.     LOGGER.log(Level.INFO, "Created implicit secure tcp endpoint {0}",
  12.         default_secure_tpc_endpoint.getAddress());
  13.   } catch (IOException e) {
  14.     LOGGER.log(Level.SEVERE, "Could not create secure tcp endpoint", e);
  15.   }
  16. }

代码示例来源：origin: eclipse/californium

  1. @Before
  2. public void setupEndpoints() throws Exception {
  3.   //exchangeStore = new InMemoryMessageExchangeStore(CONFIG, new InMemoryRandomTokenProvider(CONFIG));
  4.   // bind to loopback address using an ephemeral port
  5. //	CoapEndpoint udpEndpoint = new CoapEndpoint(new InetSocketAddress(InetAddress.getLoopbackAddress(), 0), CONFIG, exchangeStore);
  6.   client = new CoapEndpoint(new InetSocketAddress(InetAddress.getLoopbackAddress(), 0), CONFIG);
  7.   client.addInterceptor(clientInterceptor);
  8.   client.addInterceptor(new MessageTracer());
  9.   client.start();
  10.   System.out.println("Client binds to port " + client.getAddress().getPort());
  11.   server = createLockstepEndpoint(client.getAddress());
  12. }

代码示例来源：origin: eclipse/californium

  1. @BeforeClass
  2. public static void startupServer() {
  3.   network.getStandardTestConfig().setLong(NetworkConfig.Keys.MAX_TRANSMIT_WAIT, 100);
  4.   createServer();
  5.   System.out.println(System.lineSeparator() + "Start " + ClientSynchronousTest.class.getSimpleName() +
  6.       " on " + serverEndpoint.getAddress());
  7. }

代码示例来源：origin: eclipse/californium

  1. private static void createServer() {
  2.   serverEndpoint = new CoapEndpoint(new InetSocketAddress(InetAddress.getLoopbackAddress(), 0));
  3.   resource = new StorageResource(TARGET, CONTENT_1);
  4.   server = new CoapServer();
  5.   server.add(resource);
  6.   server.addEndpoint(serverEndpoint);
  7.   server.start();
  8.   serverPort = serverEndpoint.getAddress().getPort();
  9. }

代码示例来源：origin: eclipse/californium

  1. @Before
  2. public void setupServer() throws Exception {
  3.   System.out.println(System.lineSeparator() + "Start " + getClass().getSimpleName());
  4.   NetworkConfig config = network.createTestConfig()
  5.     .setInt(NetworkConfig.Keys.MAX_MESSAGE_SIZE, 128)
  6.     .setInt(NetworkConfig.Keys.PREFERRED_BLOCK_SIZE, 128)
  7.     .setInt(NetworkConfig.Keys.ACK_TIMEOUT, 200) // client retransmits after 200 ms
  8.     .setInt(NetworkConfig.Keys.ACK_RANDOM_FACTOR, 1);
  9.   client = new CoapEndpoint(new InetSocketAddress(InetAddress.getLoopbackAddress(), 0), config);
  10.   client.addInterceptor(new MessageTracer());
  11.   client.start();
  12.   clientPort = client.getAddress().getPort();
  13.   server = createLockstepEndpoint(client.getAddress());
  14.   System.out.println("Client binds to port " + clientPort);
  15. }

代码示例来源：origin: eclipse/californium

  1. @Before
  2. public void setupEndpoints() throws Exception {
  3.   testResource = new TestResource("test");
  4.   exchangeStore = new InMemoryMessageExchangeStore(CONFIG);
  5.   // bind to loopback address using an ephemeral port
  6.   CoapEndpoint udpEndpoint = new CoapEndpoint(new InetSocketAddress(InetAddress.getLoopbackAddress(), 0), CONFIG, exchangeStore);
  7.   server = new CoapServer();
  8.   server.addEndpoint(udpEndpoint);
  9.   server.add(testResource);
  10.   server.getEndpoints().get(0).addInterceptor(serverInterceptor);
  11.   server.start();
  12.   InetSocketAddress serverAddress = server.getEndpoints().get(0).getAddress();
  13.   System.out.println("Server binds to port " + serverAddress.getPort());
  14.   client = createLockstepEndpoint(serverAddress);
  15. }

内容来源于网络，如有侵权，请联系作者删除！

Endpoint

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com