電子發(fā)燒友網(wǎng)>電子資料下載>電子資料>VnanoMsg Android Socket通訊庫

VnanoMsg Android Socket通訊庫

2513674 2022-06-10 | zip | 0.65 MB | 次下載 | 2積分

普通下載普通下載

資料介紹

授權協(xié)議 Apache

開發(fā)語言 Kotlin C/C++

操作系統(tǒng) Android

軟件類型開源軟件

所屬分類手機/移動開發(fā)、手機開發(fā)包

軟件簡介

VNanoMsg是Android下的Socket通訊庫，對NanoMsg的二次封裝，仿照NNanoMsg的第三方開源庫。

使用方法

添加依賴項

在build.gradle中加入VNanoMsg的引用

	android { 
	  allprojects {
	     repositories {
	       maven { url 'https://jitpack.io' }
	     }
	  }
	} 

	dependencies {
	    implementation 'com.github.Vaccae:VNanoMsg:1.0.3'
	}

核心函數(shù)

創(chuàng)建對應的通訊模式

//PAIR通訊模式
var nn = NNPAIR()

//BUS通訊模式
var nn = NNBUS()

//REQREP模式
var nn = NNREQREP()

//PUBSUB模式
var nn = NNPUBSUB()

//SURVEY模式
var nn = NNSURVEY()

//PipeLine中的Push模式
var nn - NNPIPEPUSH()

//PipeLine中的Pull模式
var nn - NNPIPEPULL()

綁定地址（服務端）

//綁定地址  地址要寫全如上  tcp://加地址
//返回是 bool  ture是成功  false是失敗
var res = nn.bind("tcp://*:8080")

連接服務端

//連接服務端  地址要寫全如上  tcp://加地址
//返回是 bool  ture是成功  false是失敗
var res = nn.connect("tcp://localhost:8080")

發(fā)送數(shù)據(jù)

//發(fā)送數(shù)據(jù)  String
//返回值：發(fā)送的字節(jié)數(shù) Int
var res = nn.send("你好")

//發(fā)送數(shù)據(jù)  ByteArray
//返回值：發(fā)送的字節(jié)數(shù)
val msg = "你好"
val bytes = msg.toByteArray()
var res = nn.send(bytes)

接收數(shù)據(jù)

//接慢數(shù)據(jù)
//返回值：接收到字符串 String
var res = nn.recv()

//接收數(shù)據(jù)  
//返回值：接收的數(shù)據(jù) ByteArray
var res = nn.recvbyte()
val msg = res.toString(charset = Charsets.UTF_8)

設置/取消訂閱前綴

==訂閱消息只針對PUBSUB模式才有的參數(shù)==

//設置訂閱前綴
//返回值：大于0成功，小于0失敗 Int
var res = nn.subscribe("輸入要訂閱的主題字符串"）
    
//取消訂閱前綴
//返回值：大于0成功，小于0失敗 Int
var res = nn.unsubscribe("輸入要取消訂閱的主題字符串")

特別說明

==執(zhí)行連接、發(fā)送、接收數(shù)據(jù)時需要加上try catch防止程序崩潰，因為在NDK中接收失敗或是發(fā)送失敗時我都會直接拋出異常來
==

	try {
	  //發(fā)送數(shù)據(jù)
	  it?.send(edtinput.text.toString())
	  //延時50毫秒
	  Thread.sleep(50)
	  //接收數(shù)據(jù)
	  val recvmsg = it?.recv()
	  tvmsg.append(recvmsg + "\r\n")
	} catch (e: IllegalArgumentException) {
	  tvmsg.append(e.message.toString() + "\r\n")
	}

簡單例子

這里用的是REQREP的模式，別的模式就是在創(chuàng)建時設置對應的類即可。

	class REQREPActivity : AppCompatActivity() {
	
	    private var nnreqrep: NNREQREP? = null
	
	
  	  override fun onCreate(savedInstanceState: Bundle?) {
   	     super.onCreate(savedInstanceState)
   	     setContentView(R.layout.activity_reqrep)
	
  	      //連接按鈕
   	     btnConnent.setOnClickListener {
   	         if (nnreqrep == null) {
  	              nnreqrep = NNREQREP()
   	         }
   	         nnreqrep.let {
   	             try {
   	                 if (it?.connect(edtipadr.text.toString())!!) {
   	                     tvmsg.append("REQREP連接成功！\r\n")
   	                 } else {
   	                     tvmsg.append("REQREP連接失敗！\r\n")
   	                 }
   	             } catch (e: IllegalArgumentException) {
   	                 tvmsg.append(e.message.toString() + "\r\n")
   	             }
   	         }
   	     }
				 	
      	  //發(fā)送按鈕
  	      btnSend.setOnClickListener {
   	         nnreqrep.let {
   	             try {
   	                 val input = edtinput.text.toString()
   	                 val bytes = input.toByteArray()
   	                 //發(fā)送數(shù)據(jù)
   	                 it?.send(bytes)
   	                 //延時50毫秒
   	                 Thread.sleep(50)
   	                 //接收數(shù)據(jù)
   	                 val recvbyte = it?.recvbyte()
   	                 val recvmsg = recvbyte?.toString(charset = Charsets.UTF_8)
	
 	                   tvmsg.append(recvmsg + "\r\n")
 	               } catch (e: IllegalArgumentException) {
 	                   tvmsg.append(e.message.toString() + "\r\n")
 	               }
  	          }
  	      }
   	 }
	}