MQTT服务错误&Quot；套接字失败：EPERM&Quot；
这是我的MQTTCONECTION课程
public class MQTTService extends Service {
private static final String TAG = "MQTTService";
private static boolean hasWifi = false;
private static boolean hasMmobile = false;
private Thread thread;
private ConnectivityManager mConnMan;
private volatile IMqttAsyncClient mqttClient;
private String deviceId;
class MQTTBroadcastReceiver extends BroadcastReceiver {
@Override
public void onReceive(Context context, Intent intent) {
IMqttToken token;
boolean hasConnectivity = false;
boolean hasChanged = false;
NetworkInfo infos[] = mConnMan.getAllNetworkInfo();
for (int i = 0; i < infos.length; i++){
if (infos[i].getTypeName().equalsIgnoreCase("MOBILE")){
if((infos[i].isConnected() != hasMmobile)){
hasChanged = true;
hasMmobile = infos[i].isConnected();
}
Log.d(TAG, infos[i].getTypeName() + " is " + infos[i].isConnected());
} else if ( infos[i].getTypeName().equalsIgnoreCase("WIFI") ){
if((infos[i].isConnected() != hasWifi)){
hasChanged = true;
hasWifi = infos[i].isConnected();
}
Log.d(TAG, infos[i].getTypeName() + " is " + infos[i].isConnected());
}
}
hasConnectivity = hasMmobile || hasWifi;
Log.v(TAG, "hasConn: " + hasConnectivity + " hasChange: " + hasChanged + " - "+(mqttClient == null || !mqttClient.isConnected()));
if (hasConnectivity && hasChanged && (mqttClient == null || !mqttClient.isConnected())) {
//Log.d(TAG, "Llama a la función doConnect");
doConnect();
} else if (!hasConnectivity && mqttClient != null && mqttClient.isConnected()) {
Log.d(TAG, "doDisconnect()");
try {
token = mqttClient.disconnect();
token.waitForCompletion(1000);
} catch (MqttException e) {
e.printStackTrace();
}
}
}
};
public class MQTTBinder extends Binder {
public MQTTService getService(){
return MQTTService.this;
}
}
@Override
public void onCreate() {
IntentFilter intentf = new IntentFilter();
setClientID();
intentf.addAction(ConnectivityManager.CONNECTIVITY_ACTION);
registerReceiver(new MQTTBroadcastReceiver(), new IntentFilter(ConnectivityManager.CONNECTIVITY_ACTION));
mConnMan = (ConnectivityManager) getSystemService(CONNECTIVITY_SERVICE);
}
@Override
public void onConfigurationChanged(Configuration newConfig) {
Log.d(TAG, "onConfigurationChanged()");
android.os.Debug.waitForDebugger();
super.onConfigurationChanged(newConfig);
}
private void setClientID(){
WifiManager wifiManager = (WifiManager) getSystemService(Context.WIFI_SERVICE);
WifiInfo wInfo = wifiManager.getConnectionInfo();
deviceId = wInfo.getMacAddress();
if(deviceId == null){
deviceId = MqttAsyncClient.generateClientId();
}
}
private void doConnect(){
IMqttToken token;
MqttConnectOptions options = new MqttConnectOptions();
options.setCleanSession(true);
//StrictMode.setThreadPolicy(new StrictMode.ThreadPolicy.Builder().detectDiskReads().detectDiskWrites().detectNetwork().penaltyLog().build());
try {
mqttClient = new MqttAsyncClient("tcp://192.168.0.9:1883", deviceId, new MemoryPersistence());
token = mqttClient.connect();
token.waitForCompletion(3500);
mqttClient.setCallback(new MqttEventCallback());
token = mqttClient.subscribe("test", 0);
token.waitForCompletion(5000);
token.setActionCallback(new IMqttActionListener() {
@Override
public void onSuccess(IMqttToken asyncActionToken) {
Log.d(TAG, "Si se conecto");
/*String mensaje = "Conchita";
byte[] mensajeB = mensaje.getBytes(UTF_8);
MqttMessage mqttMessage = new MqttMessage(mensajeB);
try {
mqttClient.publish("test", mqttMessage);
} catch (MqttException e) {
e.printStackTrace();
}*/
}
@Override
public void onFailure(IMqttToken asyncActionToken, Throwable exception) {
Log.d(TAG, "Que nel");
}
});
} catch (MqttSecurityException e) {
e.printStackTrace();
} catch (MqttException e) {
switch (e.getReasonCode()) {
case MqttException.REASON_CODE_BROKER_UNAVAILABLE:
Log.d(TAG, "The broker was not available to handle the request.");
break;
case MqttException.REASON_CODE_CLIENT_ALREADY_DISCONNECTED:
Log.d(TAG, "The client is already disconnected.");
break;
case MqttException.REASON_CODE_CLIENT_CLOSED:
Log.d(TAG, "The client is closed - no operations are permitted on the client in this state.");
break;
case MqttException.REASON_CODE_CLIENT_DISCONNECT_PROHIBITED:
Log.d(TAG, "Thrown when an attempt to call MqttClient.disconnect() has been made from within a method on MqttCallback.");
break;
case MqttException.REASON_CODE_CLIENT_DISCONNECTING:
Log.d(TAG, "The client is currently disconnecting and cannot accept any new work.");
break;
case MqttException.REASON_CODE_CLIENT_EXCEPTION:
Log.d(TAG, "Client encountered an exception.");
System.out.println("Cause of Exception: "
+ e.getCause());
break;
case MqttException.REASON_CODE_CLIENT_NOT_CONNECTED:
Log.d(TAG, "The client is not connected to the server.");
break;
case MqttException.REASON_CODE_CLIENT_TIMEOUT:
Log.d(TAG, "Client timed out while waiting for a response from the server.");
break;
case MqttException.REASON_CODE_CONNECT_IN_PROGRESS:
Log.d(TAG, "A connect operation in already in progress, only one connect can happen at a time.");
break;
case MqttException.REASON_CODE_CONNECTION_LOST:
Log.d(TAG, "The client has been unexpectedly disconnected from the server.");
break;
case MqttException.REASON_CODE_DISCONNECTED_BUFFER_FULL:
Log.d(TAG, "The Client has attempted to publish a message whilst in the 'resting' / ");
break;
case MqttException.REASON_CODE_FAILED_AUTHENTICATION:
Log.d(TAG, "Client encountered an exception.");
break; //
case MqttException.REASON_CODE_INVALID_CLIENT_ID:
Log.d(TAG, "The server has rejected the supplied client ID");
break;
case MqttException.REASON_CODE_INVALID_MESSAGE:
Log.d(TAG, "Protocol error: the message was not recognized as a valid MQTT packet.");
break;
case MqttException.REASON_CODE_INVALID_PROTOCOL_VERSION:
Log.d(TAG, "The protocol version requested is not supported by the server.");
break;
case MqttException.REASON_CODE_MAX_INFLIGHT:
Log.d(TAG, "A request has been made to send a message but the maximum number of inflight messages has already been reached.");
break;
case MqttException.REASON_CODE_NO_MESSAGE_IDS_AVAILABLE:
Log.d(TAG, "Internal error, caused by no new message IDs being available.");
break;
case MqttException.REASON_CODE_NOT_AUTHORIZED:
Log.d(TAG, "ot authorized to perform the requested operation");
break;//--
case MqttException.REASON_CODE_SERVER_CONNECT_ERROR:
Log.d(TAG, "Unable to connect to server");
break;
case MqttException.REASON_CODE_SOCKET_FACTORY_MISMATCH:
Log.d(TAG, "Server URI and supplied SocketFactory do not match.");
break;
case MqttException.REASON_CODE_SSL_CONFIG_ERROR:
Log.d(TAG, "SSL configuration error.");
break;
case MqttException.REASON_CODE_SUBSCRIBE_FAILED:
Log.d(TAG, "Error from subscribe - returned from the server.");
break;
case MqttException. REASON_CODE_TOKEN_INUSE:
Log.d(TAG, "A request has been made to use a token that is already associated with another action.");
break;
case MqttException.REASON_CODE_UNEXPECTED_ERROR:
Log.d(TAG, "An unexpected error has occurred.");
break;//--
case MqttException.REASON_CODE_WRITE_TIMEOUT:
Log.d(TAG, "Client timed out while waiting to write messages to the server.");
break;//--
/*case MqttException.REASON_CODE_SERVER_CONNECT_ERROR:
Log.d(TAG, "c" +e.getMessage());
e.printStackTrace();
break;
case MqttException.REASON_CODE_FAILED_AUTHENTICATION:
Intent i = new Intent("RAISEALLARM");
i.putExtra("ALLARM", e);
Log.d(TAG, "b"+ e.getMessage());
break;*/
default:
Log.e(TAG, "a_" + e.getMessage());
}
}
}
@Override
public int onStartCommand(Intent intent, int flags, int startId) {
Log.v(TAG, "onStartCommand()");
return START_STICKY;
}
private class MqttEventCallback implements MqttCallback {
@Override
public void connectionLost(Throwable arg0) {
}
@Override
public void deliveryComplete(IMqttDeliveryToken arg0) {
}
@Override
@SuppressLint("NewApi")
public void messageArrived(String topic, final MqttMessage msg) throws Exception {
Log.i(TAG, "Message arrived from topic" + topic);
Handler h = new Handler(getMainLooper());
h.post(new Runnable() {
@Override
public void run() {
Intent launchA = new Intent(MQTTService.this, MainActivity.class);
launchA.putExtra("message", msg.getPayload());
//TODO write somethinkg that has some sense
if(Build.VERSION.SDK_INT >= 11){
launchA.addFlags(Intent.FLAG_ACTIVITY_NEW_TASK|Intent.FLAG_ACTIVITY_REORDER_TO_FRONT|Intent.FLAG_ACTIVITY_NO_ANIMATION);
} /*else {
launchA.addFlags(Intent.FLAG_ACTIVITY_NEW_TASK);
}*/
startActivity(launchA);
Toast.makeText(getApplicationContext(), "MQTT Message:
" + new String(msg.getPayload()), Toast.LENGTH_SHORT).show();
}
});
}
}
public String getThread(){
return Long.valueOf(thread.getId()).toString();
}
@Override
public IBinder onBind(Intent intent) {
Log.i(TAG, "onBind called");
return null;
}
}
这是我的主要活动：
public class MainActivity extends AppCompatActivity {
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_main);
Intent mymqttservice_intent = new Intent(this, MQTTService.class);
startService(mymqttservice_intent);
}
}
和清单文件：
<?xml version="1.0" encoding="utf-8"?>
<manifest xmlns:android="http://schemas.android.com/apk/res/android"
package="com.example.serviciomqtt_2">
<uses-permission android:name="android.permission.ACCESS_WIFI_STATE" />
<uses-permission android:name="android.permission.ACCESS_NETWORK_STATE"/>
<uses-permission android:name="android.permission.ACCESS_INTERNET"/>
<application
android:allowBackup="true"
android:icon="@mipmap/ic_launcher"
android:label="@string/app_name"
android:roundIcon="@mipmap/ic_launcher_round"
android:supportsRtl="true"
android:usesCleartextTraffic="true"
android:theme="@style/AppTheme">
<service
android:enabled="true"
android:name="MQTTService"
/>
<activity android:name=".MainActivity">
<intent-filter>
<action android:name="android.intent.action.MAIN" />
<category android:name="android.intent.category.LAUNCHER" />
</intent-filter>
</activity>
</application>
</manifest>
我正在使用API 29，此外，MOSquitto MQTT Broker处于活动状态
Status Mosquitto Broker
当我运行应用程序时，出现下一个错误：
I/System.out：异常原因：java.net.SocketException：套接字失败：EPERM(不允许操作)
解决方案
替换：
<uses-permission android:name="android.permission.ACCESS_INTERNET"/>
使用：
<uses-permission android:name="android.permission.INTERNET"/>
相关文章