bingoogolapple
commented
6 years ago 开启报警功能
- 初始化数据库表 CreateTableStatement-mysql.sql 和 SpringBatchJobReositorySchema-mysql.sql
- 修改 pinpoint/web 模块的 jdbc.properties
jdbc.driverClassName=com.mysql.jdbc.Driver
jdbc.url=jdbc:mysql://mysqlhost:3306/pinpoint?characterEncoding=UTF-8
jdbc.username=admin
jdbc.password=admin- 修改 pinpoint/web 模块的 batch.properties
#batch enable config
batch.enable=true
#batch server ip to execute batch
batch.server.ip=127.0.0.1- 添加邮件配置文件 mail.properties 到 pinpoint/web 模块的 resources 目录中
mail.smtpserver=smtp.xxxx.com
mail.smtpserver.port=25
mail.from=username@xxxx.com
mail.password=your_pwd- 为 pinpoint/web 模块的 pom.xml 添加依赖
<dependency>
<groupId>com.sun.mail</groupId>
<artifactId>javax.mail</artifactId>
<version>1.6.0</version>
</dependency>- 添加报警消息发送器 AlarmMessageSenderImpl.java 到 pinpoint/web 模块的包 com.navercorp.pinpoint.web.alarm 中
package com.navercorp.pinpoint.web.alarm;
import com.navercorp.pinpoint.common.util.PropertyUtils;
import com.navercorp.pinpoint.web.alarm.checker.AlarmChecker;
import com.navercorp.pinpoint.web.service.UserGroupService;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.mail.SimpleMailMessage;
import org.springframework.mail.javamail.JavaMailSenderImpl;
import org.springframework.stereotype.Component;
import java.io.IOException;
import java.util.List;
import java.util.Properties;
/**
* 作者:王浩 邮件:bingoogolapple@gmail.com
* 创建时间:2017/8/4 下午1:51
* 描述:报警消息发送器
*/
@Component
public class AlarmMessageSenderImpl implements AlarmMessageSender {
private static final Logger LOGGER = LoggerFactory.getLogger(AlarmMessageSenderImpl.class);
@Autowired
private UserGroupService userGroupService;
private JavaMailSenderImpl mailSender;
public AlarmMessageSenderImpl() {
try {
Properties properties = PropertyUtils.loadPropertyFromClassPath("mail.properties");
mailSender = new JavaMailSenderImpl();
mailSender.setHost(properties.getProperty("mail.smtpserver"));
mailSender.setPort(Integer.parseInt(properties.getProperty("mail.smtpserver.port")));
mailSender.setUsername(properties.getProperty("mail.from"));
mailSender.setPassword(properties.getProperty("mail.password"));
mailSender.setJavaMailProperties(getMailProperties());
} catch (IOException e) {
mailSender = null;
LOGGER.error("初始化邮件发送者失败", e);
e.printStackTrace();
}
}
private Properties getMailProperties() {
Properties properties = new Properties();
properties.setProperty("mail.transport.protocol", "smtp");
properties.setProperty("mail.smtp.auth", "true");
properties.setProperty("mail.smtp.starttls.enable", "true");
properties.setProperty("mail.smtp.starttls.required", "true");
properties.setProperty("mail.debug", "false");
return properties;
}
/**
* 发送邮件
*
* @param to 邮件接收者
* @param text 邮件内容
*/
private void sendEmail(String to, String text) {
try {
SimpleMailMessage message = new SimpleMailMessage();
message.setTo(to);
message.setSubject("pinpoint 报警邮件");
message.setText(text);
mailSender.send(message);
} catch (Exception e) {
LOGGER.error("发送邮件失败", e);
}
}
@Override
public void sendEmail(AlarmChecker checker, int sequenceCount) {
LOGGER.error("发送邮件");
List<String> receivers = userGroupService.selectEmailOfMember(checker.getuserGroupId());
if (mailSender == null || receivers.size() == 0) {
return;
}
for (String emailId : receivers) {
sendEmail(emailId, checker.getEmailMessage());
}
}
@Override
public void sendSms(AlarmChecker checker, int sequenceCount) {
}
}- 打 release 包
mvn install -Prelease -Dmaven.test.skip=true- 后面要用到的是下面四个文件
- pinpoint/collector/target/pinpoint-collector-1.6.2.war
- pinpoint/web/target/pinpoint-web-1.6.2.war
- pinpoint/agent/target/pinpoint-agent-1.6.2.tar.gz
- hbase/scripts/hbase-create.hbase
更多配置信息请参考 官方文档
wyfaq
oatiz
uvanix
xw8520
本地编译打 release 包