2. 程式人生 > >apollo實現c#與android消息推送(三)

apollo實現c#與android消息推送(三)

阿新 • • 發佈：2017-10-03
class net names oid urn 服務 mbo target parse

3 實現c#消息推送服務

c#實現消息推送必須引入M2Mqtt.dll，源碼

a 連接apache apollo代理服務器的代碼。需要引入using uPLibrary.Networking.M2Mqtt和 using uPLibrary.Networking.M2Mqtt.Messages,需要註意的是代碼裏的client.Connect裏的admin和password是之前設置apache apollo時設置的用戶名，密碼，請自行修改。apollo實現c#與android消息推送(一)

技術分享 
 //連接apache apollo
        private void LinkClick(object
 
 sender, EventArgs e)
        {
            string clientId = "";
            string ip = "";
            string port = "";
            if (String.IsNullOrEmpty(textBoxCT.Text))
            {
                MessageBox.Show("請輸入客戶機標識！");
                return;
            }
            if (String.IsNullOrEmpty(textBoxAD.Text) && textBoxAD.Text.IndexOf(‘
 
:‘)<=0)
            {
                MessageBox.Show("請輸入IP地址且帶端口號！");
                return;
            }
            clientId = textBoxCT.Text;
            ip = textBoxAD.Text.Substring(0,textBoxAD.Text.IndexOf(‘:‘));
            port = textBoxAD.Text.Substring(textBoxAD.Text.IndexOf(‘:‘)+1);

            
 
try
            {
                client = new MqttClient(IPAddress.Parse(ip), Convert.ToInt32(port), false, null);
                client.Connect(clientId, "admin", "password", false, 0x01, false, null, null, true, 60);//admin和password是之前在apache apollo中設置的用戶名和密碼
                buttonLink.Enabled = false;
                buttonLose.Enabled = true;
                textBoxLS.ForeColor = Color.RoyalBlue;
                textBoxLS.Text = "已連接";
            }
            catch (Exception ee)
            {
                MessageBox.Show("無法連接，請確定代理服務器是否啟動，IP端口是否正確");
            }

        }
View Code

b 發布主題代碼

技術分享 
private void PublishSubmit(object sender, EventArgs e)
        {
            string pubTitle = "";//發布主題
            byte pubQu ;//發布質量

            if (String.IsNullOrEmpty(textBoxPuIt.Text))
            {
                MessageBox.Show("請輸入發布主題！");
                return;
            }
            if (String.IsNullOrEmpty(comboBoxPub.Text))
            {
                MessageBox.Show("請選擇發布主題質量！");
                return;
            }
            pubTitle = textBoxPuIt.Text;

            if (comboBoxPub.Text=="至多一次")
            {
                pubQu = MqttMsgBase.QOS_LEVEL_AT_MOST_ONCE;
            }
            else if (comboBoxPub.Text == "至少一次")
            {
                pubQu = MqttMsgBase.QOS_LEVEL_EXACTLY_ONCE;
            }
            else
            {
                pubQu = MqttMsgBase.QOS_LEVEL_EXACTLY_ONCE;
            }
            try
            {
                topic = pubTitle;
                client.Subscribe(new string[] { pubTitle }, new byte[] { pubQu });
                client.Publish(pubTitle, Encoding.UTF8.GetBytes(richTextBoxMess.Text), MqttMsgBase.QOS_LEVEL_EXACTLY_ONCE,
                       false);
            }
            catch (Exception)
            {
                if (client!=null)
                {
                    client = null;
                }
                MessageBox.Show("已斷開連接，請重新連接！");
            }
        }
View Code

c 訂閱主題代碼

技術分享 
private void SubClick(object sender, EventArgs e)
        {
            string subTitle = "";//發布主題
            byte subQu;//發布質量
            if (String.IsNullOrEmpty(textBoxSub.Text))
            {
                MessageBox.Show("請輸入訂閱主題！");
                return;
            }
            if (String.IsNullOrEmpty(comboBoxSub.Text))
            {
                MessageBox.Show("請選擇訂閱主題質量！");
                return;
            }
            subTitle = textBoxSub.Text;
            if (comboBoxSub.Text == "至多一次")
            {
                subQu = MqttMsgBase.QOS_LEVEL_AT_MOST_ONCE;
            }
            else if (comboBoxSub.Text == "至少一次")
            {
                subQu = MqttMsgBase.QOS_LEVEL_EXACTLY_ONCE;
            }
            else
            {
                subQu = MqttMsgBase.QOS_LEVEL_EXACTLY_ONCE;
            }
            try
            {
                buttonRE.Enabled = false;
                buttonca.Enabled = true;
                topic = subTitle;
                client.Subscribe(new string[] { subTitle }, new byte[] { subQu });
                client.MqttMsgPublishReceived += client_MqttMsgPublishReceived;
            }
            catch (Exception)
            {
                if (client != null)
                {
                    client = null;
                }
                MessageBox.Show("已斷開連接，請重新連接！");
            }
        }
View Code

d 全部代碼

技術分享 
using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Net;
using System.Net.Sockets;
using System.Text;
using System.Threading.Tasks;
using System.Windows.Forms;
using uPLibrary.Networking.M2Mqtt;
using uPLibrary.Networking.M2Mqtt.Messages;

namespace MqttCsharp
{
    public partial class Form1 : Form
    {
        private  MqttClient client;
        private string topic = "";

        private delegate void MessDelegate<T>(T obj);
        public Form1()
        {
            InitializeComponent();
            buttonLose.Enabled = false;
            buttonca.Enabled = false;
        }

        //連接apache apollo
        private void LinkClick(object sender, EventArgs e)
        {
            string clientId = "";
            string ip = "";
            string port = "";
            if (String.IsNullOrEmpty(textBoxCT.Text))
            {
                MessageBox.Show("請輸入客戶機標識！");
                return;
            }
            if (String.IsNullOrEmpty(textBoxAD.Text) && textBoxAD.Text.IndexOf(‘:‘)<=0)
            {
                MessageBox.Show("請輸入IP地址且帶端口號！");
                return;
            }
            clientId = textBoxCT.Text;
            ip = textBoxAD.Text.Substring(0,textBoxAD.Text.IndexOf(‘:‘));
            port = textBoxAD.Text.Substring(textBoxAD.Text.IndexOf(‘:‘)+1);

            try
            {
                client = new MqttClient(IPAddress.Parse(ip), Convert.ToInt32(port), false, null);
                client.Connect(clientId, "admin", "password", false, 0x01, false, null, null, true, 60);//admin和password是之前在apache apollo中設置的用戶名和密碼
                buttonLink.Enabled = false;
                buttonLose.Enabled = true;
                textBoxLS.ForeColor = Color.RoyalBlue;
                textBoxLS.Text = "已連接";
            }
            catch (Exception ee)
            {
                MessageBox.Show("無法連接，請確定代理服務器是否啟動，IP端口是否正確");
            }

        }
        //斷開apache apollo連接
        private void CloseLink(object sender, EventArgs e)
        {
            if (client !=null && client.IsConnected)
            {
                client.Disconnect();
                client = null;
                buttonLink.Enabled = true;
                buttonLose.Enabled = false;
                textBoxLS.ForeColor = Color.Firebrick;
                textBoxLS.Text = "斷開連接";
            }

        }
        //發布按鈕的點擊事件
        private void PublishSubmit(object sender, EventArgs e)
        {
            string pubTitle = "";//發布主題
            byte pubQu ;//發布質量

            if (String.IsNullOrEmpty(textBoxPuIt.Text))
            {
                MessageBox.Show("請輸入發布主題！");
                return;
            }
            if (String.IsNullOrEmpty(comboBoxPub.Text))
            {
                MessageBox.Show("請選擇發布主題質量！");
                return;
            }
            pubTitle = textBoxPuIt.Text;

            if (comboBoxPub.Text=="至多一次")
            {
                pubQu = MqttMsgBase.QOS_LEVEL_AT_MOST_ONCE;
            }
            else if (comboBoxPub.Text == "至少一次")
            {
                pubQu = MqttMsgBase.QOS_LEVEL_EXACTLY_ONCE;
            }
            else
            {
                pubQu = MqttMsgBase.QOS_LEVEL_EXACTLY_ONCE;
            }
            try
            {
                topic = pubTitle;
                client.Subscribe(new string[] { pubTitle }, new byte[] { pubQu });
                client.Publish(pubTitle, Encoding.UTF8.GetBytes(richTextBoxMess.Text), MqttMsgBase.QOS_LEVEL_EXACTLY_ONCE,
                       false);
            }
            catch (Exception)
            {
                if (client!=null)
                {
                    client = null;
                }
                MessageBox.Show("已斷開連接，請重新連接！");
            }
        }
        //訂閱按鈕
        private void SubClick(object sender, EventArgs e)
        {
            string subTitle = "";//發布主題
            byte subQu;//發布質量
            if (String.IsNullOrEmpty(textBoxSub.Text))
            {
                MessageBox.Show("請輸入訂閱主題！");
                return;
            }
            if (String.IsNullOrEmpty(comboBoxSub.Text))
            {
                MessageBox.Show("請選擇訂閱主題質量！");
                return;
            }
            subTitle = textBoxSub.Text;
            if (comboBoxSub.Text == "至多一次")
            {
                subQu = MqttMsgBase.QOS_LEVEL_AT_MOST_ONCE;
            }
            else if (comboBoxSub.Text == "至少一次")
            {
                subQu = MqttMsgBase.QOS_LEVEL_EXACTLY_ONCE;
            }
            else
            {
                subQu = MqttMsgBase.QOS_LEVEL_EXACTLY_ONCE;
            }
            try
            {
                buttonRE.Enabled = false;
                buttonca.Enabled = true;
                topic = subTitle;
                client.Subscribe(new string[] { subTitle }, new byte[] { subQu });
                client.MqttMsgPublishReceived += client_MqttMsgPublishReceived;
            }
            catch (Exception)
            {
                if (client != null)
                {
                    client = null;
                }
                MessageBox.Show("已斷開連接，請重新連接！");
            }
        }
        void client_MqttMsgPublishReceived(object sender, MqttMsgPublishEventArgs e)
        {
            //處理接收到的消息
            string msg = Encoding.UTF8.GetString(e.Message);
            ShowMess(msg);
        }
        //列表顯示
        private void ShowMess(string msg)
        {
            if (InvokeRequired)
            {
                BeginInvoke(new MessDelegate<string>(ShowMess), msg);
            }
            else
            {
                ListViewItem item = new ListViewItem(new string[]
                {
                    topic,msg,DateTime.Now.ToString()
                });

                listViewMess.Items.Insert(0, item);
            }
           
        }

        private void CancelSubClick(object sender, EventArgs e)
        {
            try
            {
                if (client.IsConnected)
                {
                    client.Unsubscribe(new string[] { topic });
                }
                buttonRE.Enabled = true;
                buttonca.Enabled = false;
            }
            catch (Exception)
            {
                if (client != null)
                {
                    client = null;
                }
                MessageBox.Show("已斷開連接，請重新連接！");
            }
        }
    }
}
View Code

apollo實現c#與android消息推送(三)

相關推薦

apollo實現c#與android消息推送(三)

class net names oid urn 服務 mbo target parse 3 實現c#消息推送服務 c#實現消息推送必須引入M2Mqtt.dll，源碼 a 連接apache apollo代理服務器的代碼。需要引入using uPLibrar

springboot實現服務器端消息推送（websocket + sockjs + stomp）

client rem queue rip rsa socket gin enabled lis 　　服務器端推送技術在web開發中比較常用，可能早期很多人的解決方案是采用ajax向服務器輪詢消息，這種方式的輪詢頻率不好控制，所以大大增加了服務器的壓力，後來有了下面的方案

java實現後臺服務器消息推送

cat session 原理 public ntb socket通訊 func .get ora 1.什麽是WebSocketWebSocket協議是基於TCP的一種新的網絡協議。它實現了瀏覽器與服務器全雙工(full-duplex)通信——允許服務器主動發送信息給客戶端。

iOS開發——遠程消息推送的實現

ice 分享 mit load con targe you 取消 tex 在我們使用App的過程中。總是會收到非常多的消息推送。今天我們就要來實現這個功能。首先消息推送分為本地消息推送和遠程消息推送。而當中又以遠程消息最為經常使用。可是在推送遠程消息之前。

Android 基於Netty的消息推送方案之概念和工作原理(二)

img b2c 決定 watermark net nios 通道 感覺 art 上一篇文章中我講述了關於消息推送的方案以及一個基於Netty實現的一個簡單的Hello World。為了更好的理解Hello World中的代碼，今天我來解說一下關於Netty中一些概念和工

vue js 和signalr 結合實現消息推送1

ack all client aspnet 由於 user startup man logs 由於signalr2.2.0 依賴於jQuery,雖然在vuejs 略顯臃腫， 但是對於目前剛接觸 vuejs 和想實現 前後分離的我來說 這已經很好了。目前先實現功能， 然後如果

MQTT是IBM開發的一個即時通訊協議，構建於TCP/IP協議上，是物聯網IoT的訂閱協議，借助消息推送功能，可以更好地實現遠程控制

集合 cap 消息處理 簡易 遠程控制 mes ogr 設計思想 成本 最近一直做物聯網方面的開發，以下內容關於使用MQTT過程中遇到問題的記錄以及需要掌握的機制原理,主要講解理論。 背景 MQTT是IBM開發的一個即時通訊協議。MQTT構建於TCP/IP協議上

Android Mqtt 消息推送使用

time lean listen tid let valueof idc ktr ans 初始化SDK： /** * 初始化SDK * * @param context context */ public void init

WebSocket與消息推送

加密 sin exp 安裝flash throwable tin pat 允許 被調用 轉自張果原文 WebSocket與消息推送 B/S結構的軟件項目中有時客戶端需要實時的獲得服務器消息，但默認HTTP協議只支持請求響應模式，這樣做可以簡化Web服務器，減少服

Java 消息推送------GoEasy實現服務端推送和web端推送

subscribe rip world 查詢 start easy 需要 註冊 註意 項目中需要消息推送，又想較低開發成本，具體需求：角色用戶在後臺管理頁面發布一個消息，所有用這個系統的用戶無論在哪個頁面都能及時收到他發布的消息，後來我在網上查詢到了一個第三方的免費推送服務

全終端消息推送解決方案--調研與可行性分析報告

過程 AD 小型企業 工作模式 優先級 終端 華為 直接 item 題目要求 請確定本團隊項目的所有利益相關者，把調研結果發布到團隊博客中 請團隊所有成員針對目標用戶確定需求調查提綱，並進行需求調研，可以采取各種你認為可行的方法，並把調研過程和結果發布到團隊博客中 請確定

C# 數據推送 實時數據推送 輕量級消息訂閱發布 多級消息推送 分布式推送

特性 style 群聊 開始 AC 消息訂閱 進度 都在 多人 前言 本文將使用一個NuGet公開的組件技術來實現數據訂閱推送功能，由服務器進行推送數據，客戶端訂閱指定的數據後，即可以接收服務器推送過來的數據，包含了自動重連功能，使用非常方便 nuget地址：https

spring websocket 和socketjs實現單聊群聊,廣播的消息推送詳解

退出 rec oid -name 返回 classes sockets 們的 tomcat7.0 spring websocket 和socketjs實現單聊群聊,廣播的消息推送詳解 WebSocket簡單介紹 　　隨著互聯網的發展，傳統的HTTP協議已經很難滿足Web應用

企業微信簡單實現消息推送

message util 用戶 service auth _id tpc sea agen 廢話不多說，上來就堆代碼.......... 感覺挺簡單，就不過多解釋，應該一看就懂..... import java.io.IOException; import java.te

apicloud 消息推送與接收

odin community 記得 參考 ppk 用戶登錄 androi 發送通知 apk 待解決的問題，如下： 　　在使用apicloud 的時候我們，在開發用戶登錄的時候可能會遇到這樣的問題，當有2個設備a，b同事使用的app的時候並且是同一個人登錄，我們需要去做判斷，

C# 之小程序 webapi 認證 微信小程序CheckSignature 消息推送

return 程序 登錄 apps 平臺 ger file app bubuko 微信小程序想實現 模板消息推送的話 1.登錄到微信公眾平臺 - 小程序 - 開發 - 開發設置 。 找到消息推送 2.驗證消息的確來自微信服務器 微信只提供了ph

消息推送二 之webSocket

還需 由於 else har 頁面 try window class logs 友情提示： 消息推送的介紹可以參考http://www.cnblogs.com/dahuandan/p/6816173.html 什麽是webSocket webSocket是為解決客

GoBelieve IM 消息推送的方案

apn dem 所有 消息 做的 pan 切換 賬戶 mic 消息推送設計方案如下： 所有接入im SDK的deviceTOken都會存儲到IM服務器。就可以 IM服務器來根據你們服務器指定的useId來下發消息。判斷客戶端在線，並且APP在前臺。就是socket下發，IM

細說 iOS 消息推送

not 個數 text payload 自己 是否 coffee reserve use APNS的推送機制 與Android上我們自己實現的推送服務不一樣，Apple對設備的控制很嚴格。消息推送的流程必需要經過APNs： 這裏 Provider 是指某個應用的

asp.net web 通過IHttpAsyncHandler接口進行消息推送

authent div reg ret back sig sts content validate 1.創建Comet_by_ASP.NET web項目 2.handler類和result類 namespace Handle { /// <summary&g