{"id":50152,"date":"2023-06-28T04:57:46","date_gmt":"2023-11-10T01:26:50","guid":{"rendered":"https:\/\/www.silicloud.com\/zh\/blog\/%e7%94%a8scala%ef%bc%88%e5%b9%bb%e5%bd%b1%ef%bc%89%e6%9d%a5%e6%93%8d%e4%bd%9ccassandra\/"},"modified":"2024-04-30T11:01:17","modified_gmt":"2024-04-30T03:01:17","slug":"%e7%94%a8scala%ef%bc%88%e5%b9%bb%e5%bd%b1%ef%bc%89%e6%9d%a5%e6%93%8d%e4%bd%9ccassandra","status":"publish","type":"post","link":"https:\/\/www.silicloud.com\/zh\/blog\/%e7%94%a8scala%ef%bc%88%e5%b9%bb%e5%bd%b1%ef%bc%89%e6%9d%a5%e6%93%8d%e4%bd%9ccassandra\/","title":{"rendered":"\u7528Scala\uff08\u5e7b\u5f71\uff09\u6765\u64cd\u4f5cCassandra"},"content":{"rendered":"

\u4e00\u958b\u59cb<\/h1>\n

\u56e0\u4e3a\u6211\u4ee5\u524d\u4ece\u672a\u4f7f\u7528\u8fc7Scala\u64cd\u4f5cCassandra\uff0c\u6240\u4ee5\u6211\u51b3\u5b9a\u5c1d\u8bd5\u4e00\u4e0b\u3002
\n\u8d77\u521d\u6211\u4e5f\u8003\u8651\u4f7f\u7528Java\u7684\u9a71\u52a8\u7a0b\u5e8f\uff0c\u4f46\u662fphantom\u7684GitHub\u70b9\u8d5e\u6570\u4e0e\u5176\u76f8\u5dee\u65e0\u51e0\uff0c\u5e76\u4e14\u5b83\u662f\u7528Scala\u7f16\u5199\u7684\uff0c\u6240\u4ee5\u6211\u51b3\u5b9a\u8bd5\u8bd5\u8fd9\u4e2a\u3002<\/p>\n

\u203b Cassandra\u5728\u5355\u8282\u70b9\u4e0a\u542f\u52a8\u4e86Docker\u7684\u5b98\u65b9\u4ed3\u5e93\u3002\u4e0d\u4f1a\u5bf9Cassandra\u672c\u8eab\u8fdb\u884c\u89e3\u91ca\u3002<\/p>\n

\u6784\u6210<\/h2>\n

Scala\u7248\u672c\u4e3a2.12
\nsbt\u7248\u672c\u4e3a1.1
\nphantom\u7248\u672c\u4e3a2.24
\nCassandra\u7248\u672c\u4e3a3.11<\/p>\n

\u6210\u679c<\/h2>\n

sbt \u53ef\u4ee5\u7528\u4e2d\u6587\u7ffb\u8bd1\u4e3a”\u624d\u534e\u6d0b\u6ea2”\u3002<\/h1>\n

\u8fd9\u662f\u4e00\u4e2a SBT \u7684\u914d\u7f6e\u3002\u4e3a\u4e86\u4ece\u914d\u7f6e\u6587\u4ef6\u4e2d\u83b7\u53d6 Cassandra \u7684 ContactPoint\uff0c\u6211\u4eec\u8fd8\u6dfb\u52a0\u4e86 Lightbend \u7684 config\u3002<\/p>\n

name<\/span> :=<\/span> \"scala-cassandra-example\"<\/span>\r\n\r\nversion<\/span> :=<\/span> \"0.1\"<\/span>\r\n\r\nscalaVersion<\/span> :=<\/span> \"2.12.5\"<\/span>\r\n\r\nval<\/span> phantomVersion<\/span> =<\/span> \"2.24.2\"<\/span>\r\n\r\nlibraryDependencies<\/span> ++=<\/span> Seq<\/span>(<\/span>\r\n  \"com.outworkers\"<\/span>  %%<\/span> \"phantom-dsl\"<\/span> %<\/span> phantomVersion<\/span>,<\/span>\r\n  \"com.outworkers\"<\/span>  %%<\/span> \"phantom-connectors\"<\/span> %<\/span> phantomVersion<\/span>,<\/span>\r\n  \"com.typesafe\"<\/span> %<\/span> \"config\"<\/span> %<\/span> \"1.3.3\"<\/span>,<\/span>\r\n  \"org.scalatest\"<\/span> %%<\/span> \"scalatest\"<\/span> %<\/span> \"3.0.5\"<\/span> %<\/span> Test<\/span>\r\n)<\/span>\r\n<\/code><\/pre>\n
\u684c\u5b50\u6a21\u578b<\/h1>\n
Phantom\u53ef\u4ee5\u4f7f\u7528O\/R\u6620\u5c04\uff08\u6216\u8005\u76f4\u63a5\u8c03\u7528CQL\u7684\u8bdd\u53ef\u80fd\u4f1a\u611f\u5230\u6709\u70b9\u9ebb\u70e6\uff09\u3002
\n\u867d\u7136\u53ef\u4ee5\u6309\u7167\u666e\u901a\u65b9\u5f0f\u5f00\u53d1\uff0c\u4f46\u65e2\u7136\u662fCassandra\uff0c\u5c31\u8003\u8651\u4f7f\u7528\u5206\u533a\uff08\u590d\u5408\u5206\u533a\u952e\uff09\u7684\u611f\u89c9\u6765\u5c1d\u8bd5\u4e00\u4e0b\u3002<\/p>\n
package<\/span> com.example<\/span>\r\n\r\nimport<\/span> java.util.UUID<\/span>\r\n\r\nimport<\/span> scala.concurrent.Future<\/span>\r\n\r\nimport<\/span> com.outworkers.phantom.Table<\/span>\r\nimport<\/span> com.outworkers.phantom.builder.query.InsertQuery<\/span>\r\nimport<\/span> com.outworkers.phantom.dsl._<\/span>\r\nimport<\/span> com.outworkers.phantom.keys.PartitionKey<\/span>\r\n\r\n\/\/ \u30c7\u30fc\u30bf<\/span>\r\n\/\/ \u3053\u3061\u3089\u306b\u306fPartition\u60c5\u5831\u3092\u542b\u3081\u306a\u3044<\/span>\r\nfinal<\/span> case<\/span> class<\/span> Message<\/span>(<\/span>id<\/span>:<\/span> UUID<\/span>,<\/span> message<\/span>:<\/span> String<\/span>,<\/span> timestamp<\/span>:<\/span> Long<\/span>)<\/span>\r\n\r\n\/\/ \u30c6\u30fc\u30d6\u30eb<\/span>\r\nabstract<\/span> class<\/span> Messages<\/span> extends<\/span> Table<\/span>[<\/span>Messages<\/span>, Message<\/span>]<\/span> {<\/span>\r\n\r\n  \/\/ category\u3068subcategory\u306b\u3088\u308bComposite Partition Key<\/span>\r\n  object<\/span> category<\/span> extends<\/span> StringColumn<\/span> with<\/span> PartitionKey<\/span>\r\n  object<\/span> subcategory<\/span> extends<\/span> StringColumn<\/span> with<\/span> PartitionKey<\/span>\r\n\r\n  object<\/span> id<\/span> extends<\/span> UUIDColumn<\/span> with<\/span> PrimaryKey<\/span>\r\n  object<\/span> message<\/span> extends<\/span> StringColumn<\/span>\r\n  object<\/span> timestamp<\/span> extends<\/span> LongColumn<\/span>\r\n\r\n  \/\/ Partition\u3092\u6307\u5b9a\u3057\u3066\u4fdd\u5b58<\/span>\r\n  def<\/span> store<\/span>(<\/span>partition<\/span>:<\/span> (<\/span>String<\/span>,<\/span> String<\/span>),<\/span> msg<\/span>:<\/span> Message<\/span>)<\/span>:<\/span> InsertQuery.Default<\/span>[<\/span>Messages<\/span>, Message<\/span>]<\/span> =<\/span>\r\n    insert<\/span>\r\n      .<\/span>value<\/span>(<\/span>_<\/span>.<\/span>category<\/span>,<\/span> partition<\/span>.<\/span>_1<\/span>)<\/span>\r\n      .<\/span>value<\/span>(<\/span>_<\/span>.<\/span>subcategory<\/span>,<\/span> partition<\/span>.<\/span>_2<\/span>)<\/span>\r\n      .<\/span>value<\/span>(<\/span>_<\/span>.<\/span>id<\/span>,<\/span> msg<\/span>.<\/span>id<\/span>)<\/span>\r\n      .<\/span>value<\/span>(<\/span>_<\/span>.<\/span>message<\/span>,<\/span> msg<\/span>.<\/span>message<\/span>)<\/span>\r\n      .<\/span>value<\/span>(<\/span>_<\/span>.<\/span>timestamp<\/span>,<\/span> msg<\/span>.<\/span>timestamp<\/span>)<\/span>\r\n\r\n  \/\/ Partition\u3092\u691c\u7d22<\/span>\r\n  def<\/span> findByPartition<\/span>(<\/span>partition<\/span>:<\/span> (<\/span>String<\/span>,<\/span> String<\/span>))<\/span>:<\/span> Future<\/span>[<\/span>List<\/span>[<\/span>Message<\/span>]]<\/span> =<\/span>\r\n    select<\/span>.<\/span>where<\/span>(<\/span>_<\/span>.<\/span>category<\/span> eqs<\/span> partition<\/span>.<\/span>_1<\/span>).<\/span>and<\/span>(<\/span>_<\/span>.<\/span>subcategory<\/span> eqs<\/span> partition<\/span>.<\/span>_2<\/span>).<\/span>fetch<\/span>()<\/span>\r\n\r\n  \/\/ Partition+ID\u3067\u691c\u7d22<\/span>\r\n  def<\/span> findById<\/span>(<\/span>partition<\/span>:<\/span> (<\/span>String<\/span>,<\/span> String<\/span>),<\/span> id<\/span>:<\/span> UUID<\/span>)<\/span>:<\/span> Future<\/span>[<\/span>Option<\/span>[<\/span>Message<\/span>]]<\/span> =<\/span>\r\n    select<\/span>\r\n      .<\/span>where<\/span>(<\/span>_<\/span>.<\/span>category<\/span> eqs<\/span> partition<\/span>.<\/span>_1<\/span>)<\/span>\r\n      .<\/span>and<\/span>(<\/span>_<\/span>.<\/span>subcategory<\/span> eqs<\/span> partition<\/span>.<\/span>_2<\/span>)<\/span>\r\n      .<\/span>and<\/span>(<\/span>_<\/span>.<\/span>id<\/span> eqs<\/span> id<\/span>)<\/span>\r\n      .<\/span>one<\/span>()<\/span>\r\n\r\n}<\/span>\r\n<\/code><\/pre>\n
\u6570\u636e\u5e93<\/h1>\n
\u6211\u4eec\u6b63\u5728\u52aa\u529b\u4f5c\u4e3a\u63d0\u4f9b\u6570\u636e\u5e93\u670d\u52a1\u7684\u4f9b\u5e94\u5546\uff0c\u4ee5\u4fbf\u53ef\u4ee5\u5728\u67d0\u79cd\u7a0b\u5ea6\u4e0a\u8fdb\u884c\u6a21\u62df\u548c\u5176\u4ed6\u64cd\u4f5c\uff08\u4f9b\u53c2\u8003\uff09\u3002<\/p>\n
package<\/span> com.example<\/span>\r\n\r\nimport<\/span> com.outworkers.phantom.connectors.ContactPoint<\/span>\r\nimport<\/span> com.outworkers.phantom.database.<\/span>{<\/span>Database<\/span>,<\/span> DatabaseProvider<\/span>}<\/span>\r\nimport<\/span> com.outworkers.phantom.dsl.<\/span>{<\/span>CassandraConnection<\/span>,<\/span> KeySpace<\/span>,<\/span> replication<\/span>,<\/span> _<\/span>}<\/span>\r\nimport<\/span> com.typesafe.config.ConfigFactory<\/span>\r\n\r\n\/\/ \u30b3\u30cd\u30af\u30bf(Singleton)<\/span>\r\nobject<\/span> Connector<\/span> {<\/span>\r\n\r\n  private<\/span> val<\/span> config<\/span> =<\/span> ConfigFactory<\/span>.<\/span>load<\/span>()<\/span>\r\n\r\n  config<\/span>.<\/span>checkValid<\/span>(<\/span>ConfigFactory<\/span>.<\/span>defaultReference<\/span>(),<\/span> \"cassandra\"<\/span>)<\/span>\r\n\r\n  val<\/span> connection<\/span>:<\/span> CassandraConnection<\/span> =<\/span>\r\n    ContactPoint<\/span>(<\/span>config<\/span>.<\/span>getString<\/span>(<\/span>\"cassandra.host\"<\/span>),<\/span> config<\/span>.<\/span>getInt<\/span>(<\/span>\"cassandra.port\"<\/span>))<\/span>\r\n      .<\/span>noHeartbeat<\/span>()<\/span>\r\n      .<\/span>noHeartbeat<\/span>()<\/span>\r\n      .<\/span>keySpace<\/span>(<\/span>\r\n        KeySpace<\/span>(<\/span>config<\/span>.<\/span>getString<\/span>(<\/span>\"cassandra.keyspace\"<\/span>))<\/span>\r\n          .<\/span>ifNotExists<\/span>()<\/span>\r\n          .<\/span>`with`<\/span>(<\/span>\r\n            replication<\/span> eqs<\/span> SimpleStrategy<\/span>.<\/span>replication_factor<\/span>(<\/span>1<\/span>)<\/span>\r\n          )<\/span>\r\n      )<\/span>\r\n}<\/span>\r\n\r\n\/\/ \u30c7\u30fc\u30bf\u30d9\u30fc\u30b9\u5b9a\u7fa9<\/span>\r\nclass<\/span> AppDatabase<\/span>(<\/span>override<\/span> val<\/span> connector<\/span>:<\/span> CassandraConnection<\/span>)<\/span>\r\n    extends<\/span> Database<\/span>[<\/span>AppDatabase<\/span>](<\/span>connector<\/span>)<\/span> {<\/span>\r\n  object<\/span> messages<\/span> extends<\/span> Messages<\/span> with<\/span> Connector<\/span>\r\n}<\/span>\r\n\r\n\/\/ \u30d7\u30ed\u30d0\u30a4\u30c0\u3068\u3057\u3066\u63d0\u4f9b<\/span>\r\ntrait<\/span> AppDatabaseProvider<\/span> extends<\/span> DatabaseProvider<\/span>[<\/span>AppDatabase<\/span>]<\/span>\r\n<\/code><\/pre>\n
\u63d0\u4f9b\u7684\u670d\u52a1<\/h1>\n
\u6211\u53ea\u662f\u6682\u65f6\u628a\u670d\u52a1\u5f00\u901a\u4e86\u4e00\u4e0b\u3002\u56e0\u4e3a\u80fd\u591f\u8fdb\u884c\u6279\u5904\u7406\uff0c\u6240\u4ee5\u6211\u5c1d\u8bd5\u52a0\u4e0a\u4e86\u3002
\n\u6211\u8bb0\u5f97Cassandra\u7684\u6279\u5904\u7406\u6709\u4e00\u4e2a\u9650\u5236\u6570\u91cf\uff0c\u4f46\u662f\u4e0d\u77e5\u9053\u5728\u54ea\u91cc\u8fdb\u884c\u8bbe\u7f6e…\u3002<\/p>\n
package<\/span> com.example<\/span>\r\n\r\nimport<\/span> scala.concurrent.Future<\/span>\r\n\r\nimport<\/span> com.outworkers.phantom.ResultSet<\/span>\r\nimport<\/span> com.outworkers.phantom.dsl._<\/span>\r\n\r\ntrait<\/span> MessageService<\/span> extends<\/span> AppDatabaseProvider<\/span> {<\/span>\r\n\r\n  def<\/span> store<\/span>(<\/span>partition<\/span>:<\/span> (<\/span>String<\/span>,<\/span> String<\/span>),<\/span> msg<\/span>:<\/span> Message<\/span>)<\/span>:<\/span> Future<\/span>[<\/span>ResultSet<\/span>]<\/span> =<\/span>\r\n    db<\/span>.<\/span>messages<\/span>.<\/span>store<\/span>(<\/span>partition<\/span>,<\/span> msg<\/span>).<\/span>future<\/span>()<\/span>\r\n\r\n  def<\/span> findPartition<\/span>(<\/span>partition<\/span>:<\/span> (<\/span>String<\/span>,<\/span> String<\/span>))<\/span>:<\/span> Future<\/span>[<\/span>List<\/span>[<\/span>Message<\/span>]]<\/span> =<\/span>\r\n    db<\/span>.<\/span>messages<\/span>.<\/span>findByPartition<\/span>(<\/span>partition<\/span>)<\/span>\r\n\r\n  def<\/span> findById<\/span>(<\/span>partition<\/span>:<\/span> (<\/span>String<\/span>,<\/span> String<\/span>),<\/span> id<\/span>:<\/span> UUID<\/span>)<\/span>:<\/span> Future<\/span>[<\/span>Option<\/span>[<\/span>Message<\/span>]]<\/span> =<\/span>\r\n    db<\/span>.<\/span>messages<\/span>.<\/span>findById<\/span>(<\/span>partition<\/span>,<\/span> id<\/span>)<\/span>\r\n\r\n  def<\/span> batchStore<\/span>(<\/span>partition<\/span>:<\/span> (<\/span>String<\/span>,<\/span> String<\/span>),<\/span> messages<\/span>:<\/span> Message*<\/span>)<\/span>:<\/span> Future<\/span>[<\/span>ResultSet<\/span>]<\/span> =<\/span>\r\n    Batch<\/span>.<\/span>logged<\/span>.<\/span>add<\/span>(<\/span>messages<\/span>.<\/span>map<\/span>(<\/span>msg<\/span> =><\/span> db<\/span>.<\/span>messages<\/span>.<\/span>store<\/span>(<\/span>partition<\/span>,<\/span> msg<\/span>))).<\/span>future<\/span>()<\/span>\r\n\r\n}<\/span>\r\n<\/code><\/pre>\n
\u8003\u8bd5<\/h1>\n
\u6211\u5c06\u6d4b\u8bd5\u4e0a\u8ff0\u670d\u52a1\u3002\u6211\u5b9a\u4e49\u4e86\u4e00\u4e2a\u8fde\u63a5\u5668\u7528\u4e8e\u6d4b\u8bd5\uff0c\u5e76\u5c06\u5176\u4f20\u9012\u7ed9\u670d\u52a1\u3002
\n\u770b\u8d77\u6765phantom\u53ef\u4ee5\u6839\u636e\u6307\u5b9a\u7684\u6a21\u578b\u521b\u5efa\u8868\u683c\uff08messageService.database.create()\uff09\u3002
\n\u7531\u4e8eScalaFutures\u7684patienceConfig\u7684\u9ed8\u8ba4\u8bbe\u7f6e\u53ef\u80fd\u4f1a\u8d85\u65f6\uff0c\u56e0\u6b64\u6211\u4eec\u6b63\u5728\u8986\u76d6\u5e76\u5ef6\u957f\u5b83\u3002<\/p>\n
package<\/span> com.example<\/span>\r\n\r\nimport<\/span> java.time.<\/span>{<\/span>LocalDateTime<\/span>,<\/span> ZoneId<\/span>}<\/span>\r\nimport<\/span> java.util.UUID<\/span>\r\n\r\nimport<\/span> scala.language.reflectiveCalls<\/span>\r\n\r\nimport<\/span> com.datastax.driver.core.SocketOptions<\/span>\r\nimport<\/span> com.outworkers.phantom.connectors.<\/span>{<\/span>CassandraConnection<\/span>,<\/span> ContactPoint<\/span>}<\/span>\r\nimport<\/span> com.outworkers.phantom.dsl._<\/span>\r\nimport<\/span> com.typesafe.config.<\/span>{<\/span>Config<\/span>,<\/span> ConfigFactory<\/span>}<\/span>\r\nimport<\/span> org.scalatest.concurrent.ScalaFutures<\/span>\r\nimport<\/span> org.scalatest.time.<\/span>{<\/span>Millis<\/span>,<\/span> Seconds<\/span>,<\/span> Span<\/span>}<\/span>\r\nimport<\/span> org.scalatest.<\/span>{<\/span>BeforeAndAfterAll<\/span>,<\/span> Matchers<\/span>,<\/span> OptionValues<\/span>,<\/span> WordSpecLike<\/span>}<\/span>\r\n\r\nclass<\/span> MessageServiceSpec<\/span>\r\n    extends<\/span> WordSpecLike<\/span>\r\n    with<\/span> Matchers<\/span>\r\n    with<\/span> BeforeAndAfterAll<\/span>\r\n    with<\/span> ScalaFutures<\/span>\r\n    with<\/span> OptionValues<\/span> {<\/span>\r\n\r\n  \/\/ \u30c7\u30d5\u30a9\u30eb\u30c8\u3060\u3068\u30bf\u30a4\u30e0\u30a2\u30a6\u30c8\u3059\u308b\u53ef\u80fd\u6027\u3042\u308a<\/span>\r\n  override<\/span> implicit<\/span> val<\/span> patienceConfig<\/span>:<\/span> PatienceConfig<\/span> =<\/span>\r\n    PatienceConfig<\/span>(<\/span>timeout<\/span> =<\/span> Span<\/span>(<\/span>5<\/span>,<\/span> Seconds<\/span>),<\/span> interval<\/span> =<\/span> Span<\/span>(<\/span>200<\/span>,<\/span> Millis<\/span>))<\/span>\r\n\r\n  object<\/span> TestConnector<\/span> {<\/span>\r\n    private<\/span> val<\/span> config<\/span>:<\/span> Config<\/span> =<\/span> ConfigFactory<\/span>.<\/span>parseString<\/span>(<\/span>\"\"\"cassandra {\r\n        |  host: \"x.x.x.x\" \/\/ IP\u6307\u5b9a\r\n        |  port: 9042\r\n        |  keyspace: \"scala_cassandra_example\"\r\n        |}\r\n      \"\"\"<\/span>.<\/span>stripMargin<\/span>)<\/span>\r\n\r\n    val<\/span> connection<\/span>:<\/span> CassandraConnection<\/span> =<\/span>\r\n      ContactPoint<\/span>(<\/span>config<\/span>.<\/span>getString<\/span>(<\/span>\"cassandra.host\"<\/span>),<\/span> config<\/span>.<\/span>getInt<\/span>(<\/span>\"cassandra.port\"<\/span>))<\/span>\r\n        .<\/span>withClusterBuilder<\/span>(<\/span>\r\n          _<\/span>.<\/span>withSocketOptions<\/span>(<\/span>\r\n            new<\/span> SocketOptions<\/span>()<\/span>\r\n              .<\/span>setConnectTimeoutMillis<\/span>(<\/span>20000<\/span>)<\/span>\r\n              .<\/span>setReadTimeoutMillis<\/span>(<\/span>20000<\/span>)<\/span>\r\n          ))<\/span>\r\n        .<\/span>noHeartbeat<\/span>()<\/span>\r\n        .<\/span>keySpace<\/span>(<\/span>\r\n          KeySpace<\/span>(<\/span>config<\/span>.<\/span>getString<\/span>(<\/span>\"cassandra.keyspace\"<\/span>))<\/span>\r\n            .<\/span>ifNotExists<\/span>()<\/span>\r\n            .<\/span>`with`<\/span>(<\/span>\r\n              replication<\/span> eqs<\/span> SimpleStrategy<\/span>.<\/span>replication_factor<\/span>(<\/span>1<\/span>)<\/span>\r\n            )<\/span>\r\n        )<\/span>\r\n  }<\/span>\r\n\r\n  object<\/span> TestDatabase<\/span> extends<\/span> AppDatabase<\/span>(<\/span>TestConnector<\/span>.<\/span>connection<\/span>)<\/span>\r\n\r\n  trait<\/span> TestDatabaseProvider<\/span> extends<\/span> AppDatabaseProvider<\/span> {<\/span>\r\n    override<\/span> def<\/span> database<\/span>:<\/span> AppDatabase<\/span> =<\/span> TestDatabase<\/span>\r\n  }<\/span>\r\n\r\n  val<\/span> messageService<\/span> =<\/span> new<\/span> MessageService<\/span> with<\/span> TestDatabaseProvider<\/span>\r\n\r\n  override<\/span> def<\/span> beforeAll<\/span>()<\/span>:<\/span> Unit<\/span> =<\/span> {<\/span>\r\n    messageService<\/span>.<\/span>database<\/span>.<\/span>create<\/span>()<\/span>\r\n    ()<\/span>\r\n  }<\/span>\r\n\r\n  override<\/span> def<\/span> afterAll<\/span>()<\/span>:<\/span> Unit<\/span> =<\/span> {<\/span>\r\n    messageService<\/span>.<\/span>database<\/span>.<\/span>drop<\/span>()<\/span>\r\n    ()<\/span>\r\n  }<\/span>\r\n\r\n  \"message service\"<\/span> should<\/span> {<\/span>\r\n\r\n    \"store and find by id\"<\/span> in<\/span> {<\/span>\r\n      val<\/span> partition<\/span>:<\/span> (<\/span>String<\/span>,<\/span> String<\/span>)<\/span> =<\/span> (<\/span>\"A\"<\/span>,<\/span> \"1\"<\/span>)<\/span>\r\n      val<\/span> message<\/span> =<\/span> Message<\/span>(<\/span>UUID<\/span>.<\/span>randomUUID<\/span>(),<\/span>\r\n                            \"Test\"<\/span>,<\/span>\r\n                            LocalDateTime<\/span>.<\/span>now<\/span>().<\/span>atZone<\/span>(<\/span>ZoneId<\/span>.<\/span>systemDefault<\/span>()).<\/span>toEpochSecond<\/span>)<\/span>\r\n      val<\/span> q<\/span> =<\/span> for<\/span> {<\/span>\r\n        _<\/span> <-<\/span> messageService<\/span>.<\/span>store<\/span>(<\/span>partition<\/span>,<\/span> message<\/span>)<\/span>\r\n        find<\/span> <-<\/span> messageService<\/span>.<\/span>findById<\/span>(<\/span>partition<\/span>,<\/span> message<\/span>.<\/span>id<\/span>)<\/span>\r\n      }<\/span> yield<\/span> find<\/span>\r\n\r\n      whenReady<\/span>(<\/span>q<\/span>)<\/span> {<\/span> find<\/span> =><\/span>\r\n        find<\/span> shouldBe<\/span> defined<\/span>\r\n        find<\/span>.<\/span>value<\/span> shouldBe<\/span> message<\/span>\r\n      }<\/span>\r\n    }<\/span>\r\n\r\n    \"batch store and find by partition\"<\/span> in<\/span> {<\/span>\r\n      val<\/span> partition<\/span>:<\/span> (<\/span>String<\/span>,<\/span> String<\/span>)<\/span> =<\/span> (<\/span>\"B\"<\/span>,<\/span> \"1\"<\/span>)<\/span>\r\n      val<\/span> messages<\/span> =<\/span> Seq<\/span>\r\n        .<\/span>range<\/span>(<\/span>0<\/span>,<\/span> 1000<\/span>)<\/span>\r\n        .<\/span>map<\/span>(<\/span>\r\n          i<\/span> =><\/span>\r\n            Message<\/span>(<\/span>UUID<\/span>.<\/span>randomUUID<\/span>(),<\/span>\r\n                    \"Test\"<\/span> +<\/span> i<\/span>,<\/span>\r\n                    LocalDateTime<\/span>.<\/span>now<\/span>().<\/span>atZone<\/span>(<\/span>ZoneId<\/span>.<\/span>systemDefault<\/span>()).<\/span>toEpochSecond<\/span>))<\/span>\r\n\r\n      val<\/span> q<\/span> =<\/span> for<\/span> {<\/span>\r\n        _<\/span> <-<\/span> messageService<\/span>.<\/span>batchStore<\/span>(<\/span>partition<\/span>,<\/span> messages<\/span>:<\/span> _<\/span>*<\/span>)<\/span>\r\n        res<\/span> <-<\/span> messageService<\/span>.<\/span>findPartition<\/span>(<\/span>partition<\/span>)<\/span>\r\n      }<\/span> yield<\/span> res<\/span>\r\n\r\n      whenReady<\/span>(<\/span>q<\/span>)<\/span> {<\/span> res<\/span> =><\/span>\r\n        res<\/span>.<\/span>size<\/span> shouldBe<\/span> 1000<\/span>\r\n      }<\/span>\r\n    }<\/span>\r\n  }<\/span>\r\n}<\/span>\r\n<\/code><\/pre>\n
It can be paraphrased as:
\n\u6700\u540e<\/h1>\n
\u5e7b\u5f71\u81ea\u8eab\u53ef\u80fd\u662f\u9ad8\u529f\u80fd\u7684\uff0c\u53ef\u4ee5\u505a\u5f88\u591a\u4e8b\u60c5\uff0c\u4f46\u7531\u4e8e\u6587\u4ef6\u5f88\u96be\u8bfb\u61c2\uff08\u800c\u4e14\u53ef\u80fd\u8fd8\u6ca1\u6709\u5b8c\u6210\uff09\uff0c\u6240\u4ee5\u5c31\u5728\u8fd9\u4e2a\u5730\u65b9\u59a5\u534f\u4e86\u3002<\/p>\n","protected":false},"excerpt":{"rendered":"
\u4e00\u958b\u59cb \u56e0\u4e3a\u6211\u4ee5\u524d\u4ece\u672a\u4f7f\u7528\u8fc7Scala\u64cd\u4f5cCassandra\uff0c\u6240\u4ee5\u6211\u51b3\u5b9a\u5c1d\u8bd5\u4e00\u4e0b\u3002 \u8d77\u521d\u6211\u4e5f\u8003\u8651\u4f7f\u7528Java\u7684 […]<\/p>\n","protected":false},"author":3,"featured_media":0,"comment_status":"closed","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[1],"tags":[],"class_list":["post-50152","post","type-post","status-publish","format-standard","hentry","category-uncategorized"],"yoast_head":"\n\u7528Scala\uff08\u5e7b\u5f71\uff09\u6765\u64cd\u4f5cCassandra - Blog - Silicon Cloud<\/title>\n<meta name=\"robots\" content=\"index, follow, max-snippet:-1, max-image-preview:large, max-video-preview:-1\" \/>\n<link rel=\"canonical\" href=\"https:\/\/www.silicloud.com\/zh\/blog\/\u7528scala\uff08\u5e7b\u5f71\uff09\u6765\u64cd\u4f5ccassandra\/\" \/>\n<meta property=\"og:locale\" content=\"zh_CN\" \/>\n<meta property=\"og:type\" content=\"article\" \/>\n<meta property=\"og:title\" content=\"\u7528Scala\uff08\u5e7b\u5f71\uff09\u6765\u64cd\u4f5cCassandra\" \/>\n<meta property=\"og:description\" content=\"\u4e00\u958b\u59cb \u56e0\u4e3a\u6211\u4ee5\u524d\u4ece\u672a\u4f7f\u7528\u8fc7Scala\u64cd\u4f5cCassandra\uff0c\u6240\u4ee5\u6211\u51b3\u5b9a\u5c1d\u8bd5\u4e00\u4e0b\u3002 \u8d77\u521d\u6211\u4e5f\u8003\u8651\u4f7f\u7528Java\u7684 […]\" \/>\n<meta property=\"og:url\" content=\"https:\/\/www.silicloud.com\/zh\/blog\/\u7528scala\uff08\u5e7b\u5f71\uff09\u6765\u64cd\u4f5ccassandra\/\" \/>\n<meta property=\"og:site_name\" content=\"Blog - Silicon Cloud\" \/>\n<meta property=\"article:published_time\" content=\"2023-11-10T01:26:50+00:00\" \/>\n<meta property=\"article:modified_time\" content=\"2024-04-30T03:01:17+00:00\" \/>\n<meta name=\"author\" content=\"\u97f5, \u79d1\" \/>\n<meta name=\"twitter:card\" content=\"summary_large_image\" \/>\n<meta name=\"twitter:label1\" content=\"\u4f5c\u8005\" \/>\n\t<meta name=\"twitter:data1\" content=\"\u97f5, \u79d1\" \/>\n\t<meta name=\"twitter:label2\" content=\"\u9884\u8ba1\u9605\u8bfb\u65f6\u95f4\" \/>\n\t<meta name=\"twitter:data2\" content=\"3 \u5206\" \/>\n<script type=\"application\/ld+json\" class=\"yoast-schema-graph\">{\"@context\":\"https:\/\/schema.org\",\"@graph\":[{\"@type\":\"WebPage\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/%e7%94%a8scala%ef%bc%88%e5%b9%bb%e5%bd%b1%ef%bc%89%e6%9d%a5%e6%93%8d%e4%bd%9ccassandra\/\",\"url\":\"https:\/\/www.silicloud.com\/zh\/blog\/%e7%94%a8scala%ef%bc%88%e5%b9%bb%e5%bd%b1%ef%bc%89%e6%9d%a5%e6%93%8d%e4%bd%9ccassandra\/\",\"name\":\"\u7528Scala\uff08\u5e7b\u5f71\uff09\u6765\u64cd\u4f5cCassandra - Blog - Silicon Cloud\",\"isPartOf\":{\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/#website\"},\"datePublished\":\"2023-11-10T01:26:50+00:00\",\"dateModified\":\"2024-04-30T03:01:17+00:00\",\"author\":{\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/6530331a63adef3b3443a1fab53a0e6e\"},\"breadcrumb\":{\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/%e7%94%a8scala%ef%bc%88%e5%b9%bb%e5%bd%b1%ef%bc%89%e6%9d%a5%e6%93%8d%e4%bd%9ccassandra\/#breadcrumb\"},\"inLanguage\":\"zh-Hans\",\"potentialAction\":[{\"@type\":\"ReadAction\",\"target\":[\"https:\/\/www.silicloud.com\/zh\/blog\/%e7%94%a8scala%ef%bc%88%e5%b9%bb%e5%bd%b1%ef%bc%89%e6%9d%a5%e6%93%8d%e4%bd%9ccassandra\/\"]}]},{\"@type\":\"BreadcrumbList\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/%e7%94%a8scala%ef%bc%88%e5%b9%bb%e5%bd%b1%ef%bc%89%e6%9d%a5%e6%93%8d%e4%bd%9ccassandra\/#breadcrumb\",\"itemListElement\":[{\"@type\":\"ListItem\",\"position\":1,\"name\":\"\u9996\u9875\",\"item\":\"https:\/\/www.silicloud.com\/zh\/blog\/\"},{\"@type\":\"ListItem\",\"position\":2,\"name\":\"\u7528Scala\uff08\u5e7b\u5f71\uff09\u6765\u64cd\u4f5cCassandra\"}]},{\"@type\":\"WebSite\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/#website\",\"url\":\"https:\/\/www.silicloud.com\/zh\/blog\/\",\"name\":\"Blog - Silicon Cloud\",\"description\":\"\",\"inLanguage\":\"zh-Hans\"},{\"@type\":\"Person\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/6530331a63adef3b3443a1fab53a0e6e\",\"name\":\"\u97f5, \u79d1\",\"image\":{\"@type\":\"ImageObject\",\"inLanguage\":\"zh-Hans\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/image\/\",\"url\":\"https:\/\/secure.gravatar.com\/avatar\/429ccb39b3fff5188bc17986222cfb0936cbadb8cc933cff04ab5ca01bd30a08?s=96&d=mm&r=g\",\"contentUrl\":\"https:\/\/secure.gravatar.com\/avatar\/429ccb39b3fff5188bc17986222cfb0936cbadb8cc933cff04ab5ca01bd30a08?s=96&d=mm&r=g\",\"caption\":\"\u97f5, \u79d1\"},\"url\":\"https:\/\/www.silicloud.com\/zh\/blog\/author\/yunke\/\"},{\"@type\":\"ImageObject\",\"inLanguage\":\"zh-Hans\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/%e7%94%a8scala%ef%bc%88%e5%b9%bb%e5%bd%b1%ef%bc%89%e6%9d%a5%e6%93%8d%e4%bd%9ccassandra\/#local-main-organization-logo\",\"url\":\"\",\"contentUrl\":\"\",\"caption\":\"Blog - Silicon Cloud\"}]}<\/script>\n<!-- \/ Yoast SEO Premium plugin. -->","yoast_head_json":{"title":"\u7528Scala\uff08\u5e7b\u5f71\uff09\u6765\u64cd\u4f5cCassandra - Blog - Silicon Cloud","robots":{"index":"index","follow":"follow","max-snippet":"max-snippet:-1","max-image-preview":"max-image-preview:large","max-video-preview":"max-video-preview:-1"},"canonical":"https:\/\/www.silicloud.com\/zh\/blog\/\u7528scala\uff08\u5e7b\u5f71\uff09\u6765\u64cd\u4f5ccassandra\/","og_locale":"zh_CN","og_type":"article","og_title":"\u7528Scala\uff08\u5e7b\u5f71\uff09\u6765\u64cd\u4f5cCassandra","og_description":"\u4e00\u958b\u59cb \u56e0\u4e3a\u6211\u4ee5\u524d\u4ece\u672a\u4f7f\u7528\u8fc7Scala\u64cd\u4f5cCassandra\uff0c\u6240\u4ee5\u6211\u51b3\u5b9a\u5c1d\u8bd5\u4e00\u4e0b\u3002 \u8d77\u521d\u6211\u4e5f\u8003\u8651\u4f7f\u7528Java\u7684 […]","og_url":"https:\/\/www.silicloud.com\/zh\/blog\/\u7528scala\uff08\u5e7b\u5f71\uff09\u6765\u64cd\u4f5ccassandra\/","og_site_name":"Blog - Silicon Cloud","article_published_time":"2023-11-10T01:26:50+00:00","article_modified_time":"2024-04-30T03:01:17+00:00","author":"\u97f5, \u79d1","twitter_card":"summary_large_image","twitter_misc":{"\u4f5c\u8005":"\u97f5, \u79d1","\u9884\u8ba1\u9605\u8bfb\u65f6\u95f4":"3 \u5206"},"schema":{"@context":"https:\/\/schema.org","@graph":[{"@type":"WebPage","@id":"https:\/\/www.silicloud.com\/zh\/blog\/%e7%94%a8scala%ef%bc%88%e5%b9%bb%e5%bd%b1%ef%bc%89%e6%9d%a5%e6%93%8d%e4%bd%9ccassandra\/","url":"https:\/\/www.silicloud.com\/zh\/blog\/%e7%94%a8scala%ef%bc%88%e5%b9%bb%e5%bd%b1%ef%bc%89%e6%9d%a5%e6%93%8d%e4%bd%9ccassandra\/","name":"\u7528Scala\uff08\u5e7b\u5f71\uff09\u6765\u64cd\u4f5cCassandra - Blog - Silicon Cloud","isPartOf":{"@id":"https:\/\/www.silicloud.com\/zh\/blog\/#website"},"datePublished":"2023-11-10T01:26:50+00:00","dateModified":"2024-04-30T03:01:17+00:00","author":{"@id":"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/6530331a63adef3b3443a1fab53a0e6e"},"breadcrumb":{"@id":"https:\/\/www.silicloud.com\/zh\/blog\/%e7%94%a8scala%ef%bc%88%e5%b9%bb%e5%bd%b1%ef%bc%89%e6%9d%a5%e6%93%8d%e4%bd%9ccassandra\/#breadcrumb"},"inLanguage":"zh-Hans","potentialAction":[{"@type":"ReadAction","target":["https:\/\/www.silicloud.com\/zh\/blog\/%e7%94%a8scala%ef%bc%88%e5%b9%bb%e5%bd%b1%ef%bc%89%e6%9d%a5%e6%93%8d%e4%bd%9ccassandra\/"]}]},{"@type":"BreadcrumbList","@id":"https:\/\/www.silicloud.com\/zh\/blog\/%e7%94%a8scala%ef%bc%88%e5%b9%bb%e5%bd%b1%ef%bc%89%e6%9d%a5%e6%93%8d%e4%bd%9ccassandra\/#breadcrumb","itemListElement":[{"@type":"ListItem","position":1,"name":"\u9996\u9875","item":"https:\/\/www.silicloud.com\/zh\/blog\/"},{"@type":"ListItem","position":2,"name":"\u7528Scala\uff08\u5e7b\u5f71\uff09\u6765\u64cd\u4f5cCassandra"}]},{"@type":"WebSite","@id":"https:\/\/www.silicloud.com\/zh\/blog\/#website","url":"https:\/\/www.silicloud.com\/zh\/blog\/","name":"Blog - Silicon Cloud","description":"","inLanguage":"zh-Hans"},{"@type":"Person","@id":"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/6530331a63adef3b3443a1fab53a0e6e","name":"\u97f5, \u79d1","image":{"@type":"ImageObject","inLanguage":"zh-Hans","@id":"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/image\/","url":"https:\/\/secure.gravatar.com\/avatar\/429ccb39b3fff5188bc17986222cfb0936cbadb8cc933cff04ab5ca01bd30a08?s=96&d=mm&r=g","contentUrl":"https:\/\/secure.gravatar.com\/avatar\/429ccb39b3fff5188bc17986222cfb0936cbadb8cc933cff04ab5ca01bd30a08?s=96&d=mm&r=g","caption":"\u97f5, \u79d1"},"url":"https:\/\/www.silicloud.com\/zh\/blog\/author\/yunke\/"},{"@type":"ImageObject","inLanguage":"zh-Hans","@id":"https:\/\/www.silicloud.com\/zh\/blog\/%e7%94%a8scala%ef%bc%88%e5%b9%bb%e5%bd%b1%ef%bc%89%e6%9d%a5%e6%93%8d%e4%bd%9ccassandra\/#local-main-organization-logo","url":"","contentUrl":"","caption":"Blog - Silicon Cloud"}]}},"_links":{"self":[{"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/posts\/50152","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/users\/3"}],"replies":[{"embeddable":true,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/comments?post=50152"}],"version-history":[{"count":2,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/posts\/50152\/revisions"}],"predecessor-version":[{"id":91510,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/posts\/50152\/revisions\/91510"}],"wp:attachment":[{"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/media?parent=50152"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/categories?post=50152"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/tags?post=50152"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}