OrientDB Server 阻塞问题分析(一)

在OrientDB pyorient 的使用中发现，如果因为执行非法的语句（比如 select * from xxxxxxxx, xxxxxxxx 是一个不存在的class）导致OrientDB Server 解析失败（com.orientechnologies.orient.core.exception.OQueryParsingException: Error on parsing query), pyorient 会抛出 MemoryError。 此时pyorient client 就不能正常使用，会“阻塞”当前进程，需要重新初始化client 才可以继续使用。

具体示例如下：

# filename: test.py 

import logging

from tornado.options import parse_command_line
import pyorient

cmdb_port = 2424
cmdb_url = "db-vip"
db_username = "root"
db_password = "root"
db_name = "cmdb_test"

client = pyorient.OrientDB(cmdb_url, cmdb_port)
session_id = client.connect(db_username, db_password)



def test_cmd(sql_cmd):
    logging.info('come into test_cmd')
    try:
        client.db_open(db_name, db_username, db_password)
        ret = client.command(sql_cmd)
        logging.info('ret len: %s', len(ret))
    except Exception as e:
        logging.exception("Test cmd failed, Exception: %s", e.args)


if __name__ == '__main__':
    parse_command_line()

    sql_cmd_1 = 'select * from xxxxxxx'   #  类 xxxxxxx 不存在，非法的sql 语句
    for i in range(3):
        test_cmd(sql_cmd_1)

    sql_cmd_2 = 'select * from V'  #  有效的sql 语句 
    test_cmd(sql_cmd_2)

执行 test.py 文件, 发现：
三次执行 sql_cmd_1 都出现了异常，提示 MemoryError.
之后执行 sql_cmd_2 也出现了同样的异常，提示 MemoryError.

(py2.7.13env) [root@test-app-1 misc]# python test.py
[I 180322 15:56:20 test:19] come into test_cmd
[E 180322 15:56:20 test:30] Test cmd failed, Exception: ()
    Traceback (most recent call last):
      File "test.py", line 22, in test_cmd
        ret = client.command(sql_cmd)
      File "/root/.virtualenvs/py2.7.13cmdb2.0/lib/python2.7/site-packages/pyorient/orient.py", line 462, in command
        .prepare(( QUERY_CMD, ) + args).send().fetch_response()
      File "/root/.virtualenvs/py2.7.13cmdb2.0/lib/python2.7/site-packages/pyorient/messages/commands.py", line 144, in fetch_response
        super( CommandMessage, self ).fetch_response()
      File "/root/.virtualenvs/py2.7.13cmdb2.0/lib/python2.7/site-packages/pyorient/messages/base.py", line 265, in fetch_response
        self._decode_all()
      File "/root/.virtualenvs/py2.7.13cmdb2.0/lib/python2.7/site-packages/pyorient/messages/base.py", line 249, in _decode_all
        self._decode_header()
      File "/root/.virtualenvs/py2.7.13cmdb2.0/lib/python2.7/site-packages/pyorient/messages/base.py", line 176, in _decode_header
        serialized_exception = self._decode_field( FIELD_STRING )
      File "/root/.virtualenvs/py2.7.13cmdb2.0/lib/python2.7/site-packages/pyorient/messages/base.py", line 366, in _decode_field
        _decoded_string = self._orientSocket.read( _len )
      File "/root/.virtualenvs/py2.7.13cmdb2.0/lib/python2.7/site-packages/pyorient/orient.py", line 164, in read
        buf = bytearray(_len_to_read)
    MemoryError

[I 180322 15:56:20 test:19] come into test_cmd
[E 180322 15:56:20 test:30] Test cmd failed, Exception: ()
    Traceback (most recent call last):
      File "test.py", line 21, in test_cmd
        client.db_open(db_name, db_username, db_password)
      File "/root/.virtualenvs/py2.7.13cmdb2.0/lib/python2.7/site-packages/pyorient/orient.py", line 412, in db_open
        .prepare((db_name, user, password, db_type, client_id)).send().fetch_response()
      File "/root/.virtualenvs/py2.7.13cmdb2.0/lib/python2.7/site-packages/pyorient/messages/database.py", line 101, in fetch_response
        result = super(DbOpenMessage, self).fetch_response()
      File "/root/.virtualenvs/py2.7.13cmdb2.0/lib/python2.7/site-packages/pyorient/messages/base.py", line 265, in fetch_response
        self._decode_all()
      File "/root/.virtualenvs/py2.7.13cmdb2.0/lib/python2.7/site-packages/pyorient/messages/base.py", line 250, in _decode_all
        self._decode_body()
      File "/root/.virtualenvs/py2.7.13cmdb2.0/lib/python2.7/site-packages/pyorient/messages/base.py", line 242, in _decode_body
        self._body.append( self._decode_field( field ) )
      File "/root/.virtualenvs/py2.7.13cmdb2.0/lib/python2.7/site-packages/pyorient/messages/base.py", line 366, in _decode_field
        _decoded_string = self._orientSocket.read( _len )
      File "/root/.virtualenvs/py2.7.13cmdb2.0/lib/python2.7/site-packages/pyorient/orient.py", line 164, in read
        buf = bytearray(_len_to_read)
    MemoryError
[I 180322 15:56:20 test:19] come into test_cmd
[E 180322 15:56:20 test:30] Test cmd failed, Exception: ()
    Traceback (most recent call last):
      File "test.py", line 21, in test_cmd
        client.db_open(db_name, db_username, db_password)
      File "/root/.virtualenvs/py2.7.13cmdb2.0/lib/python2.7/site-packages/pyorient/orient.py", line 412, in db_open
        .prepare((db_name, user, password, db_type, client_id)).send().fetch_response()
      File "/root/.virtualenvs/py2.7.13cmdb2.0/lib/python2.7/site-packages/pyorient/messages/database.py", line 101, in fetch_response
        result = super(DbOpenMessage, self).fetch_response()
      File "/root/.virtualenvs/py2.7.13cmdb2.0/lib/python2.7/site-packages/pyorient/messages/base.py", line 265, in fetch_response
        self._decode_all()
      File "/root/.virtualenvs/py2.7.13cmdb2.0/lib/python2.7/site-packages/pyorient/messages/base.py", line 250, in _decode_all
        self._decode_body()
      File "/root/.virtualenvs/py2.7.13cmdb2.0/lib/python2.7/site-packages/pyorient/messages/base.py", line 242, in _decode_body
        self._body.append( self._decode_field( field ) )
      File "/root/.virtualenvs/py2.7.13cmdb2.0/lib/python2.7/site-packages/pyorient/messages/base.py", line 366, in _decode_field
        _decoded_string = self._orientSocket.read( _len )
      File "/root/.virtualenvs/py2.7.13cmdb2.0/lib/python2.7/site-packages/pyorient/orient.py", line 164, in read
        buf = bytearray(_len_to_read)
    MemoryError

[I 180322 15:56:20 test:19] come into test_cmd
[E 180322 15:56:20 test:30] Test cmd failed, Exception: ()
    Traceback (most recent call last):
      File "test.py", line 21, in test_cmd
        client.db_open(db_name, db_username, db_password)
      File "/root/.virtualenvs/py2.7.13cmdb2.0/lib/python2.7/site-packages/pyorient/orient.py", line 412, in db_open
        .prepare((db_name, user, password, db_type, client_id)).send().fetch_response()
      File "/root/.virtualenvs/py2.7.13cmdb2.0/lib/python2.7/site-packages/pyorient/messages/database.py", line 101, in fetch_response
        result = super(DbOpenMessage, self).fetch_response()
      File "/root/.virtualenvs/py2.7.13cmdb2.0/lib/python2.7/site-packages/pyorient/messages/base.py", line 265, in fetch_response
        self._decode_all()
      File "/root/.virtualenvs/py2.7.13cmdb2.0/lib/python2.7/site-packages/pyorient/messages/base.py", line 250, in _decode_all
        self._decode_body()
      File "/root/.virtualenvs/py2.7.13cmdb2.0/lib/python2.7/site-packages/pyorient/messages/base.py", line 242, in _decode_body
        self._body.append( self._decode_field( field ) )
      File "/root/.virtualenvs/py2.7.13cmdb2.0/lib/python2.7/site-packages/pyorient/messages/base.py", line 366, in _decode_field
        _decoded_string = self._orientSocket.read( _len )
      File "/root/.virtualenvs/py2.7.13cmdb2.0/lib/python2.7/site-packages/pyorient/orient.py", line 164, in read
        buf = bytearray(_len_to_read)
    MemoryError

查看 OrientDB Server 的日志， 可以看到 OQueryParsingException。
虽然OrientDB Server 出现错误日志，但不影响 OrientDB Server 的正常使用，OrientDB Studio 也可以正常访问和使用。

xception `1320FF76` in storage `plocal:/opt/orientdb/databases/cmdb_test`: 2.2.31 (build 285537d2767275f460df32c6a3be01bfff6a517c,
branch 2.2.x)
com.orientechnologies.orient.core.exception.OQueryParsingException: Error on parsing query
Query:  xxxxxxx
------^
        DB name="cmdb_test"
        at com.orientechnologies.orient.core.sql.filter.OSQLTarget.<init>(OSQLTarget.java:74)
        at com.orientechnologies.orient.core.sql.OSQLEngine.parseTarget(OSQLEngine.java:464)
        at com.orientechnologies.orient.core.sql.OCommandExecutorSQLSelect.parse(OCommandExecutorSQLSelect.java:278)
        at com.orientechnologies.orient.core.sql.OCommandExecutorSQLSelect.parse(OCommandExecutorSQLSelect.java:93)
        at com.orientechnologies.orient.core.sql.OCommandExecutorSQLDelegate.parse(OCommandExecutorSQLDelegate.java:53)
        at com.orientechnologies.orient.core.sql.OCommandExecutorSQLDelegate.parse(OCommandExecutorSQLDelegate.java:34)
        at com.orientechnologies.orient.core.storage.impl.local.OAbstractPaginatedStorage.command(OAbstractPaginatedStorage.java:331
9)
        at com.orientechnologies.orient.core.command.OCommandRequestTextAbstract.execute(OCommandRequestTextAbstract.java:69)
        at com.orientechnologies.orient.server.network.protocol.binary.ONetworkProtocolBinary.command(ONetworkProtocolBinary.java:15
64)
        at com.orientechnologies.orient.server.network.protocol.binary.ONetworkProtocolBinary.executeRequest(ONetworkProtocolBinary.
java:664)
        at com.orientechnologies.orient.server.network.protocol.binary.ONetworkProtocolBinary.sessionRequest(ONetworkProtocolBinary.
java:398)
        at com.orientechnologies.orient.server.network.protocol.binary.ONetworkProtocolBinary.execute(ONetworkProtocolBinary.java:21
7)
        at com.orientechnologies.common.thread.OSoftThread.run(OSoftThread.java:82)
Caused by: com.orientechnologies.orient.core.exception.OCommandExecutionException: Class 'XXXXXXX' was not found in database 'cmdb_t
est'
        DB name="cmdb_test"
        at com.orientechnologies.orient.core.sql.filter.OSQLTarget.extractTargets(OSQLTarget.java:273)
        at com.orientechnologies.orient.core.sql.filter.OSQLTarget.<init>(OSQLTarget.java:64)
        ... 12 more

结合日志，分析发现： 一旦client.command() 执行出现异常，当前Client 就不能正常使用，即使去执行正常有效的sql_command 也不能执行获取结果集。

一个改进的策略是：

在发现client 不可用的时候（比如 catch 到 MemoryError），重置一下client。
test_cmd方法的修改如下：

def test_cmd(sql_cmd):
    logging.info('come into test_cmd')
    try:
        client.db_open(db_name, db_username, db_password)
        ret = client.command(sql_cmd)
        logging.info('ret len: %s', len(ret))
    except MemoryError as e:
        global client
        client = pyorient.OrientDB(cmdb_url, cmdb_port)
        logging.exception("Test cmd failed, Exception: %s", e.args)
    except Exception as e:
        logging.exception("Test cmd failed, Exception: %s", e.args)

再次执行 test.py, 发现 在执行 sql_cmd_1 时出现了 MemoryError。但在后续执行sql_cmd_2 的时候可以正常执行。

(py2.7.13cmdb2.0) [root@test-app-1 misc]# python test.py
test.py:25: SyntaxWarning: name 'client' is used prior to global declaration
  global client
[I 180322 16:13:21 test:19] come into test_cmd
[E 180322 16:13:21 test:27] Test cmd failed, Exception: ()
    Traceback (most recent call last):
      File "test.py", line 22, in test_cmd
        ret = client.command(sql_cmd)
      File "/root/.virtualenvs/py2.7.13cmdb2.0/lib/python2.7/site-packages/pyorient/orient.py", line 462, in command
        .prepare(( QUERY_CMD, ) + args).send().fetch_response()
      File "/root/.virtualenvs/py2.7.13cmdb2.0/lib/python2.7/site-packages/pyorient/messages/commands.py", line 144, in fetch_response
        super( CommandMessage, self ).fetch_response()
      File "/root/.virtualenvs/py2.7.13cmdb2.0/lib/python2.7/site-packages/pyorient/messages/base.py", line 265, in fetch_response
        self._decode_all()
      File "/root/.virtualenvs/py2.7.13cmdb2.0/lib/python2.7/site-packages/pyorient/messages/base.py", line 249, in _decode_all
        self._decode_header()
      File "/root/.virtualenvs/py2.7.13cmdb2.0/lib/python2.7/site-packages/pyorient/messages/base.py", line 176, in _decode_header
        serialized_exception = self._decode_field( FIELD_STRING )
      File "/root/.virtualenvs/py2.7.13cmdb2.0/lib/python2.7/site-packages/pyorient/messages/base.py", line 366, in _decode_field
        _decoded_string = self._orientSocket.read( _len )
      File "/root/.virtualenvs/py2.7.13cmdb2.0/lib/python2.7/site-packages/pyorient/orient.py", line 164, in read
        buf = bytearray(_len_to_read)
    MemoryError
[I 180322 16:13:21 test:19] come into test_cmd
[E 180322 16:13:21 test:27] Test cmd failed, Exception: ()
    Traceback (most recent call last):
      File "test.py", line 22, in test_cmd
        ret = client.command(sql_cmd)
      File "/root/.virtualenvs/py2.7.13cmdb2.0/lib/python2.7/site-packages/pyorient/orient.py", line 462, in command
        .prepare(( QUERY_CMD, ) + args).send().fetch_response()
      File "/root/.virtualenvs/py2.7.13cmdb2.0/lib/python2.7/site-packages/pyorient/messages/commands.py", line 144, in fetch_response
        super( CommandMessage, self ).fetch_response()
      File "/root/.virtualenvs/py2.7.13cmdb2.0/lib/python2.7/site-packages/pyorient/messages/base.py", line 265, in fetch_response
        self._decode_all()
      File "/root/.virtualenvs/py2.7.13cmdb2.0/lib/python2.7/site-packages/pyorient/messages/base.py", line 249, in _decode_all
        self._decode_header()
      File "/root/.virtualenvs/py2.7.13cmdb2.0/lib/python2.7/site-packages/pyorient/messages/base.py", line 176, in _decode_header
        serialized_exception = self._decode_field( FIELD_STRING )
      File "/root/.virtualenvs/py2.7.13cmdb2.0/lib/python2.7/site-packages/pyorient/messages/base.py", line 366, in _decode_field
        _decoded_string = self._orientSocket.read( _len )
      File "/root/.virtualenvs/py2.7.13cmdb2.0/lib/python2.7/site-packages/pyorient/orient.py", line 164, in read
        buf = bytearray(_len_to_read)
    MemoryError
[I 180322 16:13:21 test:19] come into test_cmd
[E 180322 16:13:21 test:27] Test cmd failed, Exception: ()
    Traceback (most recent call last):
      File "test.py", line 22, in test_cmd
        ret = client.command(sql_cmd)
      File "/root/.virtualenvs/py2.7.13cmdb2.0/lib/python2.7/site-packages/pyorient/orient.py", line 462, in command
        .prepare(( QUERY_CMD, ) + args).send().fetch_response()
      File "/root/.virtualenvs/py2.7.13cmdb2.0/lib/python2.7/site-packages/pyorient/messages/commands.py", line 144, in fetch_response
        super( CommandMessage, self ).fetch_response()
      File "/root/.virtualenvs/py2.7.13cmdb2.0/lib/python2.7/site-packages/pyorient/messages/base.py", line 265, in fetch_response
        self._decode_all()
      File "/root/.virtualenvs/py2.7.13cmdb2.0/lib/python2.7/site-packages/pyorient/messages/base.py", line 249, in _decode_all
        self._decode_header()
      File "/root/.virtualenvs/py2.7.13cmdb2.0/lib/python2.7/site-packages/pyorient/messages/base.py", line 176, in _decode_header
        serialized_exception = self._decode_field( FIELD_STRING )
      File "/root/.virtualenvs/py2.7.13cmdb2.0/lib/python2.7/site-packages/pyorient/messages/base.py", line 366, in _decode_field
        _decoded_string = self._orientSocket.read( _len )
      File "/root/.virtualenvs/py2.7.13cmdb2.0/lib/python2.7/site-packages/pyorient/orient.py", line 164, in read
        buf = bytearray(_len_to_read)
    MemoryError
[I 180322 16:13:21 test:19] come into test_cmd
[I 180322 16:13:23 test:23] ret len: 6109

扩展

同样的问题，在交互式命令行，会提示 timeout， 这个比较奇怪 :(
执行到 pyorient/orient.py read() 时候， 文件执行和命令行执行出现差别...

In [36]: sql_cmd_1 = 'select * from xxxxxxx'

In [37]: test_cmd(sql_cmd_1)
ERROR:root:Test cmd failed, Exception: ('timed out',)
Traceback (most recent call last):
  File "<ipython-input-35-22cb912a84d8>", line 5, in test_cmd
    ret = client.command(sql_cmd)
  File "/root/.virtualenvs/py2.7.14cmdb2.0/lib/python2.7/site-packages/pyorient/orient.py", line 462, in command
    .prepare(( QUERY_CMD, ) + args).send().fetch_response()
  File "/root/.virtualenvs/py2.7.14cmdb2.0/lib/python2.7/site-packages/pyorient/messages/commands.py", line 144, in fetch_response
    super( CommandMessage, self ).fetch_response()
  File "/root/.virtualenvs/py2.7.14cmdb2.0/lib/python2.7/site-packages/pyorient/messages/base.py", line 265, in fetch_response
    self._decode_all()
  File "/root/.virtualenvs/py2.7.14cmdb2.0/lib/python2.7/site-packages/pyorient/messages/base.py", line 249, in _decode_all
    self._decode_header()
  File "/root/.virtualenvs/py2.7.14cmdb2.0/lib/python2.7/site-packages/pyorient/messages/base.py", line 176, in _decode_header
    serialized_exception = self._decode_field( FIELD_STRING )
  File "/root/.virtualenvs/py2.7.14cmdb2.0/lib/python2.7/site-packages/pyorient/messages/base.py", line 366, in _decode_field
    _decoded_string = self._orientSocket.read( _len )
  File "/root/.virtualenvs/py2.7.14cmdb2.0/lib/python2.7/site-packages/pyorient/orient.py", line 167, in read
    n_bytes = self._socket.recv_into(view, _len_to_read)
timeout: timed out

附录：

class Exception(BaseException)
 |  Common base class for all non-exit exceptions.
 |
 |  Method resolution order:
 |      Exception
 |      BaseException
 |      __builtin__.object


class MemoryError(StandardError)
 |  Out of memory.
 |
 |  Method resolution order:
 |      MemoryError
 |      StandardError
 |      Exception
 |      BaseException
 |      __builtin__.object
 |


class OrientDB(__builtin__.object)
 |  OrientDB client object
 |
 |  Point of entrance to use the basic commands you can issue to the server
 |
 |  :param host: hostname of the server to connect  defaults to localhost
 |  :param port: integer port of the server         defaults to 2424
 |
 |  Usage::
 |
 |      >>> from pyorient import OrientDB
 |      >>> client = OrientDB("localhost", 2424)
 |      >>> client.db_open('MyDatabase', 'admin', 'admin')
 |
 |  Methods defined here:
 |
 |  __getattr__(self, item)
 |
 |  __init__(self, host='localhost', port=2424, serialization_type='ORecordDocument2csv')
 |
 |  batch(self, *args)
 |
 |  close(self)
 |
 |  command(self, *args)
 |


 |  db_open(self, db_name, user, password, db_type='document', client_id='')
 |       Opens a database on the remote OrientDB Server.
 |       Returns the Session-Id to being reused for all the next calls and the list of configured clusters
 |
 |      :param db_name: database name as string. Example: "demo"
 |      :param user: username as string
 |      :param password: password as string
 |      :param db_type: string, can be DB_TYPE_DOCUMENT or DB_TYPE_GRAPH
 |      :param client_id: Can be null for clients. In clustered configuration is the distributed node
 |      :return: an array of :class:`OrientCluster <pyorient.types.OrientCluster>` object
 |
 |      Usage::
 |
 |        >>> import pyorient
 |        >>> orient = pyorient.OrientDB('localhost', 2424)
 |        >>> orient.db_open('asd', 'admin', 'admin')
最后编辑于 ：
©著作权归作者所有,转载或内容合作请联系作者
  • 人面猴
    序言：七十年代末，一起剥皮案震惊了整个滨河市，随后出现的几起案子，更是在滨河造成了极大的恐慌，老刑警刘岩，带你破解...
    沈念sama阅读 204,590评论 6赞 478
  • 死咒
    序言：滨河连续发生了三起死亡事件，死亡现场离奇诡异，居然都是意外死亡，警方通过查阅死者的电脑和手机，发现死者居然都...
    沈念sama阅读 86,808评论 2赞 381
  • 救了他两次的神仙让他今天三更去死
    文/潘晓璐 我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
    开封第一讲书人阅读 151,151评论 0赞 337
  • 道士缉凶录：失踪的卖姜人
    文/不坏的土叔 我叫张陵，是天一观的道长。 经常有香客问我，道长，这世上最难降的妖魔是什么？ 我笑而不...
    开封第一讲书人阅读 54,779评论 1赞 277
  • 港岛之恋（遗憾婚礼）
    正文 为了忘掉前任，我火速办了婚礼，结果婚礼上，老公的妹妹穿的比我还像新娘。我一直安慰自己，他们只是感情好，可当我...
    茶点故事阅读 63,773评论 5赞 367
  • 恶毒庶女顶嫁案：这布局不是一般人想出来的
    文/花漫 我一把揭开白布。 她就那样静静地躺着，像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上，一...
    开封第一讲书人阅读 48,656评论 1赞 281
  • 城市分裂传说
    那天，我揣着相机与录音，去河边找鬼。 笑死，一个胖子当着我的面吹牛，可吹牛的内容都是我干的。 我是一名探鬼主播，决...
    沈念sama阅读 38,022评论 3赞 398
  • 双鸳鸯连环套：你想象不到人心有多黑
    文/苍兰香墨 我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
    开封第一讲书人阅读 36,678评论 0赞 258
  • 万荣杀人案实录
    序言：老挝万荣一对情侣失踪，失踪者是张志新（化名）和其女友刘颖，没想到半个月后，有当地人在树林里发现了一具尸体，经...
    沈念sama阅读 41,038评论 1赞 299
  • 护林员之死
    正文 独居荒郊野岭守林人离奇死亡，尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,659评论 2赞 321
  • 白月光启示录
    正文 我和宋清朗相恋三年，在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,756评论 1赞 330
  • 活死人
    序言：一个原本活蹦乱跳的男人离奇死亡，死状恐怖，灵堂内的尸体忽然破棺而出，到底是诈尸还是另有隐情，我是刑警宁泽，带...
    沈念sama阅读 33,411评论 4赞 321
  • 日本核电站爆炸内幕
    正文 年R本政府宣布，位于F岛的核电站，受9级特大地震影响，放射性物质发生泄漏。R本人自食恶果不足惜，却给世界环境...
    茶点故事阅读 39,005评论 3赞 307
  • 男人毒药：我在死后第九天来索命
    文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹，春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 29,973评论 0赞 19
  • 一桩弑父案，背后竟有这般阴谋
    文/苍兰香墨 我抬头看了看天上的太阳。三九已至，却和暖如春，着一层夹袄步出监牢的瞬间，已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,203评论 1赞 260
  • 情欲美人皮
    我被黑心中介骗来泰国打工， 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留，地道东北人。 一个月前我还...
    沈念sama阅读 45,053评论 2赞 350
  • 代替公主和亲
    正文 我出身青楼，却偏偏与公主长得像，于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子，可洞房花烛夜当晚...
    茶点故事阅读 42,495评论 2赞 343