下影片的好网站,再也不用担心下不到好影片了

 
我们说过Akka-http是一个好的体系融为一体工具,集成是通过数据沟通形式实现的。Http是个在网上传输和收取的标准协商。所以,在利用Akka-http从前,可能大家依然需要把Http格局的网上数据互换细节了然通晓。数据交流双方是经过Http信息类型Request和Response来实现的。在Akka-http中对应的是HttpRequest和HttpResponse。这四个档次都装有HttpEntity类型来装载需要交流的数据。首先,无论咋样数据在线上的表现情势肯定是一串bytes。所以,数据交换两头Request,Response中的Entity也亟须是以bytes来表明的。在Akka-http里大家把需要传输的数额转换成ByteString,通过网络发送給接收端、接收端再把接收音讯Entity中的ByteString转换成目标项目标多寡。那五个转移过程就是Akka-http的马尔斯(Mars)halling和Unmarshalling过程了。我们先从HttpEntity的构建函数来打听它的定义:

没有牛逼的资源帝,只有费劲的搬运工

object HttpEntity {
  implicit def apply(string: String): HttpEntity.Strict = apply(ContentTypes.`text/plain(UTF-8)`, string)
  implicit def apply(bytes: Array[Byte]): HttpEntity.Strict = apply(ContentTypes.`application/octet-stream`, bytes)
  implicit def apply(data: ByteString): HttpEntity.Strict = apply(ContentTypes.`application/octet-stream`, data)
  def apply(contentType: ContentType.NonBinary, string: String): HttpEntity.Strict =
    if (string.isEmpty) empty(contentType) else apply(contentType, ByteString(string.getBytes(contentType.charset.nioCharset)))
  def apply(contentType: ContentType, bytes: Array[Byte]): HttpEntity.Strict =
    if (bytes.length == 0) empty(contentType) else apply(contentType, ByteString(bytes))
  def apply(contentType: ContentType, data: ByteString): HttpEntity.Strict =
    if (data.isEmpty) empty(contentType) else HttpEntity.Strict(contentType, data)

  def apply(contentType: ContentType, contentLength: Long, data: Source[ByteString, Any]): UniversalEntity =
    if (contentLength == 0) empty(contentType) else HttpEntity.Default(contentType, contentLength, data)
  def apply(contentType: ContentType, data: Source[ByteString, Any]): HttpEntity.Chunked =
    HttpEntity.Chunked.fromData(contentType, data)
...

先是要表明一点,独立鱼电影不会推荐PT站或者其他急需邀请注册的网站,本文提到的必定都是无需注册或者开放注册的、简单实用的网站。

很明朗,HttpEntity可以分两大类,一种是Strict类型的,它的data是ByteString。另一种是UniversalEntity类型,它的数额dataBytes是Source[ByteString,Any]。无论怎么样最后在线上的仍然ByteString。HttpEntity的ContentType阐明了传输数据格式,有:

一经您不是那么热爱电影,只是闲暇之余看看热门的新片/美剧,不求画质与进度的话,那么下边这些网站已经能满意你了:

object ContentTypes {
  val `application/json` = ContentType(MediaTypes.`application/json`)
  val `application/octet-stream` = ContentType(MediaTypes.`application/octet-stream`)
  val `text/plain(UTF-8)` = MediaTypes.`text/plain` withCharset HttpCharsets.`UTF-8`
  val `text/html(UTF-8)` = MediaTypes.`text/html` withCharset HttpCharsets.`UTF-8`
  val `text/xml(UTF-8)` = MediaTypes.`text/xml` withCharset HttpCharsets.`UTF-8`
  val `text/csv(UTF-8)` = MediaTypes.`text/csv` withCharset HttpCharsets.`UTF-8`

  // used for explicitly suppressing the rendering of Content-Type headers on requests and responses
  val NoContentType = ContentType(MediaTypes.NoMediaType)
}

入门级

专注:ContentType只是一种备注,不影响线上数据表明形式,线上的多少永远是ByteString。可是,其中的application/octet-stream类型代表数量必须是Source[ByteString,Any]。我们下边就由此客户端的事例来了然HttpEntity。上边是一个客户端测试函数:

影视天堂:http://www.xiaopian.com/

  def runService(request: HttpRequest, rentity: RequestEntity) = {
   val futResp = for {
     entity <- Future.successful(rentity)
     resp <- Http(sys).singleRequest(
       request.copy(entity = rentity)
     )
   } yield resp

   futResp
    .andThen {
      case Success(r@HttpResponse(StatusCodes.OK, _, entity, _)) =>
        entity.dataBytes.map(_.utf8String).runForeach(println)
      case Success(r@HttpResponse(code, _, _, _)) =>
        println(s"Download request failed, response code: $code")
        r.discardEntityBytes()
      case Success(_) => println("Unable to download rows!")
      case Failure(err) => println(s"Download failed: ${err.getMessage}")

    }
  }

飘花电影:http://www.piaohua.com/

俺们只需要对这多少个函数传入RequestEntity就足以了然重临Response里Entity的洋洋细节了。首先我们要求服务端发送一个纯字符串Hello
World。服务端代码如下:

6V电影:http://www.6vdy.com/

 } ~ path("text") {
      get {
        complete("Hello World!")
      } ~

圣城家中:http://www.cnscg.org/

虽然complete(“Hello
World!”)有些迷糊,然而相应complete做了些字符串到ByteString的转移。我们可以从下边这些runService(Service)函数拿到印证。上边是以此例子的调用:

电影FM:http://dianying.fm/category/

  val reqText = HttpRequest(uri = s"http://localhost:8011/text")
  runService(reqText,HttpEntity.Empty)
    .andThen{case _ => sys.terminate()}

人人影视(需注册):http://www.yyets.com/(近年来中国站早就关门,但生产了海外站。最强大的除了韩剧资源,HR-HD电视格式的片源也是人人影视的一大特点,体积小,一般是2G左右,但是画质不错,甚至在电视上广播也不会让你失望)

从呈现的结果可以得出run瑟维斯(Service)(Service)函数中的entity.dataBytes.map(_.utf8String)已经把ByteString转换成了String,也就是说服务器端发送的Entity里的数码是ByteString。

这个简易好用,可是过多新片都有再次的,基本上控制一六个就充裕了。

大家再试着发送一些数量給服务端,然后让服务端把结果通过response
entity重回来:

假设您有以下任一需求:1、爱看经典老电影,2、爱看高清画质的视频,3、想趁早得到新片资源。最好学会用那么些网站:

    } ~ path("text") {
      get {
        complete("Hello World!")
      } ~
        post {
          withoutSizeLimit {
            extractDataBytes { bytes =>
              val data = bytes.runFold(ByteString())(_ ++ _)
              onComplete(data) { t =>
                complete(t)
              }
            }
          }
        }

爱好级

咱俩看到服务端对request
entity的操作是以ByteString举办的。客户端上传一串字符的request如下:

ED2000:http://www.ed2000.com/(网站提供的都是电驴链接,电影资源很有力,游戏/音乐/软件什么乱七八糟的都有)

  val postText = HttpRequest(HttpMethods.POST,uri = s"http://localhost:8011/text")
  val uploadText = HttpEntity(
    ContentTypes.`text/plain(UTF-8)`,
    // transform each number to a chunk of bytes
    ByteString("hello world again")
  )
  runService(postText,uploadText)
    .andThen{case _ => sys.terminate()}

SimpleCD:http://www.simplecd.me/(有电驴/种子/网盘等资源链接,很有声望的一个站)

大家得以见到放进entity里的数目是ByteString。

BT天堂:http://www.bttiantang.com/(片子很多,优点是对于热门电影来说,它提供了各大压制组/各版本的资源选拔,BDRip/720p/1080p等等,另外可以通过IMDB编号来寻觅影片)

我们领会Akka-http是依照Akka-Stream的,具备Reactive-Stream效用特色。上面我们就示范一下什么样开展stream的上传下载。首先定制一个Source:

BT之家:http://bbs.1lou.com/(综合性很强,在电影方面重点是中字熟肉,方便手机/华为平板等运动装备观察)

  val numbers = Source.fromIterator(() =>
    Iterator.continually(Random.nextInt()))
    .map(n => ByteString(s"$n\n"))
  //make conform to withoutSizeLimit constrain
  val source = limitableByteSource(numbers)

顶好精品论坛(需注册):http://bmdruchinyan.com/(重点推荐,影片分类很牛逼,比如出名导演的合集/TOP
250合集/三大电影节合集/CC标准收藏合集)

服务端也是用HttpEntity来装载那些Source然后经过HttpRequest传给客户端的:

籼米论坛(需注册):http://www.iminisd.com/forum.php(据说国产片/港产片资源很强大)

  path("random") {
      get {
        complete(
          HttpEntity(
            ContentTypes.`application/octet-stream`,
            // transform each number to a chunk of bytes
            source.take(10000)
          )
        )
      } ~

KICKASS:http://kickass.to/(俗称“踢屁股”,也是个综合性种子站,新片老片应有尽有)

咱俩在客户端仍旧用runService来分析传过来的entity。由于接受一个大型的Source,所以需要修改一下收取格局代码:

RARBG:http://www.rarbg.com/torrents.php(和KICKASS差不多,可是新片的昭示速度一般更快些,而且网页排版很尴尬)

   futResp
    .andThen {
      case Success(r@HttpResponse(StatusCodes.OK, _, entity, _)) =>
        val futEnt = entity.dataBytes.map(_.utf8String).runForeach(println)
             Await.result(futEnt, Duration.Inf) // throws if binding fails
             println("End of stream!!!")
      case Success(r@HttpResponse(code, _, _, _)) =>
        println(s"Download request failed, response code: $code")
        r.discardEntityBytes()
      case Success(_) => println("Unable to download rows!")
      case Failure(err) => println(s"Download failed: ${err.getMessage}")

    }

Torrentz:http://torrentz.eu/(综合型种子搜索引擎,很多资源帝都爱用,被叫作“万金油BT站”)

用上面的法子调用:

SeeHD:http://www.seehd.org/(以高清资源为主,720p/1080p/Remux/蓝光原盘,适合收藏党)

  val reqRandom = HttpRequest(uri = s"http://localhost:8011/random")
    runService(reqRandom,HttpEntity.Empty)
     .andThen{case _ => sys.terminate()}

BTSPREAD:http://www.btspread.com/(个人重大用以更换BT文件和重力链接,也有种子搜索引擎,能够搜番号)

再示范一下在客户端用Source上传数据。服务端代码:

如上网站已经能满意大部分影迷的急需了。

       post {
          withoutSizeLimit {
            extractDataBytes { bytes =>
              val data = bytes.runFold(ByteString())(_ ++ _)
              onComplete(data) { t =>
                complete(t)
              }
            }
          }
        }

怎么?你说您逼格相比较高?这也不要紧,下边还有一对符合淘冷门电影的网站:

客户端上传数据范例:

发烧级

 val numbers = Source.fromIterator(() =>
    Iterator.continually(Random.nextInt()))
    .map(n => ByteString(s"$n\n"))
  //make conform to withoutSizeLimit constrain
  val source = limitableByteSource(numbers)

  val bytes = HttpEntity(
    ContentTypes.`application/octet-stream`,
    // transform each number to a chunk of bytes
    source.take(10000)
  )
  val postRandom = HttpRequest(HttpMethods.POST,uri = s"http://localhost:8011/random")
  runService(postRandom,bytes)
    .andThen{case _ => sys.terminate()}

假如遭逢一些豆类评分人数不足的,甚至是没有条目标电影,这个网站可能会有奇效:

从上边研商大家询问了在马尔斯hal,Unmarshal下层只是ByteString的操作和转移。下边是这一次商讨示范源代码:

Bitsnoop:http://bitsnoop.com/(资源容量高达28PB,磁力站,可以匹配地方的BTSPREAD转成种子)

服务端:

BT
Kitty:http://btkitty.org/(资源容量有24PB,即便不及下边相当,可是也很牛逼了)

import akka.actor._
import akka.stream._
import akka.stream.scaladsl._
import akka.http.scaladsl.Http
import akka.http.scaladsl.server.Directives._
import akka.http.scaladsl.model._
import akka.util.ByteString
import akka.http.scaladsl.model.HttpEntity._

import scala.util.Random

object ServerEntity extends App {

  implicit val httpSys = ActorSystem("httpSystem")
  implicit val httpMat = ActorMaterializer()
  implicit val httpEC = httpSys.dispatcher


  val numbers = Source.fromIterator(() =>
    Iterator.continually(Random.nextInt()))
    .map(n => ByteString(s"$n\n"))
  //make conform to withoutSizeLimit constrain
  val source = limitableByteSource(numbers)



  val route =
    path("random") {
      get {
        withoutSizeLimit {
          complete(
            HttpEntity(
              ContentTypes.`application/octet-stream`,
              // transform each number to a chunk of bytes
              source.take(1000))
          )
        }
      } ~
        post {
          withoutSizeLimit {
            extractDataBytes { bytes =>
              val data = bytes.runFold(ByteString())(_ ++ _)
              onComplete(data) { t =>
                complete(t)
              }
            }
          }
        }
    } ~ path("text") {
      get {
        complete("Hello World!")
      } ~
        post {
          withoutSizeLimit {
            extractDataBytes { bytes =>
              val data = bytes.runFold(ByteString())(_ ++ _)
              onComplete(data) { t =>
                complete(t)
              }
            }
          }
        }
    }


  val (port, host) = (8011,"localhost")

  val bindingFuture = Http().bindAndHandle(route,host,port)

  println(s"Server running at $host $port. Press any key to exit ...")

  scala.io.StdIn.readLine()

  bindingFuture.flatMap(_.unbind())
    .onComplete(_ => httpSys.terminate())

}

海盗湾:http://thepiratebay.ee/(自称是当前世界上最大的BT种子服务器)

客户端:

BTDigg:https://btdigg.org/(磁力站,搜索关键字的能力较强,个人最爱用的网站)

import akka.actor._
import akka.stream._
import akka.stream.scaladsl._
import akka.http.scaladsl.Http
import akka.http.scaladsl.model.HttpEntity.limitableByteSource
import akka.http.scaladsl.model._

import scala.concurrent.duration._
import akka.util.ByteString

import scala.concurrent._
import scala.util._

object ClientEntity extends App {

  implicit val sys = ActorSystem("ClientSys")
  implicit val mat = ActorMaterializer()
  implicit val ec = sys.dispatcher

  def runService(request: HttpRequest, rentity: RequestEntity) = {
   val futResp = for {
     entity <- Future.successful(rentity)
     resp <- Http(sys).singleRequest(
       request.copy(entity = rentity)
     )
   } yield resp

   futResp
    .andThen {
      case Success(r@HttpResponse(StatusCodes.OK, _, entity, _)) =>
        val futEnt = entity.dataBytes.map(_.utf8String).runForeach(println)
             Await.result(futEnt, Duration.Inf) // throws if binding fails
             println("End of stream!!!")
      case Success(r@HttpResponse(code, _, _, _)) =>
        println(s"Download request failed, response code: $code")
        r.discardEntityBytes()
      case Success(_) => println("Unable to download rows!")
      case Failure(err) => println(s"Download failed: ${err.getMessage}")

    }
  }

  val reqText = HttpRequest(uri = s"http://localhost:8011/text")
//  runService(reqText,HttpEntity.Empty)
//    .andThen{case _ => sys.terminate()}

  val postText = HttpRequest(HttpMethods.POST,uri = s"http://localhost:8011/text")
  val uploadText = HttpEntity(
    ContentTypes.`text/plain(UTF-8)`,
    // transform each number to a chunk of bytes
    ByteString("hello world again")
  )
//  runService(postText,uploadText)
//    .andThen{case _ => sys.terminate()}

  val reqRandom = HttpRequest(uri = s"http://localhost:8011/random")
 //   runService(reqRandom,HttpEntity.Empty)
 //    .andThen{case _ => sys.terminate()}

  val numbers = Source.fromIterator(() =>
    Iterator.continually(Random.nextInt()))
    .map(n => ByteString(s"$n\n"))
  //make conform to withoutSizeLimit constrain
  val source = limitableByteSource(numbers)

  val bytes = HttpEntity(
    ContentTypes.`application/octet-stream`,
    // transform each number to a chunk of bytes
    source.take(10000)
  )
  val postRandom = HttpRequest(HttpMethods.POST,uri = s"http://localhost:8011/random")
  runService(postRandom,bytes)
    .andThen{case _ => sys.terminate()}


}

ulozto:http://www.ulozto.net/(据说搜捷克影视很好用,我没试过)

 

rutracker:http://rutracker.org/forum/index.php(俄罗斯BT站)

 

Foofind(这是一个小软件,需下载安装,但自己必须提一下这款神器,搜索引擎非凡强大。可是使用比较劳碌,软件本身下载可能没速度,我的做法是下载的文书链接复制到迅雷,新建任务下载。总之,真的一流棒。感兴趣的可以下载这几个安装包。度盘:http://pan.baidu.com/s/1ntiIcsD

 

假若上述网站仍然找不到您要的录像,这就得和谐出手去其他地点找咯,继续介绍一些找电影的主意:

 

攻略级

 

Google:懒人一般不会用,但除此之外网站之外,谷歌发动机是最靠谱的找片方法了。搜索片名+download/torrent/magnet/ed2k等后缀,能找到不少冷门电影

 

豆类条目:在豆瓣电影搜索片名之后,该影片的简介页面,就叫豆瓣条目。很多个人不经意了这块地点,1、冷门影视的话,在条款的研讨区,偶尔会有热心网友给出资源下载,2、短片的话,在条款的短评区,会有热心网友给出在线寓目地址。

 

豆子小组:这一个社区可以说是高手在民间,比如“第三世界电影资源”这种小组,里面会有过多珍爱片源,玩豆瓣的朋友能够逐步发掘。

 

豆瓣帮手:也叫“豆藤”,一款可以设置在火狐/chrome的浏览器插件,可以寻找电影/音乐/电子书,方便之处在于资源列表会展现在网页左边,可是搜索引擎不算很强,教程:http://t.cn/7MjEo

 

百度贴吧:贴吧精品区里有不少好东西,比如“北野武吧”就有成百上千粉丝上传的纪录片资源,“百度网盘吧”“360云盘吧”那种,偶尔会有人扔出部分容量多少个T的资源合集。

 

115天地:作为已经国内网盘的龙头,115的资源量自然不可轻视,感兴趣的可以去找一下各品种的资源领域,能找到不少好东西。

 

博客园果壳网:关注乐乎上的资源领域,会时时有惊喜哦,除了本人的@电影贩
之外,顺便推荐多少个博主,@独立鱼 @蓝影网 @猫叔Mack @狼魄乾坤 @蓝影屋
@资源人龙骧

 

盘搜工具:现在有众多网盘搜索的引擎,个人认为没多少用处了,即便能搜出来的也差不多是死链,故不引进

 

有关资源搜索的小技巧,这些才是第一,切勿错过:

 

多少片子不必然搜一个片名就能搜出来,国内的网站显要搜索闽南语名,外网首要搜索外文名。而几乎所有的片名,都可以在对应的豆瓣条目简介里面找到,当然IMDB条目也有

 

国内的网站当然相比简单,比如《血色将至》这部片,你可以搜“血色将至”、“血色黑金”、“There
威尔 Be Blood”

 

着重说下外国的网站,很多非爱沙尼亚语片,除了粤语译名之外,都会有三个片名,举个例证:

《精疲力尽》这部片,你可以搜英文名“Breathless”、法文名“à bout de
souffle”

《七勇士》这部片,你可以搜中文名“七壮士”,日文名“七人の侍”,英文名“Seven
Samurai”,但最好用的章程是寻觅阿拉伯语发音“Shichinin no
samurai”,最终一种方法是在外网搜索意大利语片的首选。

有点名字同样的名片,可以在后头加上年份,方便分别,比如希区柯克的《惊魂记》,可以搜“psycho
1960”。

想搜出高清版本的,可搜索片名+720p/1080p/bluray等后缀。

搜电影原声,可搜索片名+soundtrack/OST。

在Google上查找某个导演的合集,可以添加collection这多少个后缀,比如搜伍迪艾伦(Alan)的,“伍德(Wood)y
Allen
collection”。搜冷门片,可以用刚刚提到的办法,搜索片名+download/torrent/magnet/ed2k等后缀。

最后说说关于字幕的题目

搜索闽南语字幕,射手网:www.shooter.com.cn(已关闭)

鱼叔推荐一个新的字幕网站,算是射手的新进版本:www.subhd.com

说到底,希望那么些“不会找电影”的网友们,多多少少能从自我的这篇小说中学会找电影的技术。现在盗版资源面临的地形并不明朗,某些网站说禁止啥时候就被封杀了。院线方面又有推荐名额限制和档期珍惜。因而为了便利你们我的观影,精晓一些淘片技巧依然很有必不可少的。 
毕竟漫漫光影路,总无法直接做伸手党。依旧这句话,没有牛逼的资源帝,唯有劳碌的搬运工。