• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    迪恩网络公众号

Java HttpHosts类代码示例

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

本文整理汇总了Java中com.twitter.hbc.core.HttpHosts的典型用法代码示例。如果您正苦于以下问题:Java HttpHosts类的具体用法?Java HttpHosts怎么用?Java HttpHosts使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。



HttpHosts类属于com.twitter.hbc.core包,在下文中一共展示了HttpHosts类的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: configureStreamClient

import com.twitter.hbc.core.HttpHosts; //导入依赖的package包/类
private static BasicClient configureStreamClient(BlockingQueue<String> msgQueue, String twitterKeys, List<Long> userIds, List<String> terms) {
    Hosts hosts = new HttpHosts(Constants.STREAM_HOST);
    StatusesFilterEndpoint endpoint = new StatusesFilterEndpoint()
            .followings(userIds)
            .trackTerms(terms);
    endpoint.stallWarnings(false);

    String[] keys = twitterKeys.split(":");
    Authentication auth = new OAuth1(keys[0], keys[1], keys[2], keys[3]);

    ClientBuilder builder = new ClientBuilder()
            .name("Neo4j-Twitter-Stream")
            .hosts(hosts)
            .authentication(auth)
            .endpoint(endpoint)
            .processor(new StringDelimitedProcessor(msgQueue));

    return builder.build();
}
 
开发者ID:neo4j-examples,项目名称:neo4j-twitter-stream,代码行数:20,代码来源:TwitterStreamProcessor.java


示例2: getTwitterClient

import com.twitter.hbc.core.HttpHosts; //导入依赖的package包/类
private  Client getTwitterClient(Properties props, BlockingQueue<String> messageQueue) {

        String clientName = props.getProperty("clientName");
        String consumerKey = props.getProperty("consumerKey");
        String consumerSecret = props.getProperty("consumerSecret");
        String token = props.getProperty("token");
        String tokenSecret = props.getProperty("tokenSecret");
        List<String> searchTerms = Arrays.asList(props.getProperty("searchTerms").split(","));

        Authentication authentication = new OAuth1(consumerKey,consumerSecret,token,tokenSecret);
        Hosts hosebirdHosts = new HttpHosts(Constants.STREAM_HOST);
        StatusesFilterEndpoint hosebirdEndpoint = new StatusesFilterEndpoint();

        hosebirdEndpoint.trackTerms(searchTerms);

        ClientBuilder clientBuilder = new ClientBuilder();
        clientBuilder.name(clientName)
                .hosts(hosebirdHosts)
                .authentication(authentication)
                .endpoint(hosebirdEndpoint)
                .processor(new StringDelimitedProcessor(messageQueue));

          return clientBuilder.build();

    }
 
开发者ID:bbejeck,项目名称:kafka-streams,代码行数:26,代码来源:TwitterDataSource.java


示例3: testStatusesFilterEndpointOAuth1

import com.twitter.hbc.core.HttpHosts; //导入依赖的package包/类
/**
 * @throws Exception Test exception.
 */
public void testStatusesFilterEndpointOAuth1() throws Exception {
    try (IgniteDataStreamer<Long, String> dataStreamer = grid().dataStreamer(DEFAULT_CACHE_NAME)) {
        TwitterStreamerImpl streamer = newStreamerInstance(dataStreamer);

        Map<String, String> params = new HashMap<>();

        params.put("track", "apache, twitter");
        params.put("follow", "3004445758");// @ApacheIgnite id.

        streamer.setApiParams(params);
        streamer.setEndpointUrl(MOCK_TWEET_PATH);
        streamer.setHosts(new HttpHosts("http://localhost:8080"));
        streamer.setThreadsCount(8);

        executeStreamer(streamer);
    }
}
 
开发者ID:apache,项目名称:ignite,代码行数:21,代码来源:IgniteTwitterStreamerTest.java


示例4: setupHosebirdClient

import com.twitter.hbc.core.HttpHosts; //导入依赖的package包/类
public static void setupHosebirdClient() {
       /** Declare the host you want to connect to, the endpoint, and authentication (basic auth or oauth) */
	Hosts hosebirdHosts = new HttpHosts(Constants.STREAM_HOST);
	StatusesFilterEndpoint endpoint = new StatusesFilterEndpoint();

       // Optional: set up some followings and track terms
	List<Long> followings = Lists.newArrayList(1234L, 566788L);
	List<String> terms = Lists.newArrayList("twitter", "api");
	endpoint.followings(followings);
	endpoint.trackTerms(terms);

	Authentication hosebirdAuth = new OAuth1(
       		Helper.properties().getProperty("consumerKey"),
       		Helper.properties().getProperty("consumerSecret"),
       		Helper.properties().getProperty("token"),
       		Helper.properties().getProperty("secret"));

       ClientBuilder builder = new ClientBuilder()
        .name("Hosebird-Client-01")		// optional: mainly for the logs
        .hosts(hosebirdHosts)
        .authentication(hosebirdAuth)
        .endpoint(endpoint)
        .processor(new StringDelimitedProcessor(msgQueue));

	hosebirdClient = builder.build();
}
 
开发者ID:twitterdev,项目名称:twttr-kinesis,代码行数:27,代码来源:TweetCollector.java


示例5: testProperlyHandleSuccessfulConnection

import com.twitter.hbc.core.HttpHosts; //导入依赖的package包/类
@Test
public void testProperlyHandleSuccessfulConnection() {
  ClientBase clientBase = new ClientBase("name",
          mock, new HttpHosts("http://hi"), new RawEndpoint("/endpoint", HttpConstants.HTTP_GET), mockAuth,
          mockProcessor, mockReconnectionManager, mockRateTracker
  );

  mockStatusLine = mock(StatusLine.class);
  when(mockStatusLine.getStatusCode())
          .thenReturn(HttpConstants.Codes.SUCCESS);

  assertTrue(clientBase.handleConnectionResult(mockStatusLine));

  InOrder inOrder = inOrder(mockStatusLine, mockReconnectionManager);
  inOrder.verify(mockStatusLine).getStatusCode();
  inOrder.verify(mockReconnectionManager).resetCounts();

  assertFalse(clientBase.isDone());
}
 
开发者ID:twitter,项目名称:hbc,代码行数:20,代码来源:ClientBaseTest.java


示例6: testHandleIOExceptionOnConnection

import com.twitter.hbc.core.HttpHosts; //导入依赖的package包/类
@Test
public void testHandleIOExceptionOnConnection() throws IOException {
  ClientBase clientBase = new ClientBase("name",
          mock, new HttpHosts("http://hi"), new RawEndpoint("/endpoint", HttpConstants.HTTP_GET), mockAuth,
          mockProcessor, mockReconnectionManager, mockRateTracker
  );
  when(mockConnection.connect(any(HttpUriRequest.class)))
          .thenThrow(new IOException());

  HttpUriRequest mockRequest = mock(HttpUriRequest.class);
  assertNull(clientBase.establishConnection(mockConnection, mockRequest));

  InOrder inOrder = inOrder(mockConnection, mockReconnectionManager);

  inOrder.verify(mockConnection).connect(any(HttpUriRequest.class));
  inOrder.verify(mockReconnectionManager).handleLinearBackoff();

  assertFalse(clientBase.isDone());
}
 
开发者ID:twitter,项目名称:hbc,代码行数:20,代码来源:ClientBaseTest.java


示例7: testRetryTransientAuthFailures

import com.twitter.hbc.core.HttpHosts; //导入依赖的package包/类
@Test
public void testRetryTransientAuthFailures() {
  ClientBase clientBase = new ClientBase("name",
          mock, new HttpHosts("http://hi"), new RawEndpoint("/endpoint", HttpConstants.HTTP_GET), mockAuth,
          mockProcessor, mockReconnectionManager, mockRateTracker
  );

  when(mockStatusLine.getStatusCode())
          .thenReturn(401);
  when(mockStatusLine.getReasonPhrase())
          .thenReturn("reason");
  when(mockReconnectionManager.shouldReconnectOn400s())
          .thenReturn(true, true, false);

  // auth failure 3 times. We'll retry the first two times, but give up on the 3rd
  clientBase.handleConnectionResult(mockStatusLine);
  clientBase.handleConnectionResult(mockStatusLine);
  verify(mockReconnectionManager, times(2)).handleExponentialBackoff();
  assertFalse(clientBase.isDone());
  clientBase.handleConnectionResult(mockStatusLine);
  verify(mockReconnectionManager, times(2)).handleExponentialBackoff();
  assertTrue(clientBase.isDone());
}
 
开发者ID:twitter,项目名称:hbc,代码行数:24,代码来源:ClientBaseTest.java


示例8: testServiceUnavailable

import com.twitter.hbc.core.HttpHosts; //导入依赖的package包/类
@Test
public void testServiceUnavailable() {
  ClientBase clientBase = new ClientBase("name",
          mock, new HttpHosts("http://hi"), new RawEndpoint("/endpoint", HttpConstants.HTTP_GET), mockAuth,
          mockProcessor, mockReconnectionManager, mockRateTracker
  );
  when(mockStatusLine.getStatusCode())
          .thenReturn(503);

  clientBase.handleConnectionResult(mockStatusLine);
  clientBase.handleConnectionResult(mockStatusLine);
  clientBase.handleConnectionResult(mockStatusLine);
  clientBase.handleConnectionResult(mockStatusLine);

  verify(mockReconnectionManager, times(4)).handleExponentialBackoff();
  assertFalse(clientBase.isDone());
}
 
开发者ID:twitter,项目名称:hbc,代码行数:18,代码来源:ClientBaseTest.java


示例9: testInterruptedExceptionDuringProcessing

import com.twitter.hbc.core.HttpHosts; //导入依赖的package包/类
@Test
public void testInterruptedExceptionDuringProcessing() throws Exception {
  ClientBase clientBase = new ClientBase("name",
          mockClient, new HttpHosts("http://hi"), new RawEndpoint("/endpoint", HttpConstants.HTTP_GET), mockAuth,
          mockProcessor, mockReconnectionManager, mockRateTracker
  );

  when(mockStatusLine.getStatusCode())
          .thenReturn(200);

  doThrow(new InterruptedException()).when(mockProcessor).process();

  when(mockClient.getConnectionManager())
          .thenReturn(mockConnectionManager);

  BasicClient client = new BasicClient(clientBase, executorService);

  assertFalse(clientBase.isDone());
  client.connect();
  assertTrue(client.waitForFinish(100));
  assertTrue(client.isDone());
  verify(mockProcessor).setup(any(InputStream.class));
  verify(mockConnectionManager, atLeastOnce()).shutdown();
  assertEquals(EventType.STOPPED_BY_ERROR, client.getExitEvent().getEventType());
  assertTrue(client.getExitEvent().getUnderlyingException() instanceof InterruptedException);
}
 
开发者ID:twitter,项目名称:hbc,代码行数:27,代码来源:BasicClientTest.java


示例10: testExceptionIfBadScheme

import com.twitter.hbc.core.HttpHosts; //导入依赖的package包/类
@Test
public void testExceptionIfBadScheme() {
  int size = 50;
  List<String> hosts = new ArrayList<String>(size);
  for (int i = 0; i < size; i++) {
    if (i == size / 2) {
      hosts.add("thisfails.com");
    } else {
      hosts.add("https://thisismyawesomehost " + i + ".com");
    }
  }
  try {
    new HttpHosts(hosts);
    fail();
  } catch (RuntimeException e) {
    // is expected
  }
}
 
开发者ID:twitter,项目名称:hbc,代码行数:19,代码来源:HttpHostsTest.java


示例11: testIsScrambled

import com.twitter.hbc.core.HttpHosts; //导入依赖的package包/类
@Test
public void testIsScrambled() {
  int size = 50;
  List<String> hosts = new ArrayList<String>(size);
  for (int i = 0; i < size; i++) {
    hosts.add("http://thisismyawesomehost " + i + ".com");
  }
  HttpHosts httpHosts = new HttpHosts(hosts);

  boolean allSame = true;
  for (String string : hosts) {
    if (!string.equals(httpHosts.nextHost())) {
      allSame = false;
      break;
    }
  }
  assertFalse("This test failed unless you got EXTREMELY unlucky.", allSame);
}
 
开发者ID:twitter,项目名称:hbc,代码行数:19,代码来源:HttpHostsTest.java


示例12: buildClient

import com.twitter.hbc.core.HttpHosts; //导入依赖的package包/类
/**
 * @param tweetQueue tweet Queue.
 * @param hosts Hostes.
 * @param endpoint Endpoint.
 * @return Client.
 */
protected Client buildClient(BlockingQueue<String> tweetQueue, HttpHosts hosts, StreamingEndpoint endpoint) {
    Authentication authentication = new OAuth1(oAuthSettings.getConsumerKey(), oAuthSettings.getConsumerSecret(),
        oAuthSettings.getAccessToken(), oAuthSettings.getAccessTokenSecret());

    ClientBuilder builder = new ClientBuilder()
        .name("Ignite-Twitter-Client")
        .hosts(hosts)
        .authentication(authentication)
        .endpoint(endpoint)
        .processor(new StringDelimitedProcessor(tweetQueue));

    return builder.build();
}
 
开发者ID:apache,项目名称:ignite,代码行数:20,代码来源:TwitterStreamer.java


示例13: subscribe

import com.twitter.hbc.core.HttpHosts; //导入依赖的package包/类
public void subscribe(final StatusStreamHandler listener, String... terms) {
	/**
	 * Set up your blocking queues: Be sure to size these properly based on
	 * expected TPS of your stream
	 */
	BlockingQueue<String> msgQueue = new LinkedBlockingQueue<String>(100000);
	BlockingQueue<Event> eventQueue = new LinkedBlockingQueue<Event>(1000);

	/**
	 * Declare the host you want to connect to, the endpoint, and
	 * authentication (basic auth or oauth)
	 */
	Hosts hosebirdHosts = new HttpHosts(Constants.STREAM_HOST);
	StatusesFilterEndpoint hosebirdEndpoint = new StatusesFilterEndpoint();
	hosebirdEndpoint.trackTerms(Lists.newArrayList(terms));

	Authentication hosebirdAuth = oAuth();

	ClientBuilder builder = new ClientBuilder().name("Hosebird-Client-01")
			// optional: mainly for the logs
			.hosts(hosebirdHosts).authentication(hosebirdAuth).endpoint(hosebirdEndpoint)
			.processor(new StringDelimitedProcessor(msgQueue)).eventMessageQueue(eventQueue);
	Client client = builder.build();

	final ExecutorService executorService = Executors.newFixedThreadPool(1);
	final Twitter4jStatusClient t4jClient = new Twitter4jStatusClient(client, msgQueue,
			Lists.newArrayList(listener), executorService);
	t4jClient.connect();

	// Call this once for every thread you want to spin off for processing
	// the raw messages.
	// This should be called at least once.
	t4jClient.process(); // required to start processing the messages
}
 
开发者ID:cyriux,项目名称:hexagonal-sentimental,代码行数:35,代码来源:TwitterStream.java


示例14: testUnknownEndpointFails

import com.twitter.hbc.core.HttpHosts; //导入依赖的package包/类
@Test
public void testUnknownEndpointFails() {
  ClientBase clientBase = new ClientBase("name",
          mock, new HttpHosts("http://hi"), new RawEndpoint("/endpoint", HttpConstants.HTTP_GET), mockAuth,
          mockProcessor, mockReconnectionManager, mockRateTracker
  );
  when(mockStatusLine.getStatusCode())
          .thenReturn(404);
  when(mockStatusLine.getReasonPhrase())
          .thenReturn("reason");
  clientBase.handleConnectionResult(mockStatusLine);
  assertTrue(clientBase.isDone());
}
 
开发者ID:twitter,项目名称:hbc,代码行数:14,代码来源:ClientBaseTest.java


示例15: testIOExceptionDuringProcessing

import com.twitter.hbc.core.HttpHosts; //导入依赖的package包/类
@Test
public void testIOExceptionDuringProcessing() throws Exception {
  ClientBase clientBase = new ClientBase("name",
          mockClient, new HttpHosts("http://hi"), new RawEndpoint("/endpoint", HttpConstants.HTTP_GET), mockAuth,
          mockProcessor, mockReconnectionManager, mockRateTracker
  );
  BasicClient client = new BasicClient(clientBase, executorService);
  final CountDownLatch latch = new CountDownLatch(1);
  when(mockStatusLine.getStatusCode())
          .thenReturn(200);

  doNothing().when(mockProcessor).setup(any(InputStream.class));
  doThrow(new IOException()).
          doThrow(new IOException()).
          doThrow(new IOException()).
          doAnswer(new Answer() {
            @Override
            public Object answer(InvocationOnMock invocationOnMock) throws Throwable {
              latch.countDown();
              return null;
            }
          }).when(mockProcessor).process();

  client.connect();
  latch.await();
  assertFalse(clientBase.isDone());
  verify(mockProcessor, times(4)).setup(any(InputStream.class));
  // throw 3 exceptions, 4th one keeps going
  verify(mockProcessor, atLeast(4)).process();

  client.stop();
  verify(mockConnectionManager, atLeastOnce()).shutdown();
  assertTrue(client.isDone());
  assertEquals(EventType.STOPPED_BY_USER, clientBase.getExitEvent().getEventType());
}
 
开发者ID:twitter,项目名称:hbc,代码行数:36,代码来源:BasicClientTest.java


示例16: testBuilderSuccess

import com.twitter.hbc.core.HttpHosts; //导入依赖的package包/类
@Test
public void testBuilderSuccess() {
  new ClientBuilder()
          .hosts(new HttpHosts(Constants.STREAM_HOST))
          .endpoint(new StatusesSampleEndpoint())
          .processor(new NullProcessor())
          .authentication(new BasicAuth("username", "password"))
          .build();

}
 
开发者ID:twitter,项目名称:hbc,代码行数:11,代码来源:ClientBuilderTest.java


示例17: testInvalidHttpMethod

import com.twitter.hbc.core.HttpHosts; //导入依赖的package包/类
@Test
public void testInvalidHttpMethod() {
  try {
    new ClientBuilder()
            .hosts(new HttpHosts(Constants.STREAM_HOST))
            .endpoint(StatusesSampleEndpoint.PATH, "FAIL!")
            .processor(new NullProcessor())
            .authentication(new BasicAuth("username", "password"))
            .build();
    fail();
  } catch (Exception e) {
    // expected
  }
}
 
开发者ID:twitter,项目名称:hbc,代码行数:15,代码来源:ClientBuilderTest.java


示例18: testValidHttpMethod

import com.twitter.hbc.core.HttpHosts; //导入依赖的package包/类
@Test
public void testValidHttpMethod() {
  new ClientBuilder()
          .hosts(new HttpHosts(Constants.STREAM_HOST))
          .endpoint(StatusesSampleEndpoint.PATH, "gEt")
          .processor(new NullProcessor())
          .authentication(new BasicAuth("username", "password"))
          .build();

}
 
开发者ID:twitter,项目名称:hbc,代码行数:11,代码来源:ClientBuilderTest.java


示例19: testContainsAll

import com.twitter.hbc.core.HttpHosts; //导入依赖的package包/类
@Test
public void testContainsAll() {
  int size = 30;
  List<String> hosts = new ArrayList<String>(size);
  for (int i = 0; i < size; i++) {
    hosts.add("http://thisismyawesomehost " + i + ".com");
  }
  HttpHosts httpHosts = new HttpHosts(hosts);
  Set<String> hostsSet = new HashSet<String>(hosts);
  for (int i = 0; i < size; i++) {
    assertTrue(hostsSet.remove(httpHosts.nextHost()));
  }
  assertTrue(hostsSet.isEmpty());
}
 
开发者ID:twitter,项目名称:hbc,代码行数:15,代码来源:HttpHostsTest.java


示例20: testInfiniteIteration

import com.twitter.hbc.core.HttpHosts; //导入依赖的package包/类
@Test
public void testInfiniteIteration() {
  int size = 10;
  List<String> hosts = new ArrayList<String>(size);
  for (int i = 0; i < size; i++) {
    hosts.add("http://thisismyawesomehost " + i + ".com");
  }
  HttpHosts httpHosts = new HttpHosts(hosts);
  Set<String> hostsSet = new HashSet<String>(hosts);
  for (int i = 0; i < size * 10; i++) {
    assertTrue(hostsSet.contains(httpHosts.nextHost()));
  }
}
 
开发者ID:twitter,项目名称:hbc,代码行数:14,代码来源:HttpHostsTest.java



注:本文中的com.twitter.hbc.core.HttpHosts类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
Java ActiveMQMessage类代码示例发布时间:2022-05-22
下一篇:
Java NMTokenPBImpl类代码示例发布时间:2022-05-22
热门推荐
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap