Server
Sử dụng bộ sưu tập để sắp xếp ngăn nắp các trang
Lưu và phân loại nội dung dựa trên lựa chọn ưu tiên của bạn.
Máy chủ TensorFlow đang trong quá trình sử dụng để đào tạo phân tán.
Phiên bản Server
đóng gói một tập hợp thiết bị và mục tiêu Session
có thể tham gia đào tạo phân tán. Một máy chủ thuộc về một cụm (được chỉ định bởi ClusterSpec
) và tương ứng với một tác vụ cụ thể trong công việc được đặt tên. Máy chủ có thể giao tiếp với bất kỳ máy chủ nào khác trong cùng một cụm. Máy chủ sẽ không phục vụ bất kỳ yêu cầu nào cho đến khi start()
được gọi. Máy chủ sẽ ngừng cung cấp các yêu cầu sau khi gọi lệnh stop()
hoặc close()
. Xin lưu ý rằng phương thức close()
sẽ dừng máy chủ nếu nó đang chạy.
CẢNH BÁO: Server
sở hữu các tài nguyên phải được giải phóng rõ ràng bằng cách gọi close()
.
Các phiên bản của Server
đều an toàn theo luồng.
Sử dụng ví dụ:
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();
}
Nhà xây dựng công cộng
| Máy chủ (byte[] serverDef) Xây dựng một phiên bản mới của máy chủ. |
Phương pháp công khai
khoảng trống đồng bộ | đóng () Phá hủy máy chủ TensorFlow đang xử lý, giải phóng bộ nhớ. |
trống rỗng | tham gia () Chặn cho đến khi máy chủ được dừng thành công. |
khoảng trống đồng bộ | bắt đầu () Khởi động máy chủ TensorFlow đang xử lý. |
khoảng trống đồng bộ | dừng lại () Dừng máy chủ TensorFlow đang xử lý. |
Phương pháp kế thừa
Từ lớp java.lang.Object boolean | bằng (Đối tượng arg0) |
Lớp cuối cùng<?> | getClass () |
int | mã băm () |
khoảng trống cuối cùng | thông báo () |
khoảng trống cuối cùng | thông báoTất cả () |
Sợi dây | toString () |
khoảng trống cuối cùng | chờ đã (arg0 dài, int arg1) |
khoảng trống cuối cùng | chờ đã (arg0 dài) |
khoảng trống cuối cùng | Chờ đợi () |
Từ giao diện java.lang.AutoCloseable khoảng trống trừu tượng | đóng () |
Nhà xây dựng công cộng
Máy chủ công cộng (byte[] serverDef)
Xây dựng một phiên bản mới của máy chủ.
Thông số
máy chủDef | Định nghĩa máy chủ được chỉ định làm bộ đệm giao thức ServerDef được tuần tự hóa. |
---|
Phương pháp công khai
đóng đồng bộ công khai void ()
Phá hủy máy chủ TensorFlow đang xử lý, giải phóng bộ nhớ.
tham gia void công khai ()
Chặn cho đến khi máy chủ được dừng thành công.
bắt đầu khoảng trống được đồng bộ hóa công khai ()
Khởi động máy chủ TensorFlow đang xử lý.
dừng đồng bộ công khai ()
Dừng máy chủ TensorFlow đang xử lý.
Trừ phi có lưu ý khác, nội dung của trang này được cấp phép theo Giấy phép ghi nhận tác giả 4.0 của Creative Commons và các mẫu mã lập trình được cấp phép theo Giấy phép Apache 2.0. Để xem chi tiết, vui lòng tham khảo Chính sách trên trang web của Google Developers. Java là một nhãn hiệu đã đăng ký của Oracle và/hoặc các đơn vị liên kết của Oracle. Một số nội dung được cấp phép theo giấy phép numpy.
Cập nhật lần gần đây nhất: 2025-07-27 UTC.
[null,null,["Cập nhật lần gần đây nhất: 2025-07-27 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](/versions/r2.14/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()](/versions/r2.14/api_docs/java/org/tensorflow/Server#start()) is invoked. The server will stop serving requests once [stop()](/versions/r2.14/api_docs/java/org/tensorflow/Server#stop()) or\n[close()](/versions/r2.14/api_docs/java/org/tensorflow/Server#close()) is invoked. Be aware that [close()](/versions/r2.14/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()](/versions/r2.14/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](/versions/r2.14/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](/versions/r2.14/api_docs/java/org/tensorflow/Server#close())() Destroy an in-process TensorFlow server, frees memory. |\n| void | [join](/versions/r2.14/api_docs/java/org/tensorflow/Server#join())() Blocks until the server has been successfully stopped. |\n| synchronized void | [start](/versions/r2.14/api_docs/java/org/tensorflow/Server#start())() Starts an in-process TensorFlow server. |\n| synchronized void | [stop](/versions/r2.14/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."]]