 |
 |
| View previous topic :: View next topic |
| Author |
Message |
cvargcal
Joined: 17 Feb 2015
Posts: 134
|
| Translate code MQTT Arduino |
 Posted: Mon Apr 20, 2020 4:07 pm |
 |
|
Hi, I try to translate this code from Arduino, but i don't know how use the printf.
The idea is make a ConnectPacket first and after send the PublishPacket of course once again make the connection TCP, but no print fine the buffer, maybe because the printf is bad write.
| Code: |
int led = 13;
unsigned int Counter = 0;
unsigned long datalength, CheckSum, RLength;
unsigned short topiclength;
unsigned char topic[30];
char str[250];
unsigned char encodedByte;
int X;
unsigned short MQTTProtocolNameLength;
unsigned short MQTTClientIDLength;
unsigned short MQTTUsernameLength;
unsigned short MQTTPasswordLength;
char MQTTHost[30] = "io.adafruit.com";
char MQTTPort[10] = "1883";
char MQTTClientID[20] = "ABCDEF";
char MQTTTopic[30] = "cvargcal/feeds/testv";
char MQTTProtocolName[10] = "MQTT";
char MQTTLVL = 0x03;
char MQTTFlags = 0xC2;
unsigned int MQTTKeepAlive = 60;
char MQTTUsername[30] = "cvargcal";
char MQTTPassword[35] = "aio_xJeb83eGnlYAEDVgxlfyqsuKMttk";
char MQTTQOS = 0x00;
char MQTTPacketID = 0x0001;
//!
//!
//!void setup() {
//! pinMode(led, OUTPUT);
//! Serial.begin(9600);
//! Serial.println("Arduino MQTT Tutorial, Valetron Systems @www.raviyp.com ");
//! delay(3000);
//!}
void SendConnectPacket() {
fprintf(uart2,0x10); // Serial.write(0x10);
MQTTProtocolNameLength = strlen(MQTTProtocolName);
MQTTClientIDLength = strlen(MQTTClientID);
MQTTUsernameLength = strlen(MQTTUsername);
MQTTPasswordLength = strlen(MQTTPassword);
datalength = MQTTProtocolNameLength + 2 + 4 + MQTTClientIDLength + 2 + MQTTUsernameLength + 2 + MQTTPasswordLength + 2;
X = datalength;
do {
encodedByte = X % 128;
X = X / 128;
if (X > 0) {
encodedByte |= 128;
}
fprintf(uart2,encodedByte); //Serial.write(encodedByte);
}
while (X > 0);
fprintf(uart2,(MQTTProtocolNameLength >> 8)); //! Serial.write(MQTTProtocolNameLength >> 8);
fprintf(uart2,(MQTTProtocolNameLength & 0xFF)); //! Serial.write(MQTTProtocolNameLength & 0xFF);
fprintf(uart2,(MQTTProtocolName)); //! Serial.print(MQTTProtocolName);
fprintf(uart2,(MQTTLVL)); //! Serial.write(MQTTLVL); // LVL
fprintf(uart2,(MQTTFlags)); //! Serial.write(MQTTFlags); // Flags
fprintf(uart2,(MQTTKeepAlive >> 8)); //! Serial.write(MQTTKeepAlive >> 8);
fprintf(uart2,(MQTTKeepAlive & 0xFF)); //! Serial.write(MQTTKeepAlive & 0xFF);
fprintf(uart2,(MQTTClientIDLength >> 8)); //! Serial.write(MQTTClientIDLength >> 8);
fprintf(uart2,(MQTTClientIDLength & 0xFF)); //! Serial.write(MQTTClientIDLength & 0xFF);
fprintf(uart2,(MQTTClientID)); //! Serial.print(MQTTClientID);
fprintf(uart2,(MQTTUsernameLength >> 8)); //! Serial.write(MQTTUsernameLength >> 8);
fprintf(uart2,(MQTTUsernameLength & 0xFF)); //! Serial.write(MQTTUsernameLength & 0xFF);
fprintf(uart2,(MQTTUsername)); //! Serial.print(MQTTUsername);
fprintf(uart2,(MQTTPasswordLength >> 8)); //! Serial.write(MQTTPasswordLength >> 8);
fprintf(uart2,(MQTTPasswordLength & 0xFF)); //! Serial.write(MQTTPasswordLength & 0xFF);
fprintf(uart2,(MQTTPassword)); //! Serial.print(MQTTPassword);
}
void SendPublishPacket() {
memset(str, 0, 250);
str="57";
topiclength = sprintf((char * ) topic, MQTTTopic);
datalength = sprintf((char * ) str, "%s%u", topic, Counter);
delay_ms(1000);
fprintf(uart2,0x30); //Serial.write(0x30);
X = datalength + 2;
do {
encodedByte = X % 128;
X = X / 128;
if (X > 0) {
encodedByte |= 128;
}
fprintf(uart2,encodedByte); //Serial.write(encodedByte);
}
while (X > 0);
fprintf(uart2,(topiclength >> 8)); //! Serial.write(topiclength >> 8);
fprintf(uart2,(topiclength & 0xFF)); //! Serial.write(topiclength & 0xFF);
fprintf(uart2,(str)); //! Serial.print(str);
}
void SendSubscribePacket() {
memset(str, 0, 250);
topiclength = strlen(MQTTTopic);
datalength = 2 + 2 + topiclength + 1;
delay_ms(1000);
fprintf(uart2,0x82); //Serial.write(0x82);
X = datalength;
do {
encodedByte = X % 128;
X = X / 128;
if (X > 0) {
encodedByte |= 128;
}
fprintf(uart2,encodedByte); //Serial.write(encodedByte);
}
while (X > 0);
fprintf(uart2,(MQTTPacketID >> 8)); //! Serial.write(MQTTPacketID >> 8);
fprintf(uart2,(MQTTPacketID & 0xFF)); //! Serial.write(MQTTPacketID & 0xFF);
fprintf(uart2,(topiclength >> 8)); //! Serial.write(topiclength >> 8);
fprintf(uart2,(topiclength & 0xFF)); //! Serial.write(topiclength & 0xFF);
fprintf(uart2,(MQTTTopic)); //! Serial.print(MQTTTopic);
fprintf(uart2,(MQTTQOS)); //! Serial.write(MQTTQOS);
}
|
Here is the original:
http://www.raviyp.com/arduino-mqtt-library-with-publish-and-subscribe-example/ |
|
 |
PCM programmer
Joined: 06 Sep 2003
Posts: 21708
|
|
| Posted: Mon Apr 20, 2020 4:44 pm |
|
|
Here is my opinion of how the SendConnectPacket() routine should be
translated to CCS, with test program:
| Code: |
#include <18F46K22.h>
#device PASS_STRINGS=IN_RAM
#fuses INTRC_IO, NOWDT, BROWNOUT, PUT, NOPBADEN
#use delay(clock=4M)
#use rs232(baud=9600, UART1, ERRORS)
#include <string.h>
#define LED PIN_B0
unsigned int16 Counter = 0;
unsigned int32 datalength, CheckSum, RLength;
unsigned int16 topiclength;
unsigned char topic[30];
signed char str[250];
unsigned char encodedByte;
signed int16 X;
unsigned int16 MQTTProtocolNameLength;
unsigned int16 MQTTClientIDLength;
unsigned int16 MQTTUsernameLength;
unsigned int16 MQTTPasswordLength;
const char MQTTHost[30] = "m10.cloudmqtt.com";
const char MQTTPort[10] = "17434";
const char MQTTClientID[20] = "ABCDEF";
const char MQTTTopic[30] = "valetron";
const char MQTTProtocolName[10] = "MQIsdp";
const char MQTTLVL = 0x03;
const char MQTTFlags = 0xC2;
const unsigned int16 MQTTKeepAlive = 60;
const char MQTTUsername[30] = "dxxkgkpp";
const char MQTTPassword[35] = "qAUZBdaSIULx";
const char MQTTQOS = 0x00;
const char MQTTPacketID = 0x0001;
void SendConnectPacket(void)
{
printf("\r\nAT+CIPSEND\r\n");
delay_ms(3000);
putc(0x10);
MQTTProtocolNameLength = strlen(MQTTProtocolName);
MQTTClientIDLength = strlen(MQTTClientID);
MQTTUsernameLength = strlen(MQTTUsername);
MQTTPasswordLength = strlen(MQTTPassword);
datalength = MQTTProtocolNameLength + 2 + 4 + MQTTClientIDLength + 2 + MQTTUsernameLength + 2 + MQTTPasswordLength + 2;
X = datalength;
do{
encodedByte = X % 128;
X = X / 128;
if(X > 0) {
encodedByte |= 128;
}
putc(encodedByte);
}while (X > 0);
putc(MQTTProtocolNameLength >> 8);
putc(MQTTProtocolNameLength & 0xFF);
printf(MQTTProtocolName);
putc(MQTTLVL); // LVL
putc(MQTTFlags); // Flags
putc(MQTTKeepAlive >> 8);
putc(MQTTKeepAlive & 0xFF);
putc(MQTTClientIDLength >> 8);
putc(MQTTClientIDLength & 0xFF);
printf(MQTTClientID);
putc(MQTTUsernameLength >> 8);
putc(MQTTUsernameLength & 0xFF);
printf(MQTTUsername);
putc(MQTTPasswordLength >> 8);
putc(MQTTPasswordLength & 0xFF);
printf(MQTTPassword);
putc(0x1A);
}
//======================================
void main()
{
SendConnectPacket();
while(TRUE);
} |
|
|
|
cvargcal
Joined: 17 Feb 2015
Posts: 134
|
|
| Posted: Mon Apr 20, 2020 5:24 pm |
|
|
| PCM programmer wrote: | Here is my opinion of how the SendConnectPacket() routine should be
translated to CCS, with test program:
| Code: |
.....
while(TRUE);
} |
|
Ohh now the data look so good..... I did the connection and can send data across mqtt:
10 2C 00 06 4D 51 49 73 64 70 03 C2 00 3C 00 06
41 42 43 44 45 46 00 08 64 78 78 6B 67 6B 70 70
Thank you |
|
|
microjack64
Joined: 10 Apr 2020
Posts: 7
|
| Arduino printf or putc in pic ccs |
| Posted: Mon Apr 20, 2020 11:32 pm |
|
|
I was doing the next Arduino Nano but it has many issues. Now i am using PIC, 
but i have same issues. Your code really helped me. Please more code or examples. Add for mqtt and how to send data using esp.
_________________
mini engineer at https://projectiot123.com |
|
|
|
|
You cannot post new topics in this forum
You cannot reply to topics in this forum
You cannot edit your posts in this forum
You cannot delete your posts in this forum
You cannot vote in polls in this forum
|
Powered by phpBB © 2001, 2005 phpBB Group
|
FAQ 
Search
Register
Profile 
Log in to check your private messages 
Log in
