[code lang=”java”]<\/p>\n
package com.example.myapplication;<\/p>\n
import android.support.v7.app.ActionBarActivity;
\nimport android.os.Bundle;
\nimport android.view.Menu;
\nimport android.view.MenuItem;
\nimport android.view.View;
\nimport android.widget.EditText;
\nimport android.widget.Toast;<\/p>\n
import org.eclipse.paho.client.mqttv3.IMqttDeliveryToken;
\nimport org.eclipse.paho.client.mqttv3.MqttCallback;
\nimport org.eclipse.paho.client.mqttv3.MqttClient;
\nimport org.eclipse.paho.client.mqttv3.MqttConnectOptions;
\nimport org.eclipse.paho.client.mqttv3.MqttMessage;
\nimport org.eclipse.paho.client.mqttv3.persist.MemoryPersistence;<\/p>\n
public class MainActivity extends ActionBarActivity implements MqttCallback{<\/p>\n
private MqttClient mqttClient;<\/p>\n
@Override
\n protected void onCreate(Bundle savedInstanceState) {
\n super.onCreate(savedInstanceState);
\n setContentView(R.layout.activity_main);
\n }<\/p>\n
@Override
\n public boolean onCreateOptionsMenu(Menu menu) {
\n \/\/ Inflate the menu; this adds items to the action bar if it is present.
\n getMenuInflater().inflate(R.menu.menu_main, menu);
\n return true;
\n }<\/p>\n
@Override
\n public boolean onOptionsItemSelected(MenuItem item) {
\n \/\/ Handle action bar item clicks here. The action bar will
\n \/\/ automatically handle clicks on the Home\/Up button, so long
\n \/\/ as you specify a parent activity in AndroidManifest.xml.
\n int id = item.getItemId();<\/p>\n
\/\/noinspection SimplifiableIfStatement
\n if (id == R.id.action_settings) {
\n return true;
\n }<\/p>\n
return super.onOptionsItemSelected(item);
\n }<\/p>\n
public void clickButton(View button){
\n switch (button.getId()){
\n case R.id.register:
\n new Thread(new Runnable() {
\n @Override
\n public void run() {
\n int qos = 2;
\n String broker = "tcp:\/\/iot.eclipse.org:1883";
\n EditText editTextID = (EditText)findViewById(R.id.id);
\n String clientId = editTextID.getText().toString();
\n MemoryPersistence persistence = new MemoryPersistence();
\n try{
\n mqttClient = new MqttClient(broker, clientId, persistence);
\n MqttConnectOptions connOpts = new MqttConnectOptions();
\n connOpts.setCleanSession(true);
\n mqttClient.connect(connOpts);
\n mqttClient.subscribe(clientId);
\n mqttClient.setCallback(MainActivity.this);
\n runOnUiThread(new Runnable() {
\n public void run() {
\n Toast.makeText(getApplicationContext(), mqttClient.isConnected() ? "\u8fde\u63a5\u6210\u529f" : "\u8fde\u63a5\u5931\u8d25", Toast.LENGTH_LONG).show();
\n }
\n });
\n }
\n catch (Exception e){
\n e.printStackTrace();
\n }<\/p>\n
}
\n }).start();
\n break;
\n case R.id.send:
\n EditText editTextTargetID =(EditText)findViewById(R.id.targetID);
\n final String targetID = editTextTargetID.getText().toString();
\n String content = ((EditText)findViewById(R.id.content)).getText().toString();
\n final MqttMessage message = new MqttMessage(content.getBytes());
\n if(mqttClient==null || !mqttClient.isConnected()){
\n Toast.makeText(getApplicationContext(),"MQTT\u672a\u8fde\u63a5",Toast.LENGTH_LONG).show();
\n return;
\n }
\n new Thread(new Runnable() {
\n @Override
\n public void run() {
\n try{
\n mqttClient.publish(targetID, message);
\n }
\n catch (Exception e){
\n e.printStackTrace();
\n }
\n }
\n }).start();
\n break;
\n }
\n }<\/p>\n
@Override
\n public void connectionLost(final Throwable cause) {
\n this.runOnUiThread(new Runnable() {
\n public void run() {
\n Toast.makeText(getApplicationContext(), "\u5931\u53bb\u8fde\u63a5\uff1a" + cause.getMessage(), Toast.LENGTH_LONG).show();
\n }
\n });
\n }<\/p>\n
@Override
\n public void messageArrived(String topic, MqttMessage message)
\n throws Exception {
\n final String msg = new String(message.getPayload());
\n this.runOnUiThread(new Runnable() {
\n public void run() {
\n Toast.makeText(getApplicationContext(), "\u6536\u5230:"+msg, Toast.LENGTH_LONG).show();
\n }
\n });
\n }<\/p>\n
@Override
\n public void deliveryComplete(IMqttDeliveryToken token) {
\n try {
\n final String msg = new String(token.getMessage().getPayload());
\n this.runOnUiThread(new Runnable() {
\n public void run() {
\n Toast.makeText(getApplicationContext(), "\u53d1\u9001\u5b8c\u6bd5:" + msg, Toast.LENGTH_LONG).show();
\n }
\n });
\n }
\n catch (Exception e){
\n e.printStackTrace();
\n }
\n }<\/p>\n
}<\/p>\n
[\/code]<\/p>\n
<\/p>\n
[code lang=”xml”]<\/p>\n
<LinearLayout xmlns:android="http:\/\/schemas.android.com\/apk\/res\/android"
\n xmlns:tools="http:\/\/schemas.android.com\/tools" android:layout_width="match_parent"
\n android:layout_height="match_parent" android:paddingLeft="@dimen\/activity_horizontal_margin"
\n android:paddingRight="@dimen\/activity_horizontal_margin"
\n android:paddingTop="@dimen\/activity_vertical_margin"
\n android:paddingBottom="@dimen\/activity_vertical_margin"
\n android:orientation="vertical"
\n tools:context=".MainActivity"><\/p>\n
<LinearLayout
\n android:layout_width="fill_parent"
\n android:layout_height="50dp"
\n android:orientation="horizontal"><\/p>\n
<TextView
\n android:layout_width="50dp"
\n android:layout_height="fill_parent"
\n android:gravity="center"
\n android:text="ID:"\/><\/p>\n
<EditText
\n android:id="@+id\/id"
\n android:layout_width="100dp"
\n android:layout_height="fill_parent" \/><\/p>\n
<Button
\n android:id="@+id\/register"
\n android:layout_width="wrap_content"
\n android:layout_height="fill_parent"
\n android:text="register"
\n android:layout_alignParentLeft="true"
\n android:layout_alignParentStart="true"
\n android:onClick="clickButton" \/><\/p>\n
<\/LinearLayout><\/p>\n
<LinearLayout
\n android:layout_width="fill_parent"
\n android:layout_height="50dp"
\n android:orientation="horizontal">
\n <TextView
\n android:layout_width="80dp"
\n android:layout_height="fill_parent"
\n android:gravity="center"
\n android:text="\u63a5\u6536\u65b9ID:"\/>
\n <EditText
\n android:id="@+id\/targetID"
\n android:layout_width="50dp"
\n android:layout_height="fill_parent" \/>
\n <TextView
\n android:layout_width="40dp"
\n android:layout_height="fill_parent"
\n android:gravity="center"
\n android:text="\u5185\u5bb9:"\/>
\n <EditText
\n android:id="@+id\/content"
\n android:layout_width="100dp"
\n android:layout_height="fill_parent" \/>
\n <Button
\n android:text="Send"
\n android:id="@+id\/send"
\n android:layout_width="wrap_content"
\n android:layout_height="fill_parent"
\n android:layout_below="@+id\/textView"
\n android:layout_alignParentLeft="true"
\n android:layout_alignParentStart="true"
\n android:onClick="clickButton" \/>
\n <\/LinearLayout><\/p>\n
<\/LinearLayout><\/p>\n
[\/code]<\/p>\n","protected":false},"excerpt":{"rendered":"
[code lang=”java”] package com.example.myap […]<\/p>\n","protected":false},"author":1,"featured_media":0,"comment_status":"closed","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[24],"tags":[25,36,37],"class_list":["post-150","post","type-post","status-publish","format-standard","hentry","category-android","tag-android-2","tag-mqtt","tag-paho"],"_links":{"self":[{"href":"https:\/\/www.lixiaodong.com\/index.php?rest_route=\/wp\/v2\/posts\/150","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/www.lixiaodong.com\/index.php?rest_route=\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/www.lixiaodong.com\/index.php?rest_route=\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/www.lixiaodong.com\/index.php?rest_route=\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/www.lixiaodong.com\/index.php?rest_route=%2Fwp%2Fv2%2Fcomments&post=150"}],"version-history":[{"count":3,"href":"https:\/\/www.lixiaodong.com\/index.php?rest_route=\/wp\/v2\/posts\/150\/revisions"}],"predecessor-version":[{"id":153,"href":"https:\/\/www.lixiaodong.com\/index.php?rest_route=\/wp\/v2\/posts\/150\/revisions\/153"}],"wp:attachment":[{"href":"https:\/\/www.lixiaodong.com\/index.php?rest_route=%2Fwp%2Fv2%2Fmedia&parent=150"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.lixiaodong.com\/index.php?rest_route=%2Fwp%2Fv2%2Fcategories&post=150"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.lixiaodong.com\/index.php?rest_route=%2Fwp%2Fv2%2Ftags&post=150"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}