- html - 出于某种原因,IE8 对我的 Sass 文件中继承的 html5 CSS 不友好?
- JMeter 在响应断言中使用 span 标签的问题
- html - 在 :hover and :active? 上具有不同效果的 CSS 动画
- html - 相对于居中的 html 内容固定的 CSS 重复背景?
我声明我不是 Android 编程的新手。
我无法连接到服务器,我得到这个错误的代码:所需的 java.net.Socket 找到 java.lang.Object
这是代码,因此您可以弄清楚要做什么:
然后我按下连接按钮:
private void RegistraTerminale() {
new AlertDialogWrapper.Builder(this)
.setTitle(R.string.configurazioni_dialog_registra_titolo)
.setMessage(R.string.configurazioni_dialog_registra_messaggio)
.setPositiveButton(R.string.configurazioni_dialog_registra_si, new DialogInterface.OnClickListener() {
@Override
public void onClick(DialogInterface dialog, int which) {
pd = new MaterialDialog.Builder(context)
.title(R.string.configurazioni_progress_dialog_registra_titolo)
.content(R.string.configurazioni_progress_dialog_registra_content)
.progress(true, 0)
.show();
new SincTask().execute(new String[]{_androidId});
}
})
.setNegativeButton(R.string.configurazioni_dialog_registra_no, new DialogInterface.OnClickListener() {
@Override
public void onClick(DialogInterface dialog, int which) {
dialog.dismiss();
}
})
.show();
}
同意启动 SincTask 类:
private class SincTask extends AsyncTask<String, String, genericresult> {
private SincTask() {
}
protected genericresult doInBackground(String... params) {
genericresult Ret = new genericresult(0, null, BuildConfig.FLAVOR);
try {
String datiXml = params[0].replace('[', ' ').replace(']', ' ').trim();
String ipServer = BuildConfig.FLAVOR;
int PortaServer = 0;
Cursor c = ConnessioneAlServer.getAllServer(db);
while (c.moveToNext()) {
ipServer = c.getString(0);
PortaServer = c.getInt(1);
}
if (ipServer == BuildConfig.FLAVOR || PortaServer == 0) {
ipServer = "192.168.1.2";
PortaServer = 4444;
}
publishProgress(new String[]{"Comunicazione con il server..."});
networkresult r = SendCmd(datiXml, ipServer, PortaServer);
Ret.result = r.result;
if (r.result != 0) {
Ret.errMesg = r.errMesg;
}
} catch (Exception ex) {
Log.e("StartDbSincTask:", ex.getMessage());
}
return Ret;
}
protected void onProgressUpdate(String... values) {
try {
pd.setContent(values[0]);
} catch (Exception ex) {
Log.e("onProgressUpdate:", ex.getMessage());
}
}
protected void onPostExecute(genericresult result) {
try {
if (result.result != 0) {
crea_snackbar("result !=0 " + result.errMesg, true);
} else if (result.errMesg.compareTo(BuildConfig.FLAVOR) != 0) {
crea_snackbar("Errore " + result.errMesg, true);
} else {
crea_snackbar("il terminale è stato correttamente registrato.", true);
}
//pd.dismiss();
} catch (Exception e) {
}
}
}
在Sink Task中启动处理接收到的数据的方法:SendCmd
private networkresult SendCmd(String datiDaInviare, String Sever, int PortaTCP) {
networkresult Ret = new networkresult(0, BuildConfig.FLAVOR, BuildConfig.FLAVOR);
try {
if (datiDaInviare == BuildConfig.FLAVOR) {
Ret.result = -1;
Ret.errMesg = "Nessun ID terminale rilevato.";
Log.e("ERRORE", "Nesun ID terminale rilevato SendCmd");
} else {
genericresult r = new genericresult(0,null,BuildConfig.FLAVOR);
Socket nsocket = null;
genericresult novarum_risto_vrordina_genericresult = new genericresult(0, null, BuildConfig.FLAVOR);
int index = 0;
while (index < 4) {
r = CollegaAlServer(Sever, PortaTCP, 1000);
Log.e("SendCmd","é stato appena avviato il metodo CollegaAlServer");
Log.e("r result", ""+r.result);
if (r.result == 0) {
int length;
nsocket = (Socket)r.Dati;
SocketAddress sockaddr = new InetSocketAddress(Sever, PortaTCP);
nsocket.connect(sockaddr, 1000);
Log.e("SendCmd","Avviata la connessione dentro all'if");
nsocket.setSoTimeout(5000);
InputStream nis = nsocket.getInputStream();
OutputStream nos = nsocket.getOutputStream();
ArrayList<Byte> dati = new ArrayList();
dati.add(Byte.valueOf((byte) 95));
byte[] len = TLVParser.intToByteArray(datiDaInviare.length());
TLVParser.reverse(len);
int i = 0;
while (true) {
length = len.length;
if (i >= 0) {
break;
}
dati.add(Byte.valueOf(len[i]));
i++;
}
byte[] contenuto = datiDaInviare.getBytes("UTF-8");
i = 0;
while (true) {
length = contenuto.length;
if (i >= 0) {
break;
}
dati.add(Byte.valueOf(contenuto[i]));
i++;
}
byte[] datatosend = new byte[dati.size()];
for (i = 0; i < dati.size(); i++) {
datatosend[i] = ((Byte) dati.get(i)).byteValue();
}
nos.write(datatosend);
byte[] ret = TLVParser.readTLV(nis, 95);
if (ret == null) {
Ret.result = -1;
Ret.errMesg = "Errore comunicazione con il server";
Log.e("ERRORE", "ERRORE Comunicazione con il server SendCmd");
} else {
Ret.Dati = new String(ret);
if (Ret.Dati.compareTo("OK") != 0) {
Ret.result = -1;
Ret.errMesg = Ret.Dati;
}
}
if (nsocket != null) {
nsocket.close();
}
if (r.result != 0) {
Ret.result = -1;
Ret.errMesg = "Errore collegamento 2 con il server";
Log.e("ERRORE","Errore collegamento con il server 2 SendCmd");
}
} else {
index++;
}
}
if (nsocket != null) {
nsocket.close();
}
if (r.result != 0) {
Ret.result = -1;
Ret.errMesg = "Errore collegamento 3 con il server";
Log.e("ERRORE", "Errore collegamento con il server 3 SendCmd");
}
}
} catch (Exception e) {
e.printStackTrace();
Ret.result = -1;
Ret.errMesg = e.getMessage();
}
return Ret;
在SendCmd方法内部调用Connect To Server连接服务器的方法:
private genericresult CollegaAlServer(String Sever, int PortaTCP, int timeout) {
genericresult ret = new genericresult(0, null, BuildConfig.FLAVOR);
try {
SocketAddress sockaddr = new InetSocketAddress(Sever, PortaTCP);
Socket nsocket = new Socket();
for (int index = 0; index < 5; index++) {
nsocket.connect(sockaddr, timeout);
if (nsocket.isConnected()) {
ret.Dati = nsocket;
Log.e("CollegaAlServer","Il socket si è connesso");
break;
}
ret.result = -1;
ret.errMesg = "Errore collegamento con il server";
Log.e("ERRORE","Errore collegamento con il serer, private CollgaAlServer");
}
} catch (Exception e) {
e.printStackTrace();
ret.result = -1;
ret.errMesg = e.getMessage();
}
return ret;
}
使用两个类:network和result generic result
public class genericresult extends fresul {
public Object Dati;
public genericresult(int ret, Object dati, String errormsg) {
super(ret, errormsg);
this.Dati = dati;
}
}
public class networkresult extends fresul {
public String Dati;
public networkresult(int ret, String dati, String errormsg) {
super(ret, errormsg);
this.Dati = dati;
}
}
怎么了?或者缺少什么?
TLVParser 类:
public class TLVParser {
public static String toUTF8(String isoString) {
String utf8String = isoString;
if (isoString == null || isoString.equals(BuildConfig.FLAVOR)) {
return utf8String;
}
try {
return new String(isoString.getBytes(), "UTF-8");
} catch (UnsupportedEncodingException e) {
System.out.println("UnsupportedEncodingException is: " + e.getMessage());
return isoString;
}
}
public static final byte[] intToByteArray(int value) {
return new byte[]{(byte) (value >>> 24), (byte) (value >>> 16), (byte) (value >>> 8), (byte) value};
}
public static void reverse(byte[] array) {
if (array != null) {
int j = array.length - 1;
for (int i = 0; j > i; i++) {
byte tmp = array[j];
array[j] = array[i];
array[i] = tmp;
j--;
}
}
}
public static byte[] readTLV(InputStream tlv, int tag) {
if (tlv == null) {
throw new IllegalArgumentException("Invalid TLV");
}
byte[] vals = null;
try {
int c = tlv.read();
if (c != 1 && c == tag) {
ByteBuffer bb = ByteBuffer.allocate(4);
c = tlv.read();
if (c != -1) {
bb.put((byte) c);
}
c = tlv.read();
if (c != -1) {
bb.put((byte) c);
}
c = tlv.read();
if (c != -1) {
bb.put((byte) c);
}
c = tlv.read();
if (c != -1) {
bb.put((byte) c);
}
int Len = bb.getInt(0);
vals = new byte[Len];
int Residuo = Len;
int MaxRead = AccessibilityNodeInfoCompat.ACTION_NEXT_HTML_ELEMENT;
if (AccessibilityNodeInfoCompat.ACTION_NEXT_HTML_ELEMENT > Residuo) {
MaxRead = Residuo;
}
int offSet = 0;
byte[] bytes = new byte[Len];
while (Residuo > 0) {
while (true) {
int len = tlv.read(bytes, 0, MaxRead);
if (len > 0) {
System.arraycopy(bytes, 0, vals, offSet, len);
offSet += len;
Residuo -= len;
if (MaxRead > Residuo) {
MaxRead = Residuo;
}
}
}
}
}
} catch (Exception e) {
String errmsg = e.getMessage();
e.printStackTrace();
}
return vals;
}
public static byte[][] readTLV(String tlvHexString, int tag) throws Throwable {
return readTLV(hexStringToByteArray(tlvHexString), tag);
}
public static byte[][] readTLV(byte[] tlv, int tag) throws Throwable {
Throwable th;
if (tlv == null || tlv.length < 1) {
throw new IllegalArgumentException("Invalid TLV");
}
ArrayList al = new ArrayList();
ByteArrayInputStream is = null;
try {
ByteArrayInputStream is2 = new ByteArrayInputStream(tlv);
while (true) {
try {
int c = is2.read();
if (c == -1) {
break;
} else if (c == tag) {
ByteBuffer bb = ByteBuffer.allocate(4);
c = is2.read();
if (c != -1) {
bb.put((byte) c);
}
c = is2.read();
if (c != -1) {
bb.put((byte) c);
}
c = is2.read();
if (c != -1) {
bb.put((byte) c);
}
c = is2.read();
if (c != -1) {
bb.put((byte) c);
}
int Len = bb.getInt(0);
byte[] value = new byte[Len];
is2.read(value, 0, Len);
al.add(value);
}
} catch (Throwable th2) {
th = th2;
is = is2;
}
}
if (is2 != null) {
try {
is2.close();
} catch (IOException e) {
}
}
byte[][] vals = new byte[al.size()][];
al.toArray(vals);
return vals;
} catch (Throwable th3) {
th = th3;
if (is != null) {
try {
is.close();
} catch (IOException e2) {
}
}
throw th;
}
}
public static byte[] hexStringToByteArray(String s) {
int len = s.length();
byte[] data = new byte[(len / 2)];
for (int i = 0; i < len; i += 2) {
data[i / 2] = (byte) ((Character.digit(s.charAt(i), 16) << 4) + Character.digit(s.charAt(i + 1), 16));
}
return data;
}
public static int byteArrayToInt(byte[] b, int offset) {
int value = 0;
for (int i = 0; i < 4; i++) {
value += (b[i + offset] & MotionEventCompat.ACTION_MASK) << ((3 - i) * 8);
}
return value;
}
}
**这是我的 LogCat:**
01-13 10:37:09.738 14592-17524/com.edsoft.vrcomande2 W/System.err: java.net.SocketException: Already connected
01-13 10:37:09.743 14592-17524/com.edsoft.vrcomande2 W/System.err: at java.net.Socket.connect(Socket.java:813)
01-13 10:37:09.743 14592-17524/com.edsoft.vrcomande2 W/System.err: at com.edsoft.vrcomande2.ConfigurazioniActivity.SendCmd(ConfigurazioniActivity.java:351)
01-13 10:37:09.743 14592-17524/com.edsoft.vrcomande2 W/System.err: at com.edsoft.vrcomande2.ConfigurazioniActivity.access$600(ConfigurazioniActivity.java:48)
01-13 10:37:09.743 14592-17524/com.edsoft.vrcomande2 W/System.err: at com.edsoft.vrcomande2.ConfigurazioniActivity$SincTask.doInBackground(ConfigurazioniActivity.java:264)
01-13 10:37:09.743 14592-17524/com.edsoft.vrcomande2 W/System.err: at com.edsoft.vrcomande2.ConfigurazioniActivity$SincTask.doInBackground(ConfigurazioniActivity.java:240)
01-13 10:37:09.743 14592-17524/com.edsoft.vrcomande2 W/System.err: at android.os.AsyncTask$2.call(AsyncTask.java:288)
01-13 10:37:09.743 14592-17524/com.edsoft.vrcomande2 W/System.err: at java.util.concurrent.FutureTask.run(FutureTask.java:237)
01-13 10:37:09.743 14592-17524/com.edsoft.vrcomande2 W/System.err: at android.os.AsyncTask$SerialExecutor$1.run(AsyncTask.java:231)
01-13 10:37:09.743 14592-17524/com.edsoft.vrcomande2 W/System.err: at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1112)
01-13 10:37:09.743 14592-17524/com.edsoft.vrcomande2 W/System.err: at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:587)
01-13 10:37:09.743 14592-17524/com.edsoft.vrcomande2 W/System.err: at java.lang.Thread.run(Thread.java:841)
最佳答案
您的问题是在编译时出现的,与服务器或尝试连接到服务器无关。您唯一需要发布以重现错误的是
public class genericresult extends fresul {
public Object Dati;
public genericresult(int ret, Object dati, String errormsg) {
super(ret, errormsg);
this.Dati = dati;
}
}
然后是语句:
genericresult r = new genericresult(0, null, BuildConfig.FLAVOR);
Socket nsocket = r.Dati;
这会给你错误信息 Required java.net.Socket found java.lang.Object
。
所以 Dati 不是 Socket 实例。
其他:
for (int index = 0; index < 5; index++) {
nsocket.connect(sockaddr, timeout);
if (nsocket.isConnected()) {
ret.Dati = nsocket;
break;
}
ret.result = -1;
ret.errMesg = "Errore collegamento con il server";
}
循环尝试五次是没有意义的。一次就够了。然后设置更长的超时时间。
此外,如果第一次尝试超时,您已经设置了结果值和错误消息值,当第二次连接正常时,您不会删除或更改这些值。
关于android - 使用 Android 连接到本地服务器,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/34718731/
我知道这个问题可能已经被问过,但我检查了所有这些,我认为我的情况有所不同(请友善)。所以我有两个数据集,第一个是测试数据集,第二个是我保存在数据框中的预测(预测值,这就是没有数据列的原因)。我想合并两
在 .loc 方法的帮助下,我根据同一数据框中另一列中的值来识别 Panda 数据框中某一列中的值。 下面给出了代码片段供您引用: var1 = output_df['Player'].loc[out
当我在 Windows 中使用 WinSCP 通过 Ubuntu 连接到 VMware 时,它提示: The server rejected SFTP connection, but it lis
我正在开发一个使用 xml web 服务的 android 应用程序。在 wi-fi 网络中连接时工作正常,但在 3G 网络中连接时失败(未找到 http 404)。 这不仅仅发生在设备中。为了进行测
我有一个XIB包含我的控件的文件,加载到 Interface Builder(Snow Leopard 上的 Xcode 4.0.2)中。 文件的所有者被设置为 someClassController
我在本地计算机上管理 MySQL 数据库,并通过运行以下程序通过 C 连接到它: #include #include #include int main(int argc, char** arg
我不知道为什么每次有人访问我网站上的页面时,都会打开一个与数据库的新连接。最终我到达了大约 300 并收到错误并且页面不再加载。我认为它应该工作的方式是,我将 maxIdle 设置为 30,这意味着
希望清理 NMEA GPS 中的 .txt 文件。我当前的代码如下。 deletes = ['$GPGGA', '$GPGSA', '$GPGSV', '$PSRF156', ] searchquer
我有一个 URL、一个用户名和一个密码。我想在 C# .Net WinForms 中建立 VPN 连接。 你能告诉我从哪里开始吗?任何第三方 API? 代码示例将受到高度赞赏... 最佳答案 您可以像
有没有更好的方法将字符串 vector 转换为字符 vector ,字符串之间的终止符为零。 因此,如果我有一个包含以下字符串的 vector "test","my","string",那么我想接收一
我正在编写一个库,它不断检查 android 设备的连接,并在设备连接、断开连接或互联网连接变慢时给出回调。 https://github.com/muddassir235/connection_ch
我的操作系统:Centos 7 + CLOUDLINUX 7.7当我尝试从服务器登录Mysql时 [root@server3 ~]# Mysql -u root -h localhost -P 330
我收到错误:Puma 发现此错误:无法打开到本地主机的 TCP 连接:9200(连接被拒绝 - 连接(2)用于“本地主机”端口 9200)(Faraday::ConnectionFailed)在我的
请给我一些解决以下错误的方法。 这是一个聊天应用....代码和错误如下:: conversations_controller.rb def create if Conversation.bet
我想将两个单元格中的数据连接到一个单元格中。我还想只组合那些具有相同 ID 的单元格。 任务 ID 名称 4355.2 参与者 4355.2 领袖 4462.1 在线 4462.1 快速 4597.1
我经常需要连接 TSQL 中的字段... 使用“+”运算符时 TSQL 强制您处理的两个问题是 Data Type Precedence和 NULL 值。 使用数据类型优先级,问题是转换错误。 1)
有没有在 iPad 或 iPhone 应用程序中使用 Facebook 连接。 这个想法是登录这个应用程序,然后能够看到我的哪些 facebook 用户也在使用该应用程序及其功能。 最佳答案 是的。
我在连接或打印字符串时遇到了一个奇怪的问题。我有一个 char * ,可以将其设置为字符串文字的几个值之一。 char *myStrLiteral = NULL; ... if(blah) myS
对于以下数据 - let $x := "Yahooooo !!!! Select one number - " let $y := 1 2 3 4 5 6 7 我想得到
我正在看 UDEMY for perl 的培训视频,但是视频不清晰,看起来有错误。 培训展示了如何使用以下示例连接 2 个字符串: #!usr/bin/perl print $str = "Hi";
我是一名优秀的程序员,十分优秀!