本文整理汇总了Java中com.github.ddth.commons.utils.DPathUtils类的典型用法代码示例。如果您正苦于以下问题:Java DPathUtils类的具体用法?Java DPathUtils怎么用?Java DPathUtils使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
DPathUtils类属于com.github.ddth.commons.utils包,在下文中一共展示了DPathUtils类的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: queueExists
import com.github.ddth.commons.utils.DPathUtils; //导入依赖的package包/类
public static Result queueExists() {
Map<String, Object> params = parseRequest();
String queueName = DPathUtils.getValue(params, "queue_name", String.class);
String secret = DPathUtils.getValue(params, "secret", String.class);
QueueApi queueApi = Registry.getQueueApi();
try {
if (!queueApi.authorize(secret, queueName)) {
return doResponse(403, "Unauthorized!", false, null);
}
boolean result = queueApi.queueExists(queueName);
return doResponse(result ? 200 : 404, String.valueOf(result), result, null);
} catch (Exception e) {
final String logMsg = "Exception [" + e.getClass() + "]: " + e.getMessage();
Logger.error(logMsg, e);
return doResponse(500, logMsg, false, null);
}
}
开发者ID:btnguyen2k,项目名称:queue-server,代码行数:19,代码来源:Application.java
示例2: initQueue
import com.github.ddth.commons.utils.DPathUtils; //导入依赖的package包/类
public static Result initQueue() {
Map<String, Object> params = parseRequest();
String queueName = DPathUtils.getValue(params, "queue_name", String.class);
String secret = DPathUtils.getValue(params, "secret", String.class);
QueueApi queueApi = Registry.getQueueApi();
try {
if (!queueApi.isValidQueueName(queueName)) {
return doResponse(400, "Invalid queue name [" + queueName + "]!", false, null);
}
if (!queueApi.authorize(secret, queueName)) {
return doResponse(403, "Unauthorized!", false, null);
}
boolean result = queueApi.initQueue(queueName);
return doResponse(200, String.valueOf(result), result, null);
} catch (Exception e) {
final String logMsg = "Exception [" + e.getClass() + "]: " + e.getMessage();
Logger.error(logMsg, e);
return doResponse(500, logMsg, false, null);
}
}
开发者ID:btnguyen2k,项目名称:queue-server,代码行数:22,代码来源:Application.java
示例3: queue
import com.github.ddth.commons.utils.DPathUtils; //导入依赖的package包/类
public static Result queue() {
Map<String, Object> params = parseRequest();
String queueName = DPathUtils.getValue(params, "queue_name", String.class);
String secret = DPathUtils.getValue(params, "secret", String.class);
String contentBase64 = DPathUtils.getValue(params, "content", String.class);
QueueApi queueApi = Registry.getQueueApi();
try {
if (!queueApi.isValidQueueName(queueName)) {
return doResponse(400, "Invalid queue name [" + queueName + "]!", false, null);
}
if (!queueApi.authorize(secret, queueName)) {
return doResponse(403, "Unauthorized!", false, null);
}
QueueMessage queueMessage = QueueMessage.newInstance();
queueMessage.content(QueueServerUtils.base64Decode(contentBase64));
boolean result = queueApi.queue(queueName, queueMessage);
return doResponse(200, String.valueOf(result), result, null);
} catch (Exception e) {
final String logMsg = "Exception [" + e.getClass() + "]: " + e.getMessage();
Logger.error(logMsg, e);
return doResponse(500, logMsg, false, null);
}
}
开发者ID:btnguyen2k,项目名称:queue-server,代码行数:25,代码来源:Application.java
示例4: requeue
import com.github.ddth.commons.utils.DPathUtils; //导入依赖的package包/类
public static Result requeue() {
Map<String, Object> params = parseRequest();
String queueName = DPathUtils.getValue(params, "queue_name", String.class);
String secret = DPathUtils.getValue(params, "secret", String.class);
QueueApi queueApi = Registry.getQueueApi();
try {
if (!queueApi.isValidQueueName(queueName)) {
return doResponse(400, "Invalid queue name [" + queueName + "]!", false, null);
}
if (!queueApi.authorize(secret, queueName)) {
return doResponse(403, "Unauthorized!", false, null);
}
QueueMessage queueMessage = QueueServerUtils.queueMessageFromRequestParams(params);
boolean result = queueApi.requeue(queueName, queueMessage);
return doResponse(200, String.valueOf(result), result, null);
} catch (Exception e) {
final String logMsg = "Exception [" + e.getClass() + "]: " + e.getMessage();
Logger.error(logMsg, e);
return doResponse(500, logMsg, false, null);
}
}
开发者ID:btnguyen2k,项目名称:queue-server,代码行数:23,代码来源:Application.java
示例5: requeueSilent
import com.github.ddth.commons.utils.DPathUtils; //导入依赖的package包/类
public static Result requeueSilent() {
Map<String, Object> params = parseRequest();
String queueName = DPathUtils.getValue(params, "queue_name", String.class);
String secret = DPathUtils.getValue(params, "secret", String.class);
QueueApi queueApi = Registry.getQueueApi();
try {
if (!queueApi.isValidQueueName(queueName)) {
return doResponse(400, "Invalid queue name [" + queueName + "]!", false, null);
}
if (!queueApi.authorize(secret, queueName)) {
return doResponse(403, "Unauthorized!", false, null);
}
QueueMessage queueMessage = QueueServerUtils.queueMessageFromRequestParams(params);
boolean result = queueApi.requeueSilent(queueName, queueMessage);
return doResponse(200, String.valueOf(result), result, false);
} catch (Exception e) {
final String logMsg = "Exception [" + e.getClass() + "]: " + e.getMessage();
Logger.error(logMsg, e);
return doResponse(500, logMsg, false, null);
}
}
开发者ID:btnguyen2k,项目名称:queue-server,代码行数:23,代码来源:Application.java
示例6: finish
import com.github.ddth.commons.utils.DPathUtils; //导入依赖的package包/类
public static Result finish() {
Map<String, Object> params = parseRequest();
String queueName = DPathUtils.getValue(params, "queue_name", String.class);
String secret = DPathUtils.getValue(params, "secret", String.class);
QueueApi queueApi = Registry.getQueueApi();
try {
if (!queueApi.isValidQueueName(queueName)) {
return doResponse(400, "Invalid queue name [" + queueName + "]!", false, null);
}
if (!queueApi.authorize(secret, queueName)) {
return doResponse(403, "Unauthorized!", false, null);
}
QueueMessage queueMessage = QueueServerUtils.queueMessageFromRequestParams(params);
boolean result = queueApi.finish(queueName, queueMessage);
return doResponse(200, String.valueOf(result), result, null);
} catch (Exception e) {
final String logMsg = "Exception [" + e.getClass() + "]: " + e.getMessage();
Logger.error(logMsg, e);
return doResponse(500, logMsg, false, null);
}
}
开发者ID:btnguyen2k,项目名称:queue-server,代码行数:23,代码来源:Application.java
示例7: take
import com.github.ddth.commons.utils.DPathUtils; //导入依赖的package包/类
public static Result take() {
Map<String, Object> params = parseRequest();
String queueName = DPathUtils.getValue(params, "queue_name", String.class);
String secret = DPathUtils.getValue(params, "secret", String.class);
QueueApi queueApi = Registry.getQueueApi();
try {
if (!queueApi.isValidQueueName(queueName)) {
return doResponse(400, "Invalid queue name [" + queueName + "]!", false, null);
}
if (!queueApi.authorize(secret, queueName)) {
return doResponse(403, "Unauthorized!", false, null);
}
QueueMessage msg = queueApi.take(queueName);
Map<String, Object> result = QueueServerUtils.queueMessageToResponseParams(msg);
return doResponse(200, "", result != null, result);
} catch (Exception e) {
final String logMsg = "Exception [" + e.getClass() + "]: " + e.getMessage();
Logger.error(logMsg, e);
return doResponse(500, logMsg, false, null);
}
}
开发者ID:btnguyen2k,项目名称:queue-server,代码行数:23,代码来源:Application.java
示例8: queueSize
import com.github.ddth.commons.utils.DPathUtils; //导入依赖的package包/类
public static Result queueSize() {
Map<String, Object> params = parseRequest();
String queueName = DPathUtils.getValue(params, "queue_name", String.class);
String secret = DPathUtils.getValue(params, "secret", String.class);
QueueApi queueApi = Registry.getQueueApi();
try {
if (!queueApi.isValidQueueName(queueName)) {
return doResponse(400, "Invalid queue name [" + queueName + "]!", false, null);
}
if (!queueApi.authorize(secret, queueName)) {
return doResponse(403, "Unauthorized!", false, null);
}
int result = queueApi.queueSize(queueName);
return doResponse(200, "", result >= 0, result);
} catch (Exception e) {
final String logMsg = "Exception [" + e.getClass() + "]: " + e.getMessage();
Logger.error(logMsg, e);
return doResponse(500, logMsg, false, null);
}
}
开发者ID:btnguyen2k,项目名称:queue-server,代码行数:22,代码来源:Application.java
示例9: ephemeralSize
import com.github.ddth.commons.utils.DPathUtils; //导入依赖的package包/类
public static Result ephemeralSize() {
Map<String, Object> params = parseRequest();
String queueName = DPathUtils.getValue(params, "queue_name", String.class);
String secret = DPathUtils.getValue(params, "secret", String.class);
QueueApi queueApi = Registry.getQueueApi();
try {
if (!queueApi.isValidQueueName(queueName)) {
return doResponse(400, "Invalid queue name [" + queueName + "]!", false, null);
}
if (!queueApi.authorize(secret, queueName)) {
return doResponse(403, "Unauthorized!", false, null);
}
int result = queueApi.ephemeralSize(queueName);
return doResponse(200, "", result >= 0, result);
} catch (Exception e) {
final String logMsg = "Exception [" + e.getClass() + "]: " + e.getMessage();
Logger.error(logMsg, e);
return doResponse(500, logMsg, false, null);
}
}
开发者ID:btnguyen2k,项目名称:queue-server,代码行数:22,代码来源:Application.java
示例10: queueMessageFromRequestParams
import com.github.ddth.commons.utils.DPathUtils; //导入依赖的package包/类
/**
* Constructs a new {@link QueueMessage} from request's parameters.
*
* @param params
* @return
*/
public static QueueMessage queueMessageFromRequestParams(Map<String, Object> params) {
if (params == null) {
return null;
}
Long qId = DPathUtils.getValue(params, "queue_id", Long.class);
Date qOrgTimestamp = DPathUtils.getValue(params, "org_timestamp", Date.class);
Date qTimestamp = DPathUtils.getValue(params, "timestamp", Date.class);
Integer qNumRequeues = DPathUtils.getValue(params, "num_requeues", Integer.class);
String contentBase64 = DPathUtils.getValue(params, "content", String.class);
QueueMessage queueMessage = QueueMessage.newInstance(qId != null ? qId.longValue() : 0,
qOrgTimestamp, qTimestamp, qNumRequeues != null ? qNumRequeues.intValue() : 0,
QueueServerUtils.base64Decode(contentBase64));
return queueMessage;
}
开发者ID:btnguyen2k,项目名称:queue-server,代码行数:22,代码来源:QueueServerUtils.java
示例11: fromJson
import com.github.ddth.commons.utils.DPathUtils; //导入依赖的package包/类
/**
* Deserializes a BO from a JSON string.
*
* @param json
* the JSON string obtained from {@link #toJson(BaseBo)}
* @param clazz
* @param classLoader
* @return
* @since 0.6.0.3
*/
@SuppressWarnings("unchecked")
public static <T extends BaseBo> T fromJson(String json, Class<T> clazz,
ClassLoader classLoader) {
if (StringUtils.isBlank(json) || clazz == null) {
return null;
}
try {
Map<String, Object> data = SerializationUtils.fromJsonString(json, Map.class);
String boClassName = DPathUtils.getValue(data, FIELD_CLASSNAME, String.class);
T bo = createObject(boClassName, classLoader, clazz);
if (bo != null) {
bo.fromJson(DPathUtils.getValue(data, FIELD_BODATA, String.class));
return bo;
} else {
return null;
}
} catch (Exception e) {
throw e instanceof DeserializationException ? (DeserializationException) e
: new DeserializationException(e);
}
}
开发者ID:DDTH,项目名称:ddth-dao,代码行数:32,代码来源:BoUtils.java
示例12: fromBytes
import com.github.ddth.commons.utils.DPathUtils; //导入依赖的package包/类
/**
* Deserializes a BO from a byte array.
*
* @param bytes
* the byte array obtained from {@link #toBytes(BaseBo)}
* @param clazz
* @param classLoader
* @return
* @since 0.6.0.3
*/
@SuppressWarnings("unchecked")
public static <T extends BaseBo> T fromBytes(byte[] bytes, Class<T> clazz,
ClassLoader classLoader) {
if (bytes == null || clazz == null) {
return null;
}
try {
Map<String, Object> data = SerializationUtils.fromByteArray(bytes, Map.class);
String boClassName = DPathUtils.getValue(data, FIELD_CLASSNAME, String.class);
T bo = createObject(boClassName, classLoader, clazz);
if (bo != null) {
bo.fromByteArray(DPathUtils.getValue(data, FIELD_BODATA, byte[].class));
return bo;
} else {
return null;
}
} catch (Exception e) {
throw e instanceof DeserializationException ? (DeserializationException) e
: new DeserializationException(e);
}
}
开发者ID:DDTH,项目名称:ddth-dao,代码行数:32,代码来源:BoUtils.java
示例13: fromMap
import com.github.ddth.commons.utils.DPathUtils; //导入依赖的package包/类
/**
* Populate the BO with data from a Java map (previously generated by
* {@link #toMap()}.
*
* @param data
* BO data as a Java map (generated via {@link #toMap()}
* @return
*/
@SuppressWarnings("unchecked")
public BaseBo fromMap(Map<String, Object> data) {
if (data != null) {
lock.lock();
try {
Boolean dirty = DPathUtils.getValue(data, SER_FIELD_DIRTY, Boolean.class);
Map<String, Object> attrs = DPathUtils.getValue(data, SER_FIELD_ATTRS, Map.class);
this.attributes = initAttributes(attrs);
this.dirty = dirty != null ? dirty.booleanValue() : true;
triggerPopulate();
} finally {
lock.unlock();
}
}
return this;
}
开发者ID:DDTH,项目名称:ddth-dao,代码行数:25,代码来源:BaseBo.java
示例14: setSubAttr
import com.github.ddth.commons.utils.DPathUtils; //导入依赖的package包/类
/**
* Set a sub-attribute.
*
* @param attrName
* @param value
* @return
*/
public BaseJsonBo setSubAttr(String attrName, String dPath, Object value) {
lock();
try {
JsonNode attr = cacheJsonObjs.get(attrName);
if (attr == null) {
String[] paths = DPathUtils.splitDpath(dPath);
if (paths[0].matches("^\\[(.*?)\\]$")) {
setAttribute(attrName, "[]");
} else {
setAttribute(attrName, "{}");
}
attr = cacheJsonObjs.get(attrName);
}
JacksonUtils.setValue(attr, dPath, value, true);
return (BaseJsonBo) setAttribute(attrName, SerializationUtils.toJsonString(attr),
false);
} finally {
unlock();
}
}
开发者ID:DDTH,项目名称:ddth-dao,代码行数:28,代码来源:BaseJsonBo.java
示例15: main
import com.github.ddth.commons.utils.DPathUtils; //导入依赖的package包/类
public static void main(String[] args) {
Map<String, Object> data = new HashMap<String, Object>();
System.out.println(data);
System.out.println(DPathUtils.getValue(data, "temp", int.class));
byte[] content = "content".getBytes();
DPathUtils.setValue(data, "content", content);
System.out.println(data);
System.out.println(DPathUtils.getValue(data, "content"));
System.out.println(DPathUtils.getValue(data, "content", byte[].class));
data.clear();
DPathUtils.setValue(data, "num1", 1);
data.put("num2", 2.0);
System.out.println(data);
System.out.println(DPathUtils.getValue(data, "num1"));
System.out.println(DPathUtils.getValue(data, "num2", Integer.class));
System.out.println(DPathUtils.getValue(data, "num1", Number.class));
}
开发者ID:DDTH,项目名称:ddth-commons,代码行数:22,代码来源:QndDPathUtils.java
示例16: getAllQueueNames
import com.github.ddth.commons.utils.DPathUtils; //导入依赖的package包/类
protected Collection<String> getAllQueueNames() {
Collection<String> allQueueNames = new HashSet<String>();
try {
Connection conn = connection();
try {
conn.setAutoCommit(true);
JdbcTemplate jdbcTemplate = jdbcTemplate(conn);
final String SQL = "SELECT * FROM {0}";
List<Map<String, Object>> dbRows = jdbcTemplate.queryForList(MessageFormat.format(
SQL, getTableMetadata()));
if (dbRows != null) {
for (Map<String, Object> dbRow : dbRows) {
String queueName = DPathUtils.getValue(dbRow, "queue_name", String.class);
if (!StringUtils.isBlank(queueName)) {
allQueueNames.add(queueName);
}
}
}
} finally {
conn.close();
}
} catch (SQLException e) {
Logger.error(e.getMessage(), e);
}
return allQueueNames;
}
开发者ID:btnguyen2k,项目名称:queue-server,代码行数:28,代码来源:JdbcQueueApi.java
示例17: nextId
import com.github.ddth.commons.utils.DPathUtils; //导入依赖的package包/类
/**
* {@inheritDoc}
*/
@Override
public long nextId(String namespace, EngineType engine) {
String apiUri = "/nextId/" + namespace;
if (engine != null) {
switch (engine) {
case JDBC:
apiUri = "/nextId/" + namespace + "/jdbc";
break;
case REDIS:
apiUri = "/nextId/" + namespace + "/redis";
break;
case SNOWFLAKE:
apiUri = "/nextId/" + namespace + "/snowflake";
break;
case ZOOKEEPER:
apiUri = "/nextId/" + namespace + "/zookeeper";
break;
default:
}
}
Map<String, Object> apiResult = callApi(idServerUrl + apiUri);
if (apiResult == null) {
return -1;
}
Integer status = DPathUtils.getValue(apiResult, "status", Integer.class);
Long id = DPathUtils.getValue(apiResult, "id", Long.class);
return status != null && status.intValue() == 200 ? (id != null ? id.longValue() : -1) : -1;
}
开发者ID:btnguyen2k,项目名称:id-jclient,代码行数:32,代码来源:RestIdClient.java
示例18: fromMap
import com.github.ddth.commons.utils.DPathUtils; //导入依赖的package包/类
/**
* Deserialize queue message from a {@link Map}.
*
* @param dataMap
* @return
* @since 0.5.0
*/
@SuppressWarnings("unchecked")
public BaseUniversalQueueMessage<ID> fromMap(Map<String, Object> dataMap) {
Object queueId = DPathUtils.getValue(dataMap, FIELD_QUEUE_ID);
if (queueId != null) {
qId((ID) queueId);
}
Date orgTimestamp = DPathUtils.getValue(dataMap, FIELD_ORG_TIMESTAMP, Date.class);
if (orgTimestamp != null) {
qOriginalTimestamp(orgTimestamp);
}
Date timestamp = DPathUtils.getValue(dataMap, FIELD_TIMESTAMP, Date.class);
if (timestamp != null) {
qTimestamp(timestamp);
}
Integer numRequeues = DPathUtils.getValue(dataMap, FIELD_NUM_REQUEUES, Integer.class);
if (numRequeues != null) {
qNumRequeues(numRequeues.intValue());
}
Object content = DPathUtils.getValue(dataMap, FIELD_DATA);
if (content != null) {
if (content instanceof byte[]) {
content((byte[]) content);
} else if (content instanceof String) {
content((byte[]) Base64.decodeBase64((String) content));
}
}
String partitionKey = DPathUtils.getValue(dataMap, FIELD_PARTITION_KEY, String.class);
if (partitionKey != null) {
qPartitionKey(partitionKey);
}
return this;
}
开发者ID:DDTH,项目名称:ddth-queue,代码行数:46,代码来源:BaseUniversalQueueMessage.java
示例19: queueSize
import com.github.ddth.commons.utils.DPathUtils; //导入依赖的package包/类
/**
* {@inheritDoc}
*
* @since 0.6.2.3
*/
@Override
protected int queueSize(Connection conn) {
Map<String, Object> row = getJdbcHelper().executeSelectOne(conn, SQL_COUNT, getQueueName());
Integer result = DPathUtils.getValue(row, FIELD_COUNT, Integer.class);
return result != null ? result.intValue() : 0;
}
开发者ID:DDTH,项目名称:ddth-queue,代码行数:12,代码来源:AbstractLessLockingUniversalSingleStorageJdbcQueue.java
示例20: ephemeralSize
import com.github.ddth.commons.utils.DPathUtils; //导入依赖的package包/类
/**
* {@inheritDoc}
*
* @since 0.6.2.3
*/
@Override
protected int ephemeralSize(Connection conn) {
Map<String, Object> row = getJdbcHelper().executeSelectOne(conn, SQL_COUNT_EPHEMERAL,
getQueueName());
Integer result = DPathUtils.getValue(row, FIELD_COUNT, Integer.class);
return result != null ? result.intValue() : 0;
}
开发者ID:DDTH,项目名称:ddth-queue,代码行数:13,代码来源:AbstractLessLockingUniversalSingleStorageJdbcQueue.java
注:本文中的com.github.ddth.commons.utils.DPathUtils类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论