• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    迪恩网络公众号

Java DPathUtils类代码示例

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

本文整理汇总了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;未经允许,请勿转载。


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
Java GetLabelsToNodesResponse类代码示例发布时间:2022-05-22
下一篇:
Java LogLevel类代码示例发布时间:2022-05-22
热门推荐
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap