99import com .vilyever .jsonmodel .JsonModel ;
1010import com .vilyever .logger .Logger ;
1111import com .vilyever .socketclient .SocketClient ;
12- import com .vilyever .socketclient .SocketPacket ;
13- import com .vilyever .socketclient .SocketResponsePacket ;
12+ import com .vilyever .socketclient .helper . SocketPacket ;
13+ import com .vilyever .socketclient .helper . SocketResponsePacket ;
1414import com .vilyever .socketclient .server .SocketServer ;
1515import com .vilyever .socketclient .server .SocketServerClient ;
1616import com .vilyever .socketclient .util .IPUtil ;
@@ -54,42 +54,41 @@ protected void onCreate(Bundle savedInstanceState) {
5454 getSocketServer ().registerSocketServerDelegate (new SocketServer .SocketServerDelegate () {
5555 @ Override
5656 public void onServerBeginListen (SocketServer socketServer , int port ) {
57- Logger .log ("begin listen " + port );
57+ Logger .log ("SocketServer: begin listen " + port );
5858 }
5959
6060 @ Override
6161 public void onServerStopListen (SocketServer socketServer , int port ) {
62- Logger .log ("stop listen " + port );
62+ Logger .log ("SocketServer: stop listen " + port );
6363 }
6464
6565 @ Override
6666 public void onClientConnected (SocketServer socketServer , SocketServerClient socketServerClient ) {
67- Logger .log ("socketServer onClientConnected" );
67+ Logger .log ("SocketServer: onClientConnected" );
6868
6969 self .setServerListeningSocketServerClient (socketServerClient );
7070 socketServerClient .registerSocketDelegate (new SocketClient .SocketDelegate () {
7171 @ Override
7272 public void onConnected (SocketClient client ) {
73-
7473 }
7574
7675 @ Override
7776 public void onDisconnected (SocketClient client ) {
78- Logger .log ("serverListeningSocketServerClient onDisconnected" );
7977 }
8078
8179 @ Override
8280 public void onResponse (SocketClient client , @ NonNull SocketResponsePacket responsePacket ) {
8381// Logger.log("serverListeningSocketServerClient onResponse \n" + responsePacket.getMessage());
84- Logger .log ("serverListeningSocketServerClient onResponse length " + responsePacket .getMessage ().length ());
85- Log .d ("Logger" , "serverListeningSocketServerClient onResponse \n " + responsePacket .getMessage ());
82+ // Logger.log("serverListeningSocketServerClient onResponse length " + responsePacket.getMessage().length());
83+ // Log.d("Logger", "serverListeningSocketServerClient onResponse \n" + responsePacket.getMessage());
84+ Log .d ("Logger" , "size " + responsePacket .getData ().length + " ->" + responsePacket .getMessage ().replaceAll ("\\ r" , "" ));
8685 }
8786 });
8887 }
8988
9089 @ Override
9190 public void onClientDisconnected (SocketServer socketServer , SocketServerClient socketServerClient ) {
92- Logger .log ("socketServer onClientDisconnected" );
91+ Logger .log ("SocketServer: onClientDisconnected" );
9392 self .setServerListeningSocketServerClient (null );
9493 }
9594 });
@@ -98,18 +97,19 @@ public void onClientDisconnected(SocketServer socketServer, SocketServerClient s
9897 getLocalSocketClient ().registerSocketDelegate (new SocketClient .SocketDelegate () {
9998 @ Override
10099 public void onConnected (SocketClient client ) {
101- Logger .log ("localSocketClient onConnected" );
102- getLocalSocketClient ().send ("再见" );
100+ Logger .log ("SocketClient: internalOnConnected" );
101+ getLocalSocketClient ().send ("helo" );
102+ getLocalSocketClient ().send ("再见\r \n le\r \n baichi\r \n wahaha123\n iii" );
103103 }
104104
105105 @ Override
106106 public void onDisconnected (SocketClient client ) {
107- Logger .log ("localSocketClient onDisconnected " );
107+ Logger .log ("SocketClient: internalOnDisconnected " );
108108 }
109109
110110 @ Override
111111 public void onResponse (SocketClient client , @ NonNull SocketResponsePacket responsePacket ) {
112- Logger .log ("localSocketClient onResponse \n " + responsePacket .getMessage ());
112+ Logger .log ("SocketClient: onResponse \n " + responsePacket .getMessage ());
113113 }
114114 });
115115
@@ -132,6 +132,11 @@ public void onPollingResponse(SocketClient socketClient, SocketResponsePacket po
132132 }
133133 });
134134
135+ getLocalSocketClient ().getSocketPacketHelper ().setSendTailString ("\r \n " );
136+ getLocalSocketClient ().getSocketPacketHelper ().setReceiveTailString ("\r \n " );
137+ getSocketServer ().getSocketPacketHelper ().setSendTailString ("\r \n " );
138+ getSocketServer ().getSocketPacketHelper ().setReceiveTailString ("\r \n " );
139+
135140 getLocalSocketClient ().connect ();
136141
137142 getWindow ().getDecorView ().postDelayed (new Runnable () {
@@ -145,13 +150,8 @@ public void run() {
145150 e .printStackTrace ();
146151 }
147152
148- getLocalSocketClient ().send (SocketPacket .DefaultPollingQueryMessage );
149-
150153 getLocalSocketClient ().send ("你也好" );
151154
152-
153-
154-
155155 new AsyncTask <Void , Void , Void >() {
156156 @ Override
157157 protected Void doInBackground (Void ... params ) {
0 commit comments