forked from alibaba/taokeeper
-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
Showing
9 changed files
with
84 additions
and
141 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
|
@@ -11,7 +11,6 @@ Any question to: [email protected] | |
4. Exec taokeeper-build/build.cmd to generate taokeeper-monitor.war | ||
|
||
|
||
|
||
How to deploy(See more,please to http://rdc.taobao.com/team/jm/archives/1450 ) | ||
|
||
1. Download taokeeper.sql( https://github.com/downloads/taobao/taokeeper/taokeeper.sql ),init mysql. | ||
|
@@ -49,4 +48,27 @@ linux:JAVA_OPTS=-DconfigFilePath="/home/admin/taokeeper-monitor/config/taokeep | |
|
||
6. Visit the page: http://127.0.0.1:8080/taokeeper-monitor | ||
|
||
|
||
|
||
|
||
|
||
Alibaba OpenSource Maven Repository | ||
<profiles> | ||
<profile> | ||
<id>opensource</id> | ||
<repositories> | ||
<repository> | ||
<id>taocodeReleases</id> | ||
<name>taocode nexus</name> | ||
<url>http://mvnrepo.code.taobao.org/nexus/content/repositories/releases/</url> | ||
</repository> | ||
<repository> | ||
<id>taocodeSnapshots</id> | ||
<name>taocode nexus</name> | ||
<url>http://mvnrepo.code.taobao.org/nexus/content/repositories/snapshots/</url> | ||
</repository> | ||
</repositories> | ||
</profile> | ||
</profiles> | ||
|
||
|
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
|
@@ -2,23 +2,24 @@ | |
|
||
import static common.toolkit.java.constant.SymbolConstant.COMMA; | ||
|
||
import java.net.URLEncoder; | ||
import java.util.HashMap; | ||
import java.util.List; | ||
import java.util.Map; | ||
|
||
import org.slf4j.Logger; | ||
import org.slf4j.LoggerFactory; | ||
|
||
import com.taobao.jm.msgcenter.MsgManager; | ||
import com.taobao.jm.msgcenter.common.MsgConstants; | ||
import com.taobao.jm.msgcenter.common.Result; | ||
import com.taobao.taokeeper.common.SystemInfo; | ||
import com.taobao.taokeeper.common.constant.SystemConstant; | ||
import com.taobao.taokeeper.model.type.EnvType; | ||
import com.taobao.taokeeper.model.type.Message; | ||
import common.toolkit.java.entity.Message.MessageType; | ||
import common.toolkit.java.util.StringUtil; | ||
import common.toolkit.java.util.collection.ListUtil; | ||
import common.toolkit.java.util.io.NetUtil; | ||
|
||
/** | ||
* Description: 淘宝内部使用:旺旺消息与手机短信 | ||
* | ||
* @author 银时 [email protected] | ||
* @Date Dec 26, 2011 | ||
*/ | ||
|
@@ -35,7 +36,7 @@ public TbMessageSender( Message... messages ) { | |
@Override | ||
public void run() { | ||
|
||
if ( null == messages || 0 == messages.length || StringUtil.isBlank( SystemConstant.configOfMsgCenter ) ) | ||
if ( null == messages || 0 == messages.length || StringUtil.isBlank( SystemConstant.IP_OF_MESSAG_SEND ) ) | ||
return; | ||
|
||
for ( Message message : this.messages ) { | ||
|
@@ -52,60 +53,46 @@ public void run() { | |
|
||
/** | ||
* 发送消息 | ||
* @param targetAddresses | ||
* @param subject | ||
* @param content message content | ||
* @param channel messate tyep:sms,email,wangwang | ||
* | ||
* @param targetAddresses | ||
* @param subject | ||
* @param content | ||
* message content | ||
* @param channel | ||
* messate tyep:sms,email,wangwang | ||
* @return | ||
* @throws Exception | ||
*/ | ||
private Result sendMessage( String targetAddresses, String subject, String content, String channel ) { | ||
private boolean sendMessage( String targetAddresses, String subject, String content, String channel ) throws Exception { | ||
|
||
if ( StringUtil.isBlank( targetAddresses ) || StringUtil.isBlank( channel ) ) | ||
return null; | ||
Result result = null; | ||
String sendType = MsgConstants.CUSTOM_SERVER_LIST_TYPE; | ||
try { | ||
|
||
LOG.warn( "Init: setServiceType=" + MsgConstants.CUSTOM_SERVER_LIST_TYPE + ", custom server hosts: " + SystemConstant.serverOfMsgCenter ); | ||
MsgManager mcm = new MsgManager(); | ||
mcm.setServiceType( MsgConstants.CUSTOM_SERVER_LIST_TYPE ); | ||
mcm.setCustomServerHosts( SystemConstant.serverOfMsgCenter ); | ||
mcm.init(); | ||
|
||
if ( EnvType.DAILY.toString().equals( SystemInfo.envName ) ) { | ||
mcm.setServiceType( MsgConstants.CUSTOM_SERVER_LIST_TYPE ); | ||
mcm.setCustomServerHosts( SystemConstant.serverOfMsgCenter ); | ||
mcm.init(); | ||
} else if ( EnvType.ONLINE.toString().equals( SystemInfo.envName ) || EnvType.PREPARE.toString().equals( SystemInfo.envName ) ) { | ||
sendType = "HSF"; | ||
mcm.setServiceGroup( "HSF" ); | ||
mcm.setServiceVersion( "1.0.0" ); | ||
mcm.init(); | ||
} | ||
return false; | ||
|
||
List<String> targetAddressList = ListUtil.parseList( StringUtil.trimToEmpty( targetAddresses ), COMMA ); | ||
|
||
String sourceId = SystemConstant.sourceIdOfMsgCenter; | ||
String templateId = SystemConstant.templateIdOfMsgCenter; | ||
String messageTypeId = SystemConstant.messageTypeIdOfMsgCenter; | ||
Map<String, String> map = new HashMap<String, String>(); | ||
map.put( "ip", SystemConstant.IP_OF_MESSAG_SEND ); | ||
map.put( "subject", URLEncoder.encode( subject, "UTF-8" ) ); | ||
map.put( "content", URLEncoder.encode( content, "UTF-8" ) ); | ||
String url = ""; | ||
if ( channel.equalsIgnoreCase( MessageType.WANGWANG.toString() ) ) { | ||
|
||
List< String > targetAddressList = ListUtil.parseList( StringUtil.trimToEmpty( targetAddresses ), COMMA ); | ||
for ( String targetAddress : targetAddressList ) { | ||
result = mcm.sendMsg( targetAddress, "title: " + subject, "content: " + content, channel, sourceId, templateId, messageTypeId ); | ||
} | ||
|
||
if ( result.isSuccess() ) { | ||
LOG.warn( "Send " + channel + " message success, send type is " + sendType + ", targetAddress: " + targetAddresses + ", subject: " | ||
+ subject + ", content: " + content ); | ||
} else { | ||
LOG.warn( "Send " + channel + " message failure, send type is " + sendType + ", targetAddress: " + targetAddresses + ", subject: " | ||
+ subject + ", content: " + content ); | ||
map.put( "messageType", "sendWangWangMessage" ); | ||
map.put( "targetAddress", URLEncoder.encode( targetAddress,"UTF-8" ) ); | ||
url = StringUtil.replacePlaceholder( SystemConstant.URL_TEMPLEMENT_OF_MESSAG_SEND, map ); | ||
} | ||
} else if ( channel.equalsIgnoreCase( MessageType.SMS.toString() ) ) { | ||
|
||
} catch ( Exception e ) { | ||
LOG.warn( "Send " + channel + " message failure, send type is " + sendType + ", targetAddress: " + targetAddresses + ", subject: " | ||
+ subject + ", content: " + content ); | ||
LOG.error( e.getMessage() ); | ||
for ( String targetAddress : targetAddressList ) { | ||
map.put( "messageType", "sendWangWangMessage" ); | ||
map.put( "targetAddress", URLEncoder.encode( targetAddress, "UTF-8" ) ); | ||
url = StringUtil.replacePlaceholder( SystemConstant.URL_TEMPLEMENT_OF_MESSAG_SEND, map ); | ||
} | ||
} | ||
return result; | ||
return "ok".equalsIgnoreCase( NetUtil.getContentOfUrl( url ) ); | ||
|
||
} | ||
|
||
} |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters