|
1 | 1 | package com.vilyever.androidsocketclient; |
2 | 2 |
|
3 | | -import android.support.v7.app.AppCompatActivity; |
4 | 3 | import android.os.Bundle; |
5 | | -import android.view.Menu; |
6 | | -import android.view.MenuItem; |
| 4 | +import android.support.annotation.NonNull; |
| 5 | +import android.support.v7.app.AppCompatActivity; |
7 | 6 |
|
8 | | -import com.vilyever.socketclient.VDSocketClient; |
| 7 | +import com.vilyever.logger.Logger; |
| 8 | +import com.vilyever.socketclient.SocketClient; |
| 9 | +import com.vilyever.socketclient.server.SocketServer; |
| 10 | +import com.vilyever.socketclient.server.SocketServerClient; |
| 11 | +import com.vilyever.socketclient.util.IPUtil; |
9 | 12 |
|
10 | 13 | public class MainActivity extends AppCompatActivity { |
| 14 | + final MainActivity self = this; |
| 15 | + |
| 16 | + private SocketServer socketServer; |
| 17 | + protected SocketServer getSocketServer() { |
| 18 | + if (this.socketServer == null) { |
| 19 | + this.socketServer = new SocketServer(2333); |
| 20 | + } |
| 21 | + return this.socketServer; |
| 22 | + } |
| 23 | + |
| 24 | + private SocketClient localSocketClient; |
| 25 | + protected SocketClient getLocalSocketClient() { |
| 26 | + if (this.localSocketClient == null) { |
| 27 | + this.localSocketClient = new SocketClient("192.168.1.153", 2333); |
| 28 | + } |
| 29 | + return this.localSocketClient; |
| 30 | + } |
| 31 | + |
| 32 | + private SocketServerClient serverListeningSocketServerClient; |
| 33 | + protected MainActivity setServerListeningSocketServerClient(SocketServerClient serverListeningSocketServerClient) { |
| 34 | + this.serverListeningSocketServerClient = serverListeningSocketServerClient; |
| 35 | + return this; |
| 36 | + } |
| 37 | + protected SocketClient getServerListeningSocketServerClient() { |
| 38 | + return this.serverListeningSocketServerClient; |
| 39 | + } |
11 | 40 |
|
12 | 41 | @Override |
13 | 42 | protected void onCreate(Bundle savedInstanceState) { |
14 | 43 | super.onCreate(savedInstanceState); |
15 | 44 | setContentView(R.layout.activity_main); |
16 | 45 |
|
17 | | - VDSocketClient socketClient = new VDSocketClient(); |
18 | | - socketClient.registerDelegate(new VDSocketClient.VDSocketClientDelegate() { |
| 46 | + getSocketServer().registerSocketServerDelegate(new SocketServer.SocketServerDelegate() { |
19 | 47 | @Override |
20 | | - public void didConnect(VDSocketClient client) { |
| 48 | + public void onClientConnected(SocketServer socketServer, SocketServerClient socketServerClient) { |
| 49 | + System.out.println("socketServer onClientConnected"); |
| 50 | + |
| 51 | + self.setServerListeningSocketServerClient(socketServerClient); |
| 52 | + socketServerClient.registerSocketDelegate(new SocketClient.SocketDelegate() { |
| 53 | + @Override |
| 54 | + public void onConnected(SocketClient client) { |
21 | 55 |
|
| 56 | + } |
| 57 | + |
| 58 | + @Override |
| 59 | + public void onDisconnected(SocketClient client) { |
| 60 | + System.out.println("serverListeningSocketServerClient onDisconnected"); |
| 61 | + } |
| 62 | + |
| 63 | + @Override |
| 64 | + public void onResponse(SocketClient client, @NonNull String response) { |
| 65 | + System.out.println("serverListeningSocketServerClient onResponse \n" + response); |
| 66 | + } |
| 67 | + }); |
22 | 68 | } |
23 | 69 |
|
24 | 70 | @Override |
25 | | - public void didDisconnect(VDSocketClient client) { |
| 71 | + public void onClientDisconnected(SocketServer socketServer, SocketServerClient socketServerClient) { |
| 72 | + System.out.println("socketServer onClientDisconnected"); |
| 73 | + self.setServerListeningSocketServerClient(null); |
| 74 | + } |
| 75 | + }); |
| 76 | + getSocketServer().beginListen(); |
| 77 | + getSocketServer().setHeartBeatInterval(1000 * 120); |
26 | 78 |
|
| 79 | + getLocalSocketClient().registerSocketDelegate(new SocketClient.SocketDelegate() { |
| 80 | + @Override |
| 81 | + public void onConnected(SocketClient client) { |
| 82 | + System.out.println("localSocketClient onConnected"); |
27 | 83 | } |
28 | 84 |
|
29 | 85 | @Override |
30 | | - public void didReceiveResponse(VDSocketClient client, String response) { |
| 86 | + public void onDisconnected(SocketClient client) { |
| 87 | + System.out.println("localSocketClient onDisconnected"); |
| 88 | + } |
31 | 89 |
|
| 90 | + @Override |
| 91 | + public void onResponse(SocketClient client, @NonNull String response) { |
| 92 | + System.out.println("localSocketClient onResponse \n" + response); |
32 | 93 | } |
33 | 94 | }); |
34 | | - socketClient.connect("192.168.1.1", 80); |
35 | | - } |
36 | 95 |
|
37 | | - @Override |
38 | | - public boolean onCreateOptionsMenu(Menu menu) { |
39 | | - // Inflate the menu; this adds items to the action bar if it is present. |
40 | | - getMenuInflater().inflate(R.menu.menu_main, menu); |
41 | | - return true; |
42 | | - } |
| 96 | + getLocalSocketClient().connect(); |
| 97 | + |
| 98 | + getWindow().getDecorView().postDelayed(new Runnable() { |
| 99 | + @Override |
| 100 | + public void run() { |
| 101 | + getLocalSocketClient().send("haha test"); |
| 102 | + } |
| 103 | + }, 15 * 1000); |
| 104 | + getWindow().getDecorView().postDelayed(new Runnable() { |
| 105 | + @Override |
| 106 | + public void run() { |
| 107 | +// getLocalSocketClient().send(SocketPacket.DefaultPollingQueryMessage); |
| 108 | + getLocalSocketClient().disconnect(); |
| 109 | + } |
| 110 | + }, 30 * 1000); |
43 | 111 |
|
44 | | - @Override |
45 | | - public boolean onOptionsItemSelected(MenuItem item) { |
46 | | - // Handle action bar item clicks here. The action bar will |
47 | | - // automatically handle clicks on the Home/Up button, so long |
48 | | - // as you specify a parent activity in AndroidManifest.xml. |
49 | | - int id = item.getItemId(); |
50 | | - |
51 | | - //noinspection SimplifiableIfStatement |
52 | | - if (id == R.id.action_settings) { |
53 | | - return true; |
54 | | - } |
55 | 112 |
|
56 | | - return super.onOptionsItemSelected(item); |
| 113 | + Logger.log("ip " + IPUtil.getIPAddress(true)); |
57 | 114 | } |
| 115 | + |
58 | 116 | } |
0 commit comments