本文整理汇总了Java中com.dianping.cat.message.Event类的典型用法代码示例。如果您正苦于以下问题：Java Event类的具体用法？Java Event怎么用？Java Event使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
Event类属于com.dianping.cat.message包，在下文中一共展示了Event类的13个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: createConsumerCross
import com.dianping.cat.message.Event; //导入依赖的package包/类
/**
* 客户端处理方法
* @param url
* @param transaction
*/
private void createConsumerCross(URL url,Transaction transaction){
//供应者的名称 如：com.cmall.goods.rpc
Event crossAppEvent = Cat.newEvent(CatConstants.CONSUMER_CALL_APP,getProviderAppName(url));
//供应者ip
Event crossServerEvent = Cat.newEvent(CatConstants.CONSUMER_CALL_SERVER,url.getHost());
//供应者端口
Event crossPortEvent = Cat.newEvent(CatConstants.CONSUMER_CALL_PORT,url.getPort()+"");
crossAppEvent.setStatus(Event.SUCCESS);
crossServerEvent.setStatus(Event.SUCCESS);
crossPortEvent.setStatus(Event.SUCCESS);
completeEvent(crossAppEvent);
completeEvent(crossPortEvent);
completeEvent(crossServerEvent);
transaction.addChild(crossAppEvent);
transaction.addChild(crossPortEvent);
transaction.addChild(crossServerEvent);
}
开发者ID:xiaomin0322，项目名称:dubbo_plus，代码行数:23，代码来源:CatTransaction.java
示例2: createProviderCross
import com.dianping.cat.message.Event; //导入依赖的package包/类
/**
* 服务端处理方法
* @param url
* @param transaction
*/
private void createProviderCross(URL url,Transaction transaction){
//供应者名称
String consumerAppName = RpcContext.getContext().getAttachment(Constants.APPLICATION_KEY);
if(StringUtils.isEmpty(consumerAppName)){
consumerAppName= RpcContext.getContext().getRemoteHost()+":"+ RpcContext.getContext().getRemotePort();
}
//供应者名称
Event crossAppEvent = Cat.newEvent(CatConstants.PROVIDER_CALL_APP,consumerAppName);
//供应者地址
Event crossServerEvent = Cat.newEvent(CatConstants.PROVIDER_CALL_SERVER,url.getHost());
crossAppEvent.setStatus(Event.SUCCESS);
crossServerEvent.setStatus(Event.SUCCESS);
completeEvent(crossAppEvent);
completeEvent(crossServerEvent);
transaction.addChild(crossAppEvent);
transaction.addChild(crossServerEvent);
}
开发者ID:xiaomin0322，项目名称:dubbo_plus，代码行数:23，代码来源:CatTransaction.java
示例3: logSqlMethodEvent
import com.dianping.cat.message.Event; //导入依赖的package包/类
private void logSqlMethodEvent(String sql, List<String> batchedSql, boolean isBatched, Object sqlParams) {
String params = Stringizers.forJson().compact().from(sqlParams, CatConstants.MAX_LENGTH,
CatConstants.MAX_ITEM_LENGTH);
if (isBatched) {
if (batchedSql != null) {
for (String bSql : batchedSql) {
Cat.logEvent("SQL.Method", SqlUtils.buildSqlType(bSql), Event.SUCCESS, params);
logSqlLengthEvent(sql);
}
}
} else {
if (sql != null) {
Cat.logEvent("SQL.Method", SqlUtils.buildSqlType(sql), Event.SUCCESS, params);
logSqlLengthEvent(sql);
}
}
}
开发者ID:dianping，项目名称:zebra，代码行数:18，代码来源:CatFilter.java
示例4: sendQueue
import com.dianping.cat.message.Event; //导入依赖的package包/类
private void sendQueue(QueueName queueName, RabbitMessage rm) throws Exception {
if (rm == null || queueName == null) {
return;
}
initQueueChannel();
String _queueName = queueName.getNameByEnvironment(environment);
Transaction trans = Cat.newTransaction("RabbitMQ Message", "PUBLISH-QUEUE-" + _queueName);
Cat.logEvent("mq send queue", _queueName, Event.SUCCESS,rm.toJsonStr());
try {
queueChannel.queueDeclare(_queueName, true, false, false, null);
queueChannel.basicPublish("", _queueName, MessageProperties.PERSISTENT_TEXT_PLAIN, rm.toJsonStr().getBytes("UTF-8"));
if (LOGGER.isInfoEnabled()) {
LOGGER.info("SEND SUCCESS:[queue:{},message:{}]", _queueName, rm.toJsonStr());
}
Cat.logMetricForCount("PUBLISH-QUEUE-" + _queueName); // 统计请求次数, 可以查看对应队列中放入了多少信息
trans.setStatus(Transaction.SUCCESS);
} catch (Exception e) {
if (LOGGER.isErrorEnabled()) {
LOGGER.error("SEND ERROR:[queue:{},message:{},exception:{}]", _queueName, rm.toJsonStr(), e);
}
String err = queueName + " rabbitmq发送消息异常";
Cat.logError(err, e);
trans.setStatus(e);
throw new AsuraRabbitMqException(err, e);
} finally {
trans.complete();
}
}
开发者ID:AsuraTeam，项目名称:asura，代码行数:29，代码来源:RabbitMqSendClient.java
示例5: sendTopic
import com.dianping.cat.message.Event; //导入依赖的package包/类
/**
* 发送消息-topic方式
*
* @param exchangeName 格式为：系统标示_模块标示_功能标示
* @param msg 具体消息
* @author zhangshaobin
* @created 2016年3月1日 下午4:40:59
*/
public void sendTopic(ExchangeName exchangeName, RoutingKey routingKey, PublishSubscribeType type, String msg) throws Exception {
initTopicChannel();
String _exchange = exchangeName.getNameByEnvironment(environment);
Transaction trans = Cat.newTransaction("RabbitMQ Message", "PUBLISH-TOPIC-" + _exchange);
RabbitMessage rm = new RabbitMessage();
rm.setData(msg);
rm.setType(_exchange);
try {
Cat.logEvent("mq send topic",exchangeName.getName(),Event.SUCCESS, rm.toJsonStr());
rm.setType(_exchange);
topicChannel.exchangeDeclare(_exchange, type.getName(), true);
topicChannel.basicPublish(_exchange, routingKey.getKey(), null, rm.toJsonStr().getBytes("UTF-8"));
if (LOGGER.isInfoEnabled()) {
LOGGER.info("SEND SUCCESS:[queue:{},message:{}]", _exchange, rm.toJsonStr());
}
Cat.logMetricForCount("PUBLISH-TOPIC-" + _exchange); // 统计请求次数, 可以查看对应队列中放入了多少信息
trans.setStatus(Transaction.SUCCESS);
} catch (Exception e) {
if (LOGGER.isErrorEnabled()) {
LOGGER.error("SEND ERROR:[queue:{},message:{},exception:{}]", _exchange, rm.toJsonStr(), e);
}
String err = exchangeName + " rabbitmq发送消息异常";
Cat.logError(err, e);
trans.setStatus(e);
throw new AsuraRabbitMqException(err, e);
} finally {
trans.complete();
}
}
开发者ID:AsuraTeam，项目名称:asura，代码行数:38，代码来源:RabbitMqSendClient.java
示例6: logEvent
import com.dianping.cat.message.Event; //导入依赖的package包/类
@Override
public void logEvent(String name, String event, String desc) {
try {
if (this.producer == null) {
this.producer = Cat.getProducer();
}
if (this.producer != null) {
this.producer.logEvent(name, event, Event.SUCCESS, desc);
}
} catch (Exception e) {
logMonitorError(e);
}
}
开发者ID:justimkiss，项目名称:bee，代码行数:14，代码来源:CatMonitor.java
示例7: testBasicBussiness
import com.dianping.cat.message.Event; //导入依赖的package包/类
/**
* 测试一个最简单的示例
*/
@Test
public void testBasicBussiness() {
log.debug("测试最基本的事务");
for (int i = 0; i < 1000; i++) {
Transaction t = Cat.newTransaction("统计消息类型：URL/SQL/Bussiness。。。一级纬度", "具体消息分类，属于一个二级纬度：/index；Select * from ...");
// 增加事件记录
Cat.logEvent("RemoteLink", "sina", Event.SUCCESS, "http://sina.com.cn/");
// 增加记录变量
t.addData("channel=channel" + i % 5);
Cat.logMetricForCount("Receipt Verify Success");
Cat.logMetricForCount("Receipt Verify Success 2", 2);
Cat.logMetricForDuration("Receipt Verify Druation", 10);
Cat.logMetricForSum("sum Value", 20);
Cat.logMetricForSum("sum Value2", 20, 2);
try {
Thread.sleep(500);
} catch (InterruptedException e) {
e.printStackTrace();
}
t.complete();
}
}
开发者ID:Percy0601，项目名称:training-cat，代码行数:30，代码来源:TrainingBussinessMessage.java
示例8: findAll
import com.dianping.cat.message.Event; //导入依赖的package包/类
@Override
public List<User> findAll() {
String rootMessageId = RpcContext.getContext().getAttachment(CatConstants.PIGEON_ROOT_MESSAGE_ID);
String currentMessageId = RpcContext.getContext().getAttachment(CatConstants.PIGEON_CURRENT_MESSAGE_ID);
String serverMessageId = RpcContext.getContext().getAttachment(CatConstants.PIGEON_SERVER_MESSAGE_ID);
Transaction t = Cat.newTransaction("RemoteCall", "findAll");
MessageTree tree = Cat.getManager().getThreadLocalMessageTree();
if (null == tree) {
Cat.setup(null);
tree = Cat.getManager().getThreadLocalMessageTree();
}
tree.setRootMessageId(rootMessageId);
tree.setParentMessageId(serverMessageId);
tree.setMessageId(currentMessageId);
List<User> users = new ArrayList<User>();
int i = 0;
while (i ++ < 10) {
User u = new User();
u.setId(i);
u.setName("Percy00" + i);
users.add(u);
}
Cat.logEvent("Call", "Params", Event.SUCCESS, "parentId:" + serverMessageId + "|msgId:" + currentMessageId + "End...");
t.setStatus(Transaction.SUCCESS);
t.complete();
return users;
}
开发者ID:Percy0601，项目名称:training-cat，代码行数:33，代码来源:UserServiceImpl.java
示例9: main
import com.dianping.cat.message.Event; //导入依赖的package包/类
public static void main(String[] args) {
SpringApplication.run(ApplicationBootstrap.class, args);
for (int i = 0; i < 1000; i++) {
Transaction t = Cat.newTransaction(
"统计消息类型：URL/SQL/Bussiness。。。一级纬度",
"具体消息分类，属于一个二级纬度：/index；Select * from ...");
// 增加事件记录
Cat.logEvent("RemoteLink", "sina", Event.SUCCESS,
"http://sina.com.cn/");
// 增加记录变量
t.addData("channel=channel" + i % 5);
Cat.logMetricForCount("Receipt Verify Success");
Cat.logMetricForCount("Receipt Verify Success 2", 2);
Cat.logMetricForDuration("Receipt Verify Druation", 10);
Cat.logMetricForSum("sum Value", 20);
Cat.logMetricForSum("sum Value2", 20, 2);
try {
Thread.sleep(500);
} catch (InterruptedException e) {
e.printStackTrace();
}
t.complete();
// try {
// System.in.read();
// } catch (IOException e) {
// e.printStackTrace();
// }
}
}
开发者ID:Percy0601，项目名称:training-cat，代码行数:37，代码来源:ApplicationBootstrap.java
示例10: hello
import com.dianping.cat.message.Event; //导入依赖的package包/类
@RequestMapping("/hello")
public String hello(String name) {
Transaction t = Cat.newTransaction("URL", "/hello");
String serverMessageId = Cat.getProducer().createMessageId();
MessageTree tree = Cat.getManager().getThreadLocalMessageTree();
if (null == tree) {
Cat.setup(null);
tree = Cat.getManager().getThreadLocalMessageTree();
}
String rootMessageId = tree.getRootMessageId() == null ? tree.getMessageId() : tree.getRootMessageId();
String currentMessageId = tree.getMessageId();
// 传递上下文
RpcContext.getContext().setAttachment(CatConstants.PIGEON_ROOT_MESSAGE_ID, rootMessageId);
RpcContext.getContext().setAttachment(CatConstants.PIGEON_CURRENT_MESSAGE_ID, currentMessageId);
RpcContext.getContext().setAttachment(CatConstants.PIGEON_SERVER_MESSAGE_ID, serverMessageId);
Cat.logEvent(CatConstants.TYPE_REMOTE_CALL, CatConstants.NAME_REQUEST, Transaction.SUCCESS, serverMessageId);
Transaction t1 = Cat.newTransaction("调用远程Dubbo服务", "findAll");
System.out.println("==========" + (userService == null));
String result = "Hello: " + name + userService.findAll().size();
t1.setStatus(Transaction.SUCCESS);
t1.complete();
Cat.logEvent("Call", "DubboServer", Event.SUCCESS, "parentId:" + serverMessageId+ "|msgId:" + serverMessageId + " End...");
t.setStatus(Transaction.SUCCESS);
t.complete();
return result;
}
开发者ID:Percy0601，项目名称:training-cat，代码行数:29，代码来源:TrainingController.java
示例11: logSqlDatabaseEvent
import com.dianping.cat.message.Event; //导入依赖的package包/类
private void logSqlDatabaseEvent(SingleConnection conn) throws SQLException {
SingleConnection singleConnection = conn instanceof SingleConnection ? (SingleConnection) conn : null;
if (singleConnection != null && conn.getMetaData() != null) {
Cat.logEvent("SQL.Database", conn.getMetaData().getURL(), Event.SUCCESS,
singleConnection.getDataSourceId());
}
}
开发者ID:dianping，项目名称:zebra，代码行数:8，代码来源:CatFilter.java
示例12: completeEvent
import com.dianping.cat.message.Event; //导入依赖的package包/类
private void completeEvent(Event event){
AbstractMessage message = (AbstractMessage) event;
message.setCompleted(true);
}
开发者ID:xiaomin0322，项目名称:dubbo_plus，代码行数:5，代码来源:CatTransaction.java
示例13: logEvent
import com.dianping.cat.message.Event; //导入依赖的package包/类
@Override
public void logEvent(String type, String name, long count) {
Cat.logEvent(type, shorten(name), Event.SUCCESS, "*count=" + count);
}
开发者ID:ctripcorp，项目名称:x-pipe，代码行数:5，代码来源:CatEventMonitor.java
注：本文中的com.dianping.cat.message.Event类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。 |
客服电话
APP下载
官方微信
请发表评论