คำเตือน: API นี้เลิกใช้แล้วและจะถูกลบออกใน TensorFlow เวอร์ชันอนาคตหลังจากที่ การแทนที่ มีเสถียรภาพ
Server
จัดทุกอย่างให้เป็นระเบียบอยู่เสมอด้วยคอลเล็กชัน
บันทึกและจัดหมวดหมู่เนื้อหาตามค่ากำหนดของคุณ
เซิร์ฟเวอร์ TensorFlow ในกระบวนการ สำหรับใช้ในการฝึกอบรมแบบกระจาย
อินสแตนซ์ Server
สรุปชุดอุปกรณ์และเป้าหมาย Session
ที่สามารถเข้าร่วมการฝึกอบรมแบบกระจายได้ เซิร์ฟเวอร์เป็นของคลัสเตอร์ (ระบุโดย ClusterSpec
) และสอดคล้องกับงานเฉพาะในงานที่กำหนดชื่อ เซิร์ฟเวอร์สามารถสื่อสารกับเซิร์ฟเวอร์อื่น ๆ ในคลัสเตอร์เดียวกันได้ เซิร์ฟเวอร์จะไม่ให้บริการคำขอใด ๆ จนกว่าจะมีการเรียกใช้ start()
เซิร์ฟเวอร์จะหยุดให้บริการคำขอเมื่อมีการเรียกใช้ stop()
หรือ close()
โปรดทราบว่าเมธอด close()
จะหยุดเซิร์ฟเวอร์หากเซิร์ฟเวอร์กำลังทำงานอยู่
คำเตือน: Server
เป็นเจ้าของทรัพยากรที่ ต้องได้ รับการปลดปล่อยอย่างชัดเจนโดยการเรียกใช้ close()
อินสแตนซ์ของ Server
เป็นแบบปลอดภัยสำหรับเธรด
ใช้ตัวอย่าง:
import org.tensorflow.Server;
import org.tensorflow.distruntime.ClusterDef;
import org.tensorflow.distruntime.JobDef;
import org.tensorflow.distruntime.ServerDef;
ClusterDef clusterDef = ClusterDef.newBuilder()
.addJob(JobDef.newBuilder()
.setName("worker")
.putTasks(0, "localhost:4321")
.build()
).build();
ServerDef serverDef = ServerDef.newBuilder()
.setCluster(clusterDef)
.setJobName("worker")
.setTaskIndex(0)
.setProtocol("grpc")
.build();
try (Server srv = new Server(serverDef.toByteArray())) {
srv.start();
srv.join();
}
คอนสตรัคชั่นสาธารณะ
| เซิร์ฟเวอร์ (ไบต์[] serverDef) สร้างอินสแตนซ์ใหม่ของเซิร์ฟเวอร์ |
วิธีการสาธารณะ
โมฆะที่ซิงโครไนซ์กัน | ปิด () ทำลายเซิร์ฟเวอร์ TensorFlow ที่อยู่ในกระบวนการ เพิ่มหน่วยความจำ |
เป็นโมฆะ | เข้าร่วม () บล็อกจนกว่าเซิร์ฟเวอร์จะหยุดทำงานสำเร็จ |
โมฆะที่ซิงโครไนซ์กัน | เริ่ม () เริ่มเซิร์ฟเวอร์ TensorFlow ในกระบวนการ |
โมฆะที่ซิงโครไนซ์กัน | หยุด () หยุดเซิร์ฟเวอร์ TensorFlow ที่กำลังดำเนินการ |
วิธีการสืบทอด
จากคลาส java.lang.Object บูลีน | เท่ากับ (วัตถุ arg0) |
คลาสสุดท้าย<?> | รับคลาส () |
ภายใน | แฮชโค้ด () |
โมฆะสุดท้าย | แจ้ง () |
โมฆะสุดท้าย | แจ้งทั้งหมด () |
สตริง | toString () |
โมฆะสุดท้าย | รอสักครู่ (ยาว arg0, int arg1) |
โมฆะสุดท้าย | รอ (ยาว arg0) |
โมฆะสุดท้าย | รอ () |
จากอินเทอร์เฟซ java.lang.AutoCloseable ความว่างเปล่าที่เป็นนามธรรม | ปิด () |
คอนสตรัคชั่นสาธารณะ
เซิร์ฟเวอร์ สาธารณะ (ไบต์ [] serverDef)
สร้างอินสแตนซ์ใหม่ของเซิร์ฟเวอร์
พารามิเตอร์
เซิร์ฟเวอร์Def | ข้อกำหนดของเซิร์ฟเวอร์ที่ระบุเป็นบัฟเฟอร์โปรโตคอล ServerDef แบบอนุกรม |
---|
วิธีการสาธารณะ
โมฆะซิงโครไนซ์สาธารณะ ปิด ()
ทำลายเซิร์ฟเวอร์ TensorFlow ที่อยู่ในกระบวนการ เพิ่มหน่วยความจำ
โมฆะสาธารณะ เข้าร่วม ()
บล็อกจนกว่าเซิร์ฟเวอร์จะหยุดทำงานสำเร็จ
การซิงโครไนซ์สาธารณะ เริ่มต้นเป็น โมฆะ ()
เริ่มเซิร์ฟเวอร์ TensorFlow ในกระบวนการ
โมฆะหยุด การซิงโครไนซ์สาธารณะ ()
หยุดเซิร์ฟเวอร์ TensorFlow ที่กำลังดำเนินการ
เนื้อหาของหน้าเว็บนี้ได้รับอนุญาตภายใต้ใบอนุญาตที่ต้องระบุที่มาของครีเอทีฟคอมมอนส์ 4.0 และตัวอย่างโค้ดได้รับอนุญาตภายใต้ใบอนุญาต Apache 2.0 เว้นแต่จะระบุไว้เป็นอย่างอื่น โปรดดูรายละเอียดที่นโยบายเว็บไซต์ Google Developers Java เป็นเครื่องหมายการค้าจดทะเบียนของ Oracle และ/หรือบริษัทในเครือ
อัปเดตล่าสุด 2025-07-26 UTC
[null,null,["อัปเดตล่าสุด 2025-07-26 UTC"],[],[],null,["# Server\n\npublic final class **Server** \nAn in-process TensorFlow server, for use in distributed training.\n\nA `Server` instance encapsulates a set of devices and a [Session](/api_docs/java/org/tensorflow/Session)\ntarget that can participate in distributed training. A server belongs to a cluster (specified by\na `ClusterSpec`), and corresponds to a particular task in a named job. The server can\ncommunicate with any other server in the same cluster. The server will not serve any requests\nuntil [start()](/api_docs/java/org/tensorflow/Server#start()) is invoked. The server will stop serving requests once [stop()](/api_docs/java/org/tensorflow/Server#stop()) or\n[close()](/api_docs/java/org/tensorflow/Server#close()) is invoked. Be aware that [close()](/api_docs/java/org/tensorflow/Server#close()) method stops the server if it is\nrunning.\n\n**WARNING:** A `Server` owns resources that **must** be explicitly freed by\ninvoking [close()](/api_docs/java/org/tensorflow/Server#close()).\n\nInstances of a `Server` are thread-safe.\n\nUsing example:\n\n import org.tensorflow.Server;\n import org.tensorflow.distruntime.ClusterDef;\n import org.tensorflow.distruntime.JobDef;\n import org.tensorflow.distruntime.ServerDef;\n\n ClusterDef clusterDef = ClusterDef.newBuilder()\n .addJob(JobDef.newBuilder()\n .setName(\"worker\")\n .putTasks(0, \"localhost:4321\")\n .build()\n ).build();\n\n ServerDef serverDef = ServerDef.newBuilder()\n .setCluster(clusterDef)\n .setJobName(\"worker\")\n .setTaskIndex(0)\n .setProtocol(\"grpc\")\n .build();\n\n try (Server srv = new Server(serverDef.toByteArray())) {\n srv.start();\n srv.join();\n }\n \n\u003cbr /\u003e\n\n\u003cbr /\u003e\n\n\u003cbr /\u003e\n\n\u003cbr /\u003e\n\n\u003cbr /\u003e\n\n### Public Constructors\n\n|---|------------------------------------------------------------------------------------------------------------------------|\n| | [Server](/api_docs/java/org/tensorflow/Server#Server(byte[]))(byte\\[\\] serverDef) Constructs a new instance of server. |\n\n### Public Methods\n\n|-------------------|----------------------------------------------------------------------------------------------------------------|\n| synchronized void | [close](/api_docs/java/org/tensorflow/Server#close())() Destroy an in-process TensorFlow server, frees memory. |\n| void | [join](/api_docs/java/org/tensorflow/Server#join())() Blocks until the server has been successfully stopped. |\n| synchronized void | [start](/api_docs/java/org/tensorflow/Server#start())() Starts an in-process TensorFlow server. |\n| synchronized void | [stop](/api_docs/java/org/tensorflow/Server#stop())() Stops an in-process TensorFlow server. |\n\n### Inherited Methods\n\nFrom class java.lang.Object \n\n|------------------|---------------------------|\n| boolean | equals(Object arg0) |\n| final Class\\\u003c?\\\u003e | getClass() |\n| int | hashCode() |\n| final void | notify() |\n| final void | notifyAll() |\n| String | toString() |\n| final void | wait(long arg0, int arg1) |\n| final void | wait(long arg0) |\n| final void | wait() |\n\nFrom interface java.lang.AutoCloseable \n\n|---------------|---------|\n| abstract void | close() |\n\nPublic Constructors\n-------------------\n\n#### public\n**Server**\n(byte\\[\\] serverDef)\n\nConstructs a new instance of server. \n\n##### Parameters\n\n| serverDef | Server definition specified as a serialized [ServerDef](https://github.com/tensorflow/tensorflow/blob/master/tensorflow/core/protobuf/tensorflow_server.proto) protocol buffer. |\n|-----------|---------------------------------------------------------------------------------------------------------------------------------------------------------------------------------|\n\nPublic Methods\n--------------\n\n#### public synchronized void\n**close**\n()\n\nDestroy an in-process TensorFlow server, frees memory. \n\n##### Throws\n\n| InterruptedException | |\n|----------------------|---|\n\n#### public void\n**join**\n()\n\nBlocks until the server has been successfully stopped. \n\n#### public synchronized void\n**start**\n()\n\nStarts an in-process TensorFlow server. \n\n#### public synchronized void\n**stop**\n()\n\nStops an in-process TensorFlow server."]]