（8）Linux（客戶端）和Windows（服務端）下socket通訊實例

Linux（客戶端）和Windows（服務端）下socket通訊實例：

（1）首先是Windows作客戶端，Linux作服務端的程序

Windows   Client端

1. #include <stdio.h>
2. #include <Windows.h>
3. #pragma comment(lib, "ws2_32.lib")
4. #define Port 5000
5. #define IP_ADDRESS "192.168.1.30"     //服務器地址
6. int main() // argc是命令行總的參數個數
7. {
8. WSADATA s; // 用來儲存調用AfxSocketInit全局函數返回的Windows Sockets初始化信息
9. SOCKET ClientSocket;
10. struct sockaddr_in ClientAddr; // 一個sockaddr_in型的結構體對象
11. int ret = 0;
12. char SendBuffer[MAX_PATH]; // Windows的MAX_PATH默認是260
13. // 初始化Windows Socket
14. // WSAStartup函數對Winsock服務的初始化
15. if (WSAStartup(MAKEWORD(2, 2), &s) != 0) // 經過鏈接兩個給定的無符號參數,首個參數爲低字節
16. {
17. printf("Init Windows Socket Failed! Error: %d\n", GetLastError());
18. getchar();
19. return -1;
20. }
21. while (1)
22. {
23. // 建立一個套接口
24. // 若是這樣一個套接口用connect()與一個指定端口鏈接
25. // 則可用send()和recv()與該端口進行數據報的發送與接收
26. // 當會話結束後，調用closesocket()
27. ClientSocket = socket(AF_INET, // 只支持ARPA Internet地址格式
28. SOCK_STREAM, // 新套接口的類型描述
29. IPPROTO_TCP); // 套接口所用的協議
30. if (ClientSocket == INVALID_SOCKET)
31. {
32. printf("Create Socket Failed! Error: %d\n", GetLastError());
33. getchar();
34. return -1;
35. }
36. ClientAddr.sin_family = AF_INET;
37. ClientAddr.sin_addr.s_addr = inet_addr(IP_ADDRESS); // 定義IP地址
38. ClientAddr.sin_port = htons(Port); // 將主機的無符號短整形數轉換成網絡字節順序
39. memset(ClientAddr.sin_zero, 0X00, 8); // 函數一般爲新申請的內存作初始化工做
40. // 鏈接Socket
41. ret = connect(ClientSocket,
42. (struct sockaddr*)&ClientAddr,
43. sizeof(ClientAddr));
44. if (ret == SOCKET_ERROR)
45. {
46. printf("Socket Connect Failed! Error:%d\n", GetLastError());
47. getchar();
48. return -1;
49. }
50. else
51. {
52. printf("Socket Connect Succeed!");
53. }
54. printf("Input Data: ");
55. while (1)
56. {
57. scanf("%s", &SendBuffer);
58. // 發送數據至服務器
59. ret = send(ClientSocket,
60. SendBuffer,
61. (int)strlen(SendBuffer), // 返回發送緩衝區數據長度
62. 0);
63. if (ret == SOCKET_ERROR)
64. {
65. printf("Send Information Failed! Error:%d\n", GetLastError());
66. getchar();
67. break;
68. }
69. break;
70. }
71. // 關閉socket
72. closesocket(ClientSocket);
73. if (SendBuffer[0] == 'q') // 設定輸入第一個字符爲q時退出
74. {
75. printf("Quit!\n");
76. break;
77. }
78. }
79. WSACleanup();
80. getchar();
81. system("pause");
82. return 0;
83. }

Linux server端

1. #include <stdio.h>
2. #include <sys/socket.h>
3. #include <sys/types.h> /* See NOTES */
4. #include <sys/socket.h>
5. #include <arpa/inet.h>
6. #include <string.h>
7. #include<unistd.h>
8. #include <cstdlib>
10. #define SERVER_PORT 5000
11. #define LENGTH_OF_LISTEN_QUEUE 20
12. #define BUFFER_SIZE 10
13. int main() // (int argc, char* argv[])
14. {
15. struct sockaddr_in server_addr;
16. int server_socket;
17. int opt = 1;
18. bzero(&server_addr, sizeof(server_addr)); // 置字節字符串前n個字節爲0，包括'\0'
19. server_addr.sin_family = AF_INET;
20. server_addr.sin_addr.s_addr = htons(INADDR_ANY); // 轉小端,INADDR_ANY就是指定地址爲0.0.0.0的地址
21. server_addr.sin_port = htons(SERVER_PORT);
22. // 建立一個Socket
23. server_socket = socket(PF_INET, SOCK_STREAM, 0);
24. if (server_socket < 0)
25. {
26. printf("Create Socket Failed!\n");
27. exit(1);
28. }
30. // bind a socket
31. setsockopt(server_socket, SOL_SOCKET, SO_REUSEADDR, &opt, sizeof(opt));
32. if(bind(server_socket, (struct sockaddr*)&server_addr, sizeof(server_addr)))
33. {
34. printf("Server Bind Port: %d Failed!\n", SERVER_PORT);
35. exit(1);
36. }
37. // 監聽Socket
38. if (listen(server_socket, LENGTH_OF_LISTEN_QUEUE))
39. {
40. printf("Server Listen Failed!\n");
41. exit(1);
42. }
43. while(1)
44. {
45. struct sockaddr_in client_addr;
46. int client_socket;
47. socklen_t length;
48. char Buffer[BUFFER_SIZE];
49. // 鏈接客戶端Socket
50. length = sizeof(client_addr);
51. client_socket = accept(server_socket, (struct sockaddr*)&client_addr, &length);
52. if (client_socket < 0)
53. {
54. printf("Server Accept Failed!\n");
55. break;
56. }
57. // 從客戶端接收數據
58. while(1)
59. {
60. bzero(Buffer, BUFFER_SIZE);
61. length = recv(client_socket, Buffer, BUFFER_SIZE, 0);
62. if (length < 0)
63. {
64. printf("Server Recieve Data Failed!\n");
65. break;
66. }
67. if ('q' == Buffer[0])
68. {
69. printf("Quit!\n");
70. break;
71. }
72. printf("%s\n", Buffer);
73. break;
74. }
75. close(client_socket);
76. }
77. close(server_socket);
78. return 0;
79. }

（2）Windows作服務端，Linux作客戶端實例  傳輸視頻

windows端：

 

#include <stdio.h>

 

#include <string>

 

#include <iostream>

 

#include <Winsock2.h>

 

#include <opencv2/opencv.hpp>

 

#include <vector>

 

#include "globalsetting.h"

 

#pragma comment(lib,"ws2_32.lib")

 

/**

 

 * OpenCV video streaming over TCP/IP

 

 * Client: Receives video from server and display it

 

 * Created by Wu yongcong 2017-8-24

 

 */

 

 

using namespace cv;

 

using namespace std;

 

 

 

int main()

 

{

 

 

    //--------------------------------------------------------

 

    //networking stuff: socket , connect

 

    //--------------------------------------------------------

 

    WSADATA wsaData;

 

    SOCKET sockClient;//客戶端Socket

 

    SOCKADDR_IN addrServer;//服務端地址

 

    WSAStartup(MAKEWORD(2, 2), &wsaData);

 

 

    //新建客戶端socket

 

    sockClient = socket(AF_INET, SOCK_STREAM, 0);

 

    //定義要鏈接的服務端地址

 

    addrServer.sin_addr.S_un.S_addr = inet_addr(SOCKET_IP); //服務端IP

 

    addrServer.sin_family = AF_INET;

 

    addrServer.sin_port = htons(SOCKET_PORT);//服務端鏈接端口

 

 

    //鏈接到服務端

 

    connect(sockClient, (SOCKADDR*)&addrServer, sizeof(SOCKADDR));

 

 

 

    //----------------------------------------------------------

 

    //OpenCV Code

 

    //----------------------------------------------------------

 

 

    Mat img;

 

    img = Mat::zeros(480 , 640, CV_8UC3);//CV_8UC3表明是三通道

 

    int imgSize = img.total() * img.elemSize();

 

    uchar *iptr = img.data;

 

    int bytes = 0;

 

    int key;

 

 

    //make img continuos

 

    if ( ! img.isContinuous() ) {

 

          img = img.clone();

 

    }

 

 

    std::cout << "Image Size:" << imgSize << std::endl;

 

 

 

    namedWindow("CV Video Client",1);

 

 

    while (key != 'q') {

 

 

        if ((bytes = recv(sockClient, (char *)iptr, imgSize , MSG_WAITALL)) == -1) {

 

            std::cerr << "recv failed, received bytes = " << bytes << std::endl;

 

 

        }

 

 

        cv::imshow("CV Video Client", img);

 

 

        if (key = cv::waitKey(10) >= 0) break;

 

    }

 

 

    closesocket(sockClient);

 

    WSACleanup();

 

    return 0;

 

}

 

 

linux端：
編譯命令：

g++ `pkg-config --cflags opencv` -o server -pthread socketServer.cpp `pkg-config --libs opencv`

 

1. #include "opencv2/opencv.hpp"
2. #include <iostream>
3. #include <sys/socket.h>
4. #include <arpa/inet.h>
5. #include <sys/ioctl.h>
6. #include <net/if.h>
7. #include <unistd.h>
8. #include <string.h>
9. #include <stdio.h>
10. #include <stdlib.h>
11. #include <pthread.h>
12. #include "socketSetting.h"
13. /*
14. * Created by Wu yongcong 2017-8-25
15. *
16. * socket transfer video server
17. *
18. */
19. using namespace cv;
20. using namespace std;
21. void *display(void *);
23. VideoCapture cap(CAMMER_PORT); // open the default camera
26. int main(int argc, char** argv)
27. {
28. //--------------------------------------------------------
29. //networking stuff: socket, bind, listen
30. //--------------------------------------------------------
31. int localSocket,
32. remoteSocket,
33. port = IP_PORT;
34. struct sockaddr_in localAddr,
35. remoteAddr;
36. pthread_t thread_id;
39. int addrLen = sizeof(struct sockaddr_in);
41. localSocket = socket(AF_INET , SOCK_STREAM , 0);
42. if (localSocket == -1){
43. perror("socket() call failed!!");
44. }
45. localAddr.sin_family = AF_INET;
46. localAddr.sin_addr.s_addr = INADDR_ANY;
47. localAddr.sin_port = htons( port );
48. if( bind(localSocket,(struct sockaddr *)&localAddr , sizeof(localAddr)) < 0) {
49. perror("Can't bind() socket");
50. exit(1);
51. }
53. //Listening
54. listen(localSocket , 3);
56. std::cout << "Waiting for connections...\n"
57. << "Server Port:" << port << std::endl;
58. //accept connection from an incoming client
59. while(1){
60. remoteSocket = accept(localSocket, (struct sockaddr *)&remoteAddr, (socklen_t*)&addrLen);
62. if (remoteSocket < 0) {
63. perror("accept failed!");
64. exit(1);
65. }
66. std::cout << "Connection accepted" << std::endl;
67. pthread_create(&thread_id,NULL,display,&remoteSocket);
68. //pthread_join(thread_id,NULL);
69. }
70. //pthread_join(thread_id,NULL);
71. //close(remoteSocket);
72. return 0;
73. }
74. void *display(void *ptr){
75. int socket = *(int *)ptr;
76. //OpenCV Code
77. //----------------------------------------------------------
78. Mat img, imgGray,imgColor;
79. img = Mat::zeros(480,640,CV_8UC3);
81. //make it continuous
82. if (!img.isContinuous()) {
83. img = img.clone();
84. }
85. // int imgSize = img.total() * img.elemSize();
86. int imgSize = img.total() * img.channels();
87. int bytes = 0;
88. int key;
91. //make img continuos
92. if ( !img.isContinuous() ) {
93. img = img.clone();
94. imgGray = img.clone();
96. }
98. std::cout << "Image Size:" << imgSize << std::endl;
99. while(1) {
101. /* get a frame from camera */
102. cap >> img;
103. if (img.empty()) break;
105. //cvtColor(img, imgGray, CV_RGB2GRAY); // color change
108. //send processed image
109. if ((bytes = send(socket, img.data, imgSize, 0)) < 0){
110. std::cerr << "bytes = " << bytes << std::endl;
111. break;
112. }
113. }
114. }