Package com.firefly.net.support

Examples of com.firefly.net.support.SimpleTcpClient.connect()

9
10
11
12
13
14
15
16
17
18
19
public class SimpleTcpClientExample {
  public static void main(String[] args) {
    final SimpleTcpClient client = new SimpleTcpClient("localhost", 9900,
        new StringLineDecoder(), new StringLineEncoder());
    TcpConnection c = client.connect();
    c.send("hello client 1", new MessageReceiveCallBack() {

      @Override
      public void messageRecieved(Session session, Object obj) {
        System.out.println("con1|" + obj.toString());
View Full Code Here
44
45
46
47
48
49
50
51
52
53
54
      public void messageRecieved(Session session, Object obj) {
        System.out.println("con1|" + obj.toString());
      }
    });

    TcpConnection c2 = client.connect();
    System.out.println("con2|" + c2.send("getfile"));
    c2.close(false);

   
  }
View Full Code Here
37
38
39
40
41
42
43
44
45
46
47
    for (int i = 0; i < LOOP; i++) {
      executorService.submit(new Runnable() {
        @Override
        public void run() {
          final TcpConnection c = client.connect();
          Assert.assertThat(c.isOpen(), is(true));
          log.debug("main thread {}", Thread.currentThread()
              .toString());
          Assert.assertThat((String) c.send("hello client"), is("hello client"));
          Assert.assertThat((String) c.send("hello multithread test"), is("hello multithread test"));
View Full Code Here
51
52
53
54
55
56
57
58
59
60
        }
      });

    }

    final TcpConnection c = client.connect();
    Assert.assertThat((String) c.send("hello client 2"), is("hello client 2"));
    Assert.assertThat((String) c.send("quit"), is("bye!"));
  }
}
View Full Code Here
140
141
142
143
144
145
146
147
148
149
150
    ExecutorService executorService = Executors.newFixedThreadPool(THREAD);
    final SimpleTcpClient client = new SimpleTcpClient(host, port,
        new StringLineDecoder(), new StringLineEncoder());
    for (int i = 0; i < THREAD; i++) {
      tcpConnections[i] = client.connect();
    }
    final CyclicBarrier barrier = new CyclicBarrier(THREAD, new StatTask());

    if (asyn == 0) {
      log.info("synchronize test");
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.