通过VMCI实现VMware虚拟机与实体机、虚拟机与虚拟机的通信

虚拟机交流接口VMCI(The Virtual Machine Communication Interface)是一个在一个或多个虚拟机与宿主机之间提供高速高效交流的基本组件(infrastructure)。

创新互联于2013年创立，是专业互联网技术服务公司，拥有项目成都网站设计、成都网站建设网站策划，项目实施与项目整合能力。我们以让每一个梦想脱颖而出为使命，1280元河津做网站,已为上家服务,为河津各地企业和个人服务,联系电话:18980820575

以前，VMware提供了VMCI SDK用于VMCI开发，现在用VMCI套接字库(VMCI Sockets library)代替了SDK。

下面给出根据VMCI Sockets library编写的示例代码：

// client.cpp : 定义控制台应用程序的入口点。

//

#include "stdafx.h"

#include 

#include 

#include 

#include 

#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 

#include 

#include 

#include 

#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;

}