/*****************************************************************************************/
/* 作者 耿浩 */
/* 创建时间 2015-11-11 */
/* 最后修改时间 2015-11-12 */
/* */
/* wonderware suitelink协议解析 */
/* opclink在5413端口建立监听 */
/* xxxx表示串的长度-2 */
/* xxxx0180客户端向服务器发送基本信息。 */
/* xxxx0100服务器向客户端确认接收到了基本信息(080001000101000300a5保持不变)。 */
/* xxxx1080客户端向服务器发送标记名。 分两次发送第一次发送一个，第二次发送剩下的。 */
/* xxxx0300服务器向客户端发送。服务器把接收到的标记名的标识返回给客户端。 */
/* xxxx0800服务器向客户端发送的字串。是何意义不懂！每次重连发送的都不一样。 */
/* xxxx0900服务器发送的数据包，实时数据交换的数据包。 */
/* xxxx2440(03002440a5)在服务器和客户端不定时发送，估计是服务器或者客户用来判断是否还在线*/
/* */
/* 不满足下面要求 在字符串处理中会出错 */
/* int 32位 */
/* short 16位 */
/* char 8位 */
/* */
/*****************************************************************************************/
#include "stdafx.h"
#include <Winsock2.h>
#pragma comment(lib, "ws2_32.lib")
#pragma warning(disable : 4786)
//这个警告的意思就是说， list<string> 的构造生成的 Symbols 太长了，超过了255个字符。
//你其实不用理会这个警告，因为它只会影响到 Debugger ，而不会影响到真实的代码。如果编译一个 Release 版本的话，就会发现这个警告已经完全消失了。
#include <map>
#include <vector>
#include <string>
using namespace std;
SOCKET sockClient;
char * AccessName[] ={"op", "a1", "a2"};
typedef struct ITEMINFO
{
const char *pAccessName; //访问名
string itemName; //项目名称
int key; //索引
int quality; //通讯质量
int exist; //服务器是否有该点
union{ //值
int i;
float r;
bool d;
}value;
} ItemInfo;
typedef vector<string> AccessNameList;
typedef map<int, ItemInfo> ItemList;
AccessNameList g_accessNameList; //访问名列表
ItemList g_itemList; //项目地址列表
//访问名列表 初始化
void InitAccessList(AccessNameList &accessNameList);
//item列表 初始化
void InitItemList(ItemList &itemList);
//客户端发送 应用程序名 例如: opclink
//服务器端 不返回数据
void SendAppName(const char * appName);
//客户发送 基本信息: 访问名 计算机名 用户名 服务器端程序名称 客户端程序名称 系统时间
//除了访问名 其他是啥都没影响
void SendAccessNames(char * AccessNames[], int nSize);
//每次发送的最大字符个数;
const int bufMaxSize = 80;
//客户端向服务器端发送 项目地址
void setBuf_sendItem(char* &buf, ItemInfo &item);
bool RecvItemFinish();
void SendItemName(ItemList &itemList);
void SendItemName2(ItemList &itemList);
void RecvItemName(ItemList &itemList);
//服务器向客户端发送实时数据
void RecvItemData();
void c2w(const unsigned char* cSrc, wchar_t* wDes);
void w2c(const wchar_t* wSrc, unsigned char* cDes);
void ItemInit(const char * AccessName, const char * itemName, ItemInfo & item)
{
//标记名列表 初始化
item.pAccessName = AccessName;
item.itemName = itemName;
item.key = (int)item.itemName.c_str();
item.quality = 0;
item.exist = 0;
memset(&item.value, 0, sizeof(item.value));
}
void InitAccessList(AccessNameList &accessNameList)
{
//访问名列表 初始化
accessNameList.push_back("op");
accessNameList.push_back("a3");
accessNameList.push_back("a2");
}
void InitItemList(AccessNameList &accessNameList, ItemList &itemList)
{
//item列表 初始化
ItemInfo item01;
ItemInit(accessNameList[0].c_str(), "IRandom.Int1", item01);
itemList[item01.key] = item01;
ItemInfo item02;
ItemInit(accessNameList[0].c_str(), "IRandom.Int2", item02);
itemList[item02.key] = item02;
ItemInfo item03;
ItemInit(accessNameList[0].c_str(), "IRandom.Int3", item03);
itemList[item03.key] = item03;
// ItemInfo item04;
// ItemInit(accessNameList[0].c_str(), "IRandom.Int4", item04);
// itemList[item04.key] = item04;
}
int main(int argc, char* argv[])
{
InitAccessList(g_accessNameList);
InitItemList(g_accessNameList, g_itemList);
//SendItemName2(g_itemList);
WORD wVersionRequested;
WSADATA wsaData;
wVersionRequested = MAKEWORD(1, 1);
if(WSAStartup(wVersionRequested, &wsaData) != 0){
return 0;
}
sockClient = socket(AF_INET, SOCK_STREAM, 0);
SOCKADDR_IN addrSrv;
addrSrv.sin_addr.S_un.S_addr=inet_addr("192.168.0.73");
addrSrv.sin_family=AF_INET;
addrSrv.sin_port=htons(5413);
int retcon = connect(sockClient, (SOCKADDR*)&addrSrv,sizeof(SOCKADDR));
if(retcon == SOCKET_ERROR){
return 0;
}
SendAppName("opclink");
SendAccessNames(AccessName, 0);
SendItemName(g_itemList);
RecvItemData();
closesocket(sockClient);
WSACleanup();
printf("结束!\n");
return 0;
}
//输入名称不能包括\0 ,有\0肯定错了,因为用来strlen来取长度,可见名称中也不可能包含\0
//MultiByteToWideChar WideCharToMultiByte
//返回值代表长度， 其长度是strlen+1, 其最后一位是0
void c2w(const unsigned char* c, wchar_t* w)
{
int len = strlen((const char *)c);
MultiByteToWideChar(CP_ACP, 0, (LPCSTR)c, -1, w, len);
}
//输入名称不能包括\0 ,有\0肯定错了,因为用来wcslen来取长度,不过可见名称中也不可能包含\0
void w2c(const wchar_t* w, unsigned char* c)
{
int len = wcslen(w);
WideCharToMultiByte(CP_ACP, 0, w, -1, (LPSTR)c, len, NULL, 0);
}
void SendAppName(const char * appName)
{
//605fc3b12d05d111bf0800a0c9723e826f70636c696e6b00000000000000000000000000000000000000000000000000
//该数据包发送过去，并不回数
//此数据包的长度是48
//00-15 值固定不变
//16-47 用来存储应用程序名称,应用程序名称最多是32个字符,应用程序名最好别用中文
//如果连接的是opclink, appName = "opclink" 不能出错
int len = strlen(appName);
if (len > 32 || len <= 0)
{
return;
}
const int buflen = 48;
unsigned char buf[buflen];
memset(buf, 0, buflen);
memcpy(buf, "\x60\x5f\xc3\xb1\x2d\x05\xd1\x11\xbf\x08\x00\xa0\xc9\x72\x3e\x82", 16);
memcpy(buf+16, appName, len);
send(sockClient, (const char *)buf, buflen, 0);
}
//客户端向服务器端发送基本信息
void SendAccessNames(char * AccessName[], int nSize)
{
const int MAXSIZE = 1024;
unsigned char buf[MAXSIZE];
memset(buf, 0x00, MAXSIZE);
unsigned char slen = 0;
unsigned char* p_buf = buf;
p_buf += 2; //头2个字节保存的是整串长度-2,这个在最后写入。
*p_buf = 0x01; //标识位: 0180 客户端向服务器发送基本信息
p_buf++;
*p_buf = 0x80; //标识位: 0180 客户端向服务器发送基本信息
p_buf++;
char * ServerAppName = "a"; //opclink 是啥不会有影响
char * ClientAppName = "a"; //view 是啥不会有影响
slen = (unsigned char)strlen((const char *)ServerAppName);
*p_buf = slen; //服务器端应用程序名称 长度
p_buf++;
c2w((unsigned char*)ServerAppName, (wchar_t*)p_buf); //服务器端应用程序名称,以宽字节存储
p_buf += slen*2;
slen = (unsigned char)strlen((const char *)AccessNam
