通過VMCI實現VMware虛擬機與實體機、虛擬機與虛擬機的通信

虛擬機交流接口VMCI(The Virtual Machine Communication Interface)是一個在一個或多個虛擬機與宿主機之間提供高速高效交流的基本組件(infrastructure)。

以前，VMware提供了VMCI SDK用于VMCI開發，現在用VMCI套接字庫(VMCI Sockets library)代替了SDK。

下面給出根據VMCI Sockets library編寫的示例代碼：

// client.cpp : 定義控制臺應用程序的入口點。

//

#include "stdafx.h"

#include <stdio.h>

#include <vmci_sockets.h>

#include <WinSock2.h>

#include <WS2tcpip.h>

#define BUFSIZE 4096

#pragma comment(lib, "ws2_32")

int _tmain(int argc, _TCHAR* argv[])

{

    WSADATA wsaData = { 0 };

    struct sockaddr_vm their_addr = { 0 };

    struct sockaddr_vm my_addr = { 0 };

    int err = WSAStartup(MAKEWORD(2, 2), &wsaData);

    if (err != 0) {

        printf("Could not register with Winsock DLL.\n");

        goto cleanup;

    }

    SOCKET sockfd = INVALID_SOCKET;

    int afVMCI = VMCISock_GetAFValue();

    if ((sockfd = socket(afVMCI, SOCK_STREAM, 0)) == -1) {

        printf("socket");

        goto exit;

    }

    their_addr.svm_family = afVMCI;

   // their_addr.svm_cid = VMCISock_GetLocalCID(); // 獲取本機的CID

    their_addr.svm_cid = 2; // 2是筆者在實體機上獲取的CID，讀者可自行調用VMCISock_GetLocalCID獲取指定機器的CID

    their_addr.svm_port = 12345;

    if ((connect(sockfd, (struct sockaddr *) &their_addr, sizeof their_addr)) == -1) {

        printf("connect err %d\n", WSAGetLastError());

        goto close;

    }

    char send_buf[BUFSIZE];

    strcpy_s(send_buf, BUFSIZE, "hello\n");

    while (true)

    {

        int numbytes = 0;

        /* Initialize send_buf with your data. */

        if ((numbytes = send(sockfd, send_buf, strlen(send_buf), 0)) == -1) {

            printf("send err %d\n", WSAGetLastError());

            goto close;

        }

        printf("send %s\n", send_buf);

        Sleep(5 * 1000);

    }

close:

    closesocket(sockfd);

exit:

cleanup :

    WSACleanup();

    return 0;

}

// server.cpp : 定義控制臺應用程序的入口點。

//

#include "stdafx.h"

#include <stdio.h>

#include <vmci_sockets.h>

#include <WinSock2.h>

#include <WS2tcpip.h>

#define BUFSIZE 4096

#pragma comment(lib, "ws2_32")

int _tmain(int argc, _TCHAR* argv[])

{

    WSADATA wsaData = { 0 };

    struct sockaddr_vm my_addr = { 0 };

    int err = WSAStartup(MAKEWORD(2, 2), &wsaData);

    if (err != 0) {

        printf("Could not register with Winsock DLL.\n");

        goto cleanup;

    }

    int afVMCI = VMCISock_GetAFValue();

    SOCKET sockfd = INVALID_SOCKET;

    if ((sockfd = socket(afVMCI, SOCK_STREAM, 0)) == -1) {

        perror("socket");

        goto cleanup;

    }

    my_addr.svm_family = afVMCI;

    my_addr.svm_cid = VMADDR_CID_ANY;

    my_addr.svm_port = 12345;

    if (bind(sockfd, (struct sockaddr *) &my_addr, sizeof my_addr) == -1) {

        printf("bind");

        goto close;

    }

    if (listen(sockfd, 5) == -1) {

        perror("listen");

        goto close;

    }

    struct sockaddr_vm their_addr;

    socklen_t their_addr_len = sizeof their_addr;

    SOCKET newfd = INVALID_SOCKET;

    if ((newfd = accept(sockfd, (struct sockaddr *) &their_addr, &their_addr_len)) == -1) {

        printf("accept err %d\n", WSAGetLastError());

        goto close;

    }

    while (true)

    {

        char recv_buf[BUFSIZE];

        int numbytes = 0;

        if ((numbytes = recv(newfd, recv_buf, sizeof recv_buf, 0)) == -1) {

            printf("recv err %d\n", WSAGetLastError());

            goto close;

        }

        recv_buf[numbytes] = '\0';

        printf(recv_buf);

        if ((numbytes = send(newfd, recv_buf, numbytes, 0)) == -1) {

            printf("send err %d\n", WSAGetLastError());

            goto close;

        }

    }

close:

    closesocket(sockfd);

    closesocket(newfd);

cleanup:

    WSACleanup();

    return 0;

}