TLQ8产品培训开发环境课件

TongLINK/Q8.0开发环境,演讲人：演讲时间：,目录,API介绍及应用程序开发应用举例练习,API介绍及应用程序开发,API介绍及应用程序开发,普通API介绍,API与核心的交互机制,普通API介绍,主要结构及作用连接标识：TLQ_ID应用实例标识：TLQ_QCUHDL消息描述：TLQMSG_INFO消息操作选项：TLQMSG_OPT消息错误信息：TLQError重要字符串消息内容：msgcontent用户属性：UserProperty,普通API介绍,消息由三部分组成：消息描述（必需）用户自定义属性（可选）消息内容（必需）,普通API介绍,tlq_api.hTLQMSG_INFO结构：structmsg_infocharVerNo;/*版本号*/charMsgType;/*消息类型*/charUsrContextUSR_CONTEXT_LEN+1;/*消息的用户数据*/intMsgSize;/*消息长度*/intExpiry;/*生命周期*/charPriority;/*优先级，0.9*/charPersistence;/*持久性类型*/charMsgOperateType;/*消息控制类型，压缩或安全出口*/charMsgOperateInfoOPERATEDATALEN+1;/*消息控制数据*/unsignedintUserPropertyLen;/*用户自定义属性串的长度*/unsignedintUserPropertyNum;/*用户自定义属性的个数*/charCorrMsgIdMSGIDLEN+1;/*消息的关联属性*/,普通API介绍,以下属性在消息发送时由核心赋值，应用时不必关心,*发送成功返回后，可获取这些属性的值charSrcNodeNAMELEN+1;/*消息的源节点*/charDestQNameNAMELEN+1;/*目标队列名*/intPutDateTime;/*消息发送时间*/charGroupIDMSGIDLEN+1;/*组标识*/intGroupSeq;/*组序号*/charGroupStatus;/*组消息的状态*/charMsgOrigin;/*消息的来源*/charMsgIdMSGIDLEN+1;/*消息标识*/unsignedintOrgMsgLen;/*消息处理前的长度*/charLONG_INT_MAXLEN;/*文件大小*/intEvTime;/*事件产生的时间*/unsignedintEvStyle;/*事件类型*/intRollbackCount;/*消息回滚次数*/charReserve16;/*以备后用*/shortOffSet;/*偏移量*/,普通API介绍,以下属性在消息发送时由核心赋值，应用时不必关心,*发送成功返回后，可获取这些属性的值charSrcNodeNAMELEN+1;/*消息的源节点*/charDestQNameNAMELEN+1;/*目标队列名*/intPutDateTime;/*消息发送时间*/charGroupIDMSGIDLEN+1;/*组标识*/intGroupSeq;/*组序号*/charGroupStatus;/*组消息的状态*/charMsgOrigin;/*消息的来源*/charMsgIdMSGIDLEN+1;/*消息标识*/unsignedintOrgMsgLen;/*消息处理前的长度*/charLONG_INT_MAXLEN;/*文件大小*/intEvTime;/*事件产生的时间*/unsignedintEvStyle;/*事件类型*/intRollbackCount;/*消息回滚次数*/charReserve16;/*以备后用*/shortOffSet;/*偏移量*/,普通API介绍,函数接口的作用：实现应用与核心的交互实现个性化应用的定制,普通API介绍,接口分类,普通API介绍,连接断开系统资源,1.连接系统资源intTlq_Conn(TLQ_ID*gid,TLQError*err);2.断开系统资源intTlq_DisConn(TLQ_ID*gid,TLQError*err);说明：这两个函数成对出现,普通API介绍,开始结束应用实例,1.开始应用实例intTlq_OpenQCU(TLQ_ID*gid,TLQ_QCUHDL*qcuHandle,char*QCUName,TLQError*err);2.结束应用实例intTlq_CloseQCU(TLQ_ID*gid,TLQ_QCUHDL*qcuHandle,TLQError*err);说明：这两个函数成对出现,普通API介绍,初始化函数,1.初始化TLQMSG_INFOintTlq_InitMsgInfo(TLQMSG_INFO*pUsrMsg);2.初始化TLQMSG_OPTintTlq_InitMsgOpt(TLQMSG_OPT*msgopt);,普通API介绍,发送消息，包括普通消息、组消息、订阅事件消息、发布订阅、取消发布订阅等intTlq_PutMsg(TLQ_ID*gid,TLQ_QCUHDL*qcuHandle,TLQMSG_INFO*pUsrMsg,TLQMSG_OPT*msgopt,char*UsrProperty,char*msgcontent,TLQError*err)；msgopt.OperateType为不同的值，表示的不同操作TLQOT_PUT发送消息TLQOT_PUB发布消息TLQOT_DELPUB取消发布TLQOT_SUB订阅消息TLQOT_DELSUB取消订阅,普通API介绍,intTlq_GetMsg(TLQ_ID*gid,TLQ_QCUHDL*qcuHandle,TLQMSG_INFO*pUsrMsg,TLQMSG_OPT*msgopt,char*msgcontent,TLQError*err);msgopt.OperateTypeTLQOT_GET时，表示接收消息msgopt.OperateTypeTLQOT_BROWSE时，表示浏览消息,接收消息和浏览消息,普通API介绍,intTlq_DeleteMsg(TLQ_ID*gid,TLQ_QCUHDL*qcuHandle,TLQMSG_INFO*pUsrMsg,TLQMSG_OPT*msgopt,int*msg_num,TLQError*err);msgopt.DelState值标识删除不同状态的消息TLQSTATE_ALL删除所有状态的消息TLQSTATE_READY删除没有发送或接收完毕的消息TLQSTATE_SENDING删除正在发送的消息TLQSTATE_RECEIVING删除正在接收的消息,删除消息,普通API介绍,intTlq_AckMsg(TLQ_ID*gid,TLQ_QCUHDL*qcuHandle,TLQMSG_INFO*pUsrMsg,TLQMSG_OPT*msgopt,intAckType,TLQError*err);msgopt.AckMode值标识删除不同状态的消息TLQACK_AUTO自动确认模式，消息接收后即被删除TLQACK_USER用户确认模式，消息接收后并不删除，必须等待用户确认模式下，AckType分别取值如下：TLQACK_COMMIT提交确认TLQACK_ROLLBACK回滚确认,消息接收确认,普通API介绍,1.组消息开始的标志intTlq_BeginGroup(TLQ_ID*gid,TLQ_QCUHDL*qcuHandle,TLQError*err);2.提交组消息intTlq_CommitGroup(TLQ_ID*gid,TLQ_QCUHDL*qcuHandle,TLQError*err);3.回滚组消息intTlq_RollbackGroup(TLQ_ID*gid,TLQ_QCUHDL*qcuHandle,TLQError*err);说明：2、3必须与1配对使用,组消息接口,普通API介绍,1.事务开始标志intTlq_Begin(TLQ_ID*gid,TLQ_QCUHDL*qcuHandle,TLQError*err);2.事务提交标志intTlq_Commit(TLQ_ID*gid,TLQ_QCUHDL*qcuHandle,TLQError*err);3.事务失败后用于回滚事务intTlq_Rollback(TLQ_ID*gid,TLQ_QCUHDL*qcuHandle,TLQError*err);说明：2、3必须与1配对使用,事务接口,普通API介绍,main()Tlq_Conn(/断开系统资源说明：这是应用实例运行的基本框架，是必需的,应用模式,瘦客户,瘦客户开发,瘦客户,瘦客户,1、获取连接工厂Tlq_ClusterLookup(TLQCLUSTER_FACTORY*list,/集群连接列表int*num,/集群连接数char*jndiUrl,/jndi服务器地址char*ClusterQname,/集群队列名TLQError*tlqerr);/错误信息,客户端专用函数说明,瘦客户,2、创建生产、消费者实例,Tlq_ClusterCreateInstance(TLQCLUSTER_HANDLE*ClusterId,/IN/OUT实例句柄TLQCLUSTER_FACTORY*list,/集群成员地址列表intlistnum,/集群成员个数intConnectionNum,/单个成员创建连接数intflag,/实例类型，0：发送，1：接收intsequence,/实例序号，同一进程中不同实例序号不能相同TLQMSG_INFO*uMsg,/用于接收消息的消息描述，发送实例忽略此参数TLQMSG_OPT*msgopt,/用于接收消息的操作选项，发送实例忽略此参数intMaxSize,/发送实例可发送消息的最大值，小于等于0时使用系统默认值char*library,/用于接收实例处理消息用的动态库全路径OnException_t*ExHandle,/自定义的回调函数TLQError*tlqerr)/错误信息,瘦客户,3、生产者发送消息,Tlq_ClusterProducer(TLQCLUSTER_HANDLE*ClusterId,/实例句柄TLQMSG_INFO*uMsg,/消息描述TLQMSG_OPT*msgopt,/消息操作char*msgcontent,/消息内容char*UserProperty,/自定义属性值intprolen,/自定义属性长度TLQError*tlqerr);/错误信息应用通过生产者向集群队列发送消息。,瘦客户,5、关闭集群实例,Tlq_ClusterCloseInstance(TLQCLUSTER_HANDLE*ClusterId);关闭集群实例，释放系统资源。,4、通知集群实例开始接收处理数据Tlq_ClusterConsumer(