1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
| #include <netdb.h>
#include <netinet/in.h>
#include <unistd.h>
#include <iostream>
#include <fstream>
#include <string.h>
#include <stdlib.h>
#include "protocol.pb.h"
#include <string>
#include <cstring>
#define MAX_LINE 100
// 3 caractères pour les codes ASCII 'cr', 'lf' et '\0'
#define LINE_ARRAY_SIZE (MAX_LINE+3)
using namespace std;
int main()
{
//GOOGLE_PROTOBUF_VERIFY_VERSION;
test::Error_Info test_msg;
/*
test_msg.set_from(1);
test_msg.set_to(2);
test_msg.set_msg("toto");
*/
test_msg.set_id(1);
test_msg.set_severity(test::Error_Info_Severity_Severity_MAX);
int socketDescriptor;
int numRead;
unsigned short int serverPort;
struct sockaddr_in serverAddress;
struct hostent *hostInfo;
struct timeval timeVal;
fd_set readSet;
char buf[LINE_ARRAY_SIZE], c;
cout << "Enter server host name or IP address: ";
memset(buf, 0x0, LINE_ARRAY_SIZE); // Mise à zéro du tampon
94. cin.get(buf, MAX_LINE, '\n');
// gethostbyname() reçoit un nom d'hôte ou une adresse IP en notation
// standard 4 octets en décimal séparés par des points puis renvoie un
// pointeur sur une structure hostent. Nous avons besoin de cette structure
// plus loin. La composition de cette structure n'est pas importante pour
// l'instant.
hostInfo = gethostbyname(buf);
if (hostInfo == NULL) {
cout << "problem interpreting host: " << buf << "\n";
exit(1);
}
cout << "Enter server port number: ";
cin >> serverPort;
cin.ignore(1,'\n'); // suppression du saut de ligne
// Création de socket. "AF_INET" correspond à l'utilisation du protocole IPv4
// au niveau réseau. "SOCK_DGRAM" correspond à l'utilisation du protocole UDP
// au niveau transport. La valeur 0 indique qu'un seul protocole sera utilisé
// avec ce socket.
socketDescriptor = socket(AF_INET, SOCK_STREAM, 0);
if (socketDescriptor < 0) {
cerr << "cannot create socket\n";
exit(1);
}
// Initialisation des champs de la structure serverAddress
serverAddress.sin_family = hostInfo->h_addrtype;
memcpy((char *) &serverAddress.sin_addr.s_addr,
hostInfo->h_addr_list[0], hostInfo->h_length);
serverAddress.sin_port = htons(serverPort);
cout << "\nEntrez quelques caractères au clavier.\n";
cout << "Le serveur les modfiera et les renverra.\n";
cout << "Pour sortir, entrez une ligne avec le caractère '.' uniquement\n";
cout << "Si une ligne dépasse " << MAX_LINE << " caractères,\n";
cout << "seuls les " << MAX_LINE << " premiers caractères seront utilisés.\n\n";
// Invite de commande pour l'utilisateur et lecture des caractères jusqu'à la
// limite MAX_LINE. Puis suppression du saut de ligne.
cout << "Input: ";
memset(buf, 0x0, LINE_ARRAY_SIZE); // Zero out the buffer.
cin.get(buf, MAX_LINE, '\n');
// suppression des caractères supplémentaires et du saut de ligne
cin.ignore(1000,'\n');
string data;
test_msg.SerializeToString(&data);
// Arrêt lorsque l'utilisateur saisit une ligne ne contenant qu'un point
while (strcmp(buf, ".")) {
// Envoi de la ligne au serveur
if (sendto(socketDescriptor, data.c_str(), strlen(data.c_str()), 0,
(struct sockaddr *) &serverAddress,
sizeof(serverAddress)) < 0) {
cerr << "cannot send data ";
close(socketDescriptor);
exit(1);
}
/*
while (strcmp(buf, ".")) {
// Envoi de la ligne au serveur
if (sendto(socketDescriptor, buf, strlen(buf), 0,
(struct sockaddr *) &serverAddress,
sizeof(serverAddress)) < 0) {
cerr << "cannot send data ";
close(socketDescriptor);
exit(1);
}
*/
// Attente de la réponse pendant une seconde.
FD_ZERO(&readSet);
FD_SET(socketDescriptor, &readSet);
timeVal.tv_sec = 1;
timeVal.tv_usec = 0;
if (select(socketDescriptor+1, &readSet, NULL, NULL, &timeVal)) {
// Lecture de la ligne modifiée par le serveur.
memset(buf, 0x0, LINE_ARRAY_SIZE); // Mise à zéro du tampon
numRead = recv(socketDescriptor, buf, MAX_LINE, 0);
if (numRead < 0) {
cerr << "didn't get response from server?";
close(socketDescriptor);
exit(1);
}
cout << "Modified: " << buf << "\n";
}
else {
cout << "** Server did not respond in 1 second.\n";
}
// Invite de commande pour l'utilisateur et lecture des caractères jusqu'à la
// limite MAX_LINE. Puis suppression du saut de ligne. Comme ci-dessus.
cout << "Input: ";
memset(buf, 0x0, LINE_ARRAY_SIZE); // Mise à zéro du tampon
cin.get(buf, MAX_LINE, '\n');
// suppression des caractères supplémentaires et du saut de ligne
cin.ignore(1000,'\n');
}
close(socketDescriptor);
return 0;
} |
Communication via Socket TCP
Répondre avec citation
Cafuro est un outil SNMP dont le but est d'aider les administrateurs système et réseau à configurer leurs équipements SNMP réseau.
Envoyé par onet
Partager