mirror of
https://gitee.com/willfree/min-vpn-client_v2.git
synced 2026-10-04 19:42:00 +08:00
loginrevise2
This commit is contained in:
ChloeKiwi committed
1 parent
6de3a06a7e
commit
a24334cff2
3 files changed
+246
No files matched your search
@@ -182,4 +182,7 @@ dependencies {
|
||||
// compile 'com.github.yaming116:UpdateApp:1.0.7'
|
||||
// compile 'com.gitee.willfree:UpdateApp:1.0.7'
|
||||
// compile 'com.github.liurentian:UpdateAppUtils:v1.2.2'
|
||||
|
||||
//socket service
|
||||
implementation 'org.greenrobot:eventbus:3.1.1'
|
||||
}
|
||||
@@ -59,6 +59,8 @@
|
||||
<action android:name="android.net.VpnService" />
|
||||
</intent-filter>
|
||||
</service>
|
||||
<service android:name=".services.SocketService">
|
||||
</service>
|
||||
</application>
|
||||
|
||||
<!-- 在SDCard中创建与删除文件权限 -->
|
||||
|
||||
@@ -0,0 +1,241 @@
|
||||
/**
|
||||
* Created by yqy on 2022/7/15.
|
||||
* <p>
|
||||
* socket连接服务
|
||||
*/
|
||||
package com.pkusz.min_vpn_client.services;
|
||||
import android.app.Service;
|
||||
import android.content.Intent;
|
||||
import android.os.Binder;
|
||||
import android.os.Handler;
|
||||
import android.os.IBinder;
|
||||
import android.os.Looper;
|
||||
import android.util.Log;
|
||||
import android.widget.TabHost;
|
||||
import android.widget.Toast;
|
||||
|
||||
//import com.pkusz.min_vpn_client.Constants;
|
||||
//import com.pkusz.min_vpn_client.EventMsg;
|
||||
|
||||
import org.greenrobot.eventbus.EventBus;
|
||||
|
||||
import java.io.IOException;
|
||||
import java.io.OutputStream;
|
||||
import java.net.ConnectException;
|
||||
import java.net.InetSocketAddress;
|
||||
import java.net.NoRouteToHostException;
|
||||
import java.net.Socket;
|
||||
import java.net.SocketTimeoutException;
|
||||
import java.util.Timer;
|
||||
import java.util.TimerTask;
|
||||
|
||||
|
||||
public class SocketService extends Service {
|
||||
/*socket*/
|
||||
private Socket socket;
|
||||
/*连接线程*/
|
||||
private Thread connectThread;
|
||||
private Timer timer = new Timer();
|
||||
private OutputStream outputStream;
|
||||
|
||||
private SocketBinder sockerBinder = new SocketBinder();
|
||||
private String ip;
|
||||
private String port;
|
||||
private TimerTask task;
|
||||
|
||||
/*默认重连*/
|
||||
private boolean isReConnect = true;
|
||||
|
||||
private Handler handler = new Handler(Looper.getMainLooper());
|
||||
|
||||
|
||||
@Override
|
||||
public IBinder onBind(Intent intent) {
|
||||
return sockerBinder;
|
||||
}
|
||||
|
||||
|
||||
public class SocketBinder extends Binder {
|
||||
|
||||
/*返回SocketService 在需要的地方可以通过ServiceConnection获取到SocketService */
|
||||
public SocketService getService() {
|
||||
return SocketService.this;
|
||||
}
|
||||
}
|
||||
|
||||
@Override
|
||||
public void onCreate() {
|
||||
super.onCreate();
|
||||
}
|
||||
|
||||
|
||||
@Override
|
||||
public int onStartCommand(Intent intent, int flags, int startId) {
|
||||
|
||||
/*拿到传递过来的ip和端口号*/
|
||||
ip = "121.15.171.89";
|
||||
port = "14922";
|
||||
|
||||
/*初始化socket*/
|
||||
initSocket();
|
||||
return super.onStartCommand(intent, flags, startId);
|
||||
}
|
||||
|
||||
|
||||
/*初始化socket*/
|
||||
private void initSocket() {
|
||||
if (socket == null && connectThread == null) {
|
||||
connectThread = new Thread(new Runnable() {
|
||||
@Override
|
||||
public void run() {
|
||||
socket = new Socket();
|
||||
try {
|
||||
/*超时时间为2秒*/
|
||||
socket.connect(new InetSocketAddress(ip, Integer.valueOf(port)), 2000);
|
||||
/*连接成功的话 发送心跳包*/
|
||||
if (socket.isConnected()) {
|
||||
/*因为Toast是要运行在主线程的 这里是子线程 所以需要到主线程N那里去显示toast*/
|
||||
toastMsg("socket已连接");
|
||||
/*发送连接成功的消息*/
|
||||
// EventMsg msg = new EventMsg();
|
||||
// msg.setTag(Constants.CONNET_SUCCESS);
|
||||
// EventBus.getDefault().post(msg);
|
||||
/*发送心跳数据*/
|
||||
sendBeatData();
|
||||
}
|
||||
} catch (IOException e) {
|
||||
e.printStackTrace();
|
||||
if (e instanceof SocketTimeoutException) {
|
||||
toastMsg("连接超时，正在重连");
|
||||
releaseSocket();
|
||||
} else if (e instanceof NoRouteToHostException) {
|
||||
toastMsg("该地址不存在，请检查");
|
||||
stopSelf();
|
||||
} else if (e instanceof ConnectException) {
|
||||
toastMsg("连接异常或被拒绝，请检查");
|
||||
stopSelf();
|
||||
}
|
||||
}
|
||||
}
|
||||
});
|
||||
/*启动连接线程*/
|
||||
connectThread.start();
|
||||
}
|
||||
}
|
||||
|
||||
/*因为Toast是要运行在主线程的 所以需要到主线程哪里去显示toast*/
|
||||
private void toastMsg(final String msg) {
|
||||
|
||||
handler.post(new Runnable() {
|
||||
@Override
|
||||
public void run() {
|
||||
Toast.makeText(getApplicationContext(), msg, Toast.LENGTH_SHORT).show();
|
||||
}
|
||||
});
|
||||
}
|
||||
|
||||
|
||||
/*发送数据*/
|
||||
public void sendOrder(final String order) {
|
||||
if (socket != null && socket.isConnected()) {
|
||||
/*发送指令*/
|
||||
new Thread(new Runnable() {
|
||||
@Override
|
||||
public void run() {
|
||||
try {
|
||||
outputStream = socket.getOutputStream();
|
||||
if (outputStream != null) {
|
||||
outputStream.write((order).getBytes("gbk"));
|
||||
outputStream.flush();
|
||||
}
|
||||
} catch (IOException e) {
|
||||
e.printStackTrace();
|
||||
}
|
||||
}
|
||||
}).start();
|
||||
} else {
|
||||
toastMsg("socket连接错误,请重试");
|
||||
}
|
||||
}
|
||||
|
||||
/*定时发送数据*/
|
||||
private void sendBeatData() {
|
||||
if (timer == null) {
|
||||
timer = new Timer();
|
||||
}
|
||||
|
||||
if (task == null) {
|
||||
task = new TimerTask() {
|
||||
@Override
|
||||
public void run() {
|
||||
try {
|
||||
outputStream = socket.getOutputStream();
|
||||
/*这里的编码方式根据需求去改*/
|
||||
outputStream.write(("test").getBytes("gbk"));
|
||||
outputStream.flush();
|
||||
} catch (Exception e) {
|
||||
/*发送失败说明socket断开了或者出现了其他错误*/
|
||||
toastMsg("连接断开，正在重连");
|
||||
/*重连*/
|
||||
releaseSocket();
|
||||
e.printStackTrace();
|
||||
|
||||
}
|
||||
}
|
||||
};
|
||||
}
|
||||
|
||||
timer.schedule(task, 0, 2000);
|
||||
}
|
||||
|
||||
/*释放资源*/
|
||||
private void releaseSocket() {
|
||||
|
||||
if (task != null) {
|
||||
task.cancel();
|
||||
task = null;
|
||||
}
|
||||
if (timer != null) {
|
||||
timer.purge();
|
||||
timer.cancel();
|
||||
timer = null;
|
||||
}
|
||||
|
||||
if (outputStream != null) {
|
||||
try {
|
||||
outputStream.close();
|
||||
} catch (IOException e) {
|
||||
e.printStackTrace();
|
||||
}
|
||||
outputStream = null;
|
||||
}
|
||||
|
||||
if (socket != null) {
|
||||
try {
|
||||
socket.close();
|
||||
|
||||
} catch (IOException e) {
|
||||
}
|
||||
socket = null;
|
||||
}
|
||||
|
||||
if (connectThread != null) {
|
||||
connectThread = null;
|
||||
}
|
||||
|
||||
/*重新初始化socket*/
|
||||
if (isReConnect) {
|
||||
initSocket();
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
|
||||
@Override
|
||||
public void onDestroy() {
|
||||
super.onDestroy();
|
||||
Log.i("SocketService", "onDestroy");
|
||||
isReConnect = false;
|
||||
releaseSocket();
|
||||
}
|
||||
}
|
||||
Reference in new issue
Block a user