修改社交會員
//封裝傳送入參
:socialmember
socialmember
=newsocialmember();
socialmember
.setlastupd(newdate());
//大資料要求設定修改時間
string
getmid
= socialmember
.setmid(
request
.getdata().getmid();
));}
sendrocketmqforupdatemember
(socialmember
);rocketmq 傳送訊息
publicvoidsendrocketmqforupdatemember(socialmember
socialmember
) ",
encryptdata
);blockchainmemberrequest
request
=newblockchainmemberrequest();
request
.setdata(
item
);request
.setfldatasignature(
encryptdata
);string
jsondata
= gsonutil.
tojson
(request
, blockchainmemberrequest.class);
rocketmqproductor.
sendmsg
(null,block_chain_topic,block_chain_update_tag,null,
jsondata
);//********************====標籤傳送資料********************===
labelmemberitem
labelmemberitem
=newlabelmemberitem();
labelmemberitem
.setflmemberid(string.
valueof
(string.
valueof
(socialmember
.getmid())));
// 會員id
labelmemberitem
.setflcategory("1");
// 會員類別
labelmemberitem
.setflstatus("0");
// 會員狀態
labelmemberitem
.setfloper("update");
// 對資料進行的操作（新增還是更新 insert或者update）
labelmemberitem
.setflcreated(new******dateformat("yyyy-mm-dd hh:mm:ss").format(newdate()));
// 會員的更新時間
labelmemberitem
.setfldata(
socialmember
);string
labeljsondata
= fastjsonutil.
parsetojson
(labelmemberitem
);rocketmqproductor.
sendmsg
(null,label_topic,label_update_tag,null,
labeljsondata
);}catch(exception e)
}自己封裝方法
package com.foriseland.fas.member.mq;
import com.foriseland.fjf.mq.broadcasting.broadcastproducer;
import org.apache.rocketmq.client.producer.sendresult;
import org.slf4j.logger;
import org.slf4j.logge***ctory;
import org.springframework.beans.factory.annotation.autowired;
import org.springframework.stereotype.component;
* @author zhangchenglin
* @describe
* @createtime 2018/3/28
@component
public class rocketmqproductor catch (exception e) ", e);
return null;
sendresult sendresult = null;
try ", sendresult);
} catch (exception e) ", e);
} finally
RocketMq入門 入門示例
網上眾說紛紜。有的說啟動命令不對，有的說rocketmq預設不允許開發者私自建立topic。最後手動建立topic。但是發現消費不了訊息，很奇怪。今天我又重新安裝了一遍rocketmq。測試了一下發現還可以。上圖是rocketmq的架構圖。我們必須要對上述的一些組建或者結點做一些說明解釋 produ...
rocketmq 入門（二）實戰demo
參考文章 rocketmq實戰 啟動rocketmq的namesrv 啟動rocketmq的broker 建立乙個簡單的springboot專案 pom4.0.0 com.squid.rocketmq rocketmq test 1.0 snapshot org.springframework.bo...
Hibernate入門 入門案例
4.1 資料庫建立表 create table cst customer cust id bigint 32 not null auto increment comment 客戶編號 主鍵 cust name varchar 32 not null comment 客戶名稱 公司名稱 cust so...